170 lines
		
	
	
		
			4.7 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
			
		
		
	
	
			170 lines
		
	
	
		
			4.7 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
| // Package server is an interface for a micro server
 | |
| package server // import "go.unistack.org/micro/v3/server"
 | |
| 
 | |
| import (
 | |
| 	"context"
 | |
| 	"time"
 | |
| 
 | |
| 	"go.unistack.org/micro/v3/codec"
 | |
| 	"go.unistack.org/micro/v3/metadata"
 | |
| 	"go.unistack.org/micro/v3/register"
 | |
| )
 | |
| 
 | |
| // DefaultServer default server
 | |
| var DefaultServer = NewServer()
 | |
| 
 | |
| var (
 | |
| 	// DefaultAddress will be used if no address passed, use secure localhost
 | |
| 	DefaultAddress = "127.0.0.1:0"
 | |
| 	// DefaultName will be used if no name passed
 | |
| 	DefaultName = "server"
 | |
| 	// DefaultVersion will be used if no version passed
 | |
| 	DefaultVersion = "latest"
 | |
| 	// DefaultRegisterCheck holds func that run before register server
 | |
| 	DefaultRegisterCheck = func(context.Context) error { return nil }
 | |
| 	// DefaultRegisterInterval holds interval for register
 | |
| 	DefaultRegisterInterval = time.Second * 30
 | |
| 	// DefaultRegisterTTL holds register record ttl, must be multiple of DefaultRegisterInterval
 | |
| 	DefaultRegisterTTL = time.Second * 90
 | |
| 	// DefaultNamespace will be used if no namespace passed
 | |
| 	DefaultNamespace = "micro"
 | |
| 	// DefaultMaxMsgSize holds default max msg ssize
 | |
| 	DefaultMaxMsgSize = 1024 * 1024 * 4 // 4Mb
 | |
| 	// DefaultMaxMsgRecvSize holds default max recv size
 | |
| 	DefaultMaxMsgRecvSize = 1024 * 1024 * 4 // 4Mb
 | |
| 	// DefaultMaxMsgSendSize holds default max send size
 | |
| 	DefaultMaxMsgSendSize = 1024 * 1024 * 4 // 4Mb
 | |
| )
 | |
| 
 | |
| // Server is a simple micro server abstraction
 | |
| type Server interface {
 | |
| 	// Name returns server name
 | |
| 	Name() string
 | |
| 	// Initialise options
 | |
| 	Init(...Option) error
 | |
| 	// Retrieve the options
 | |
| 	Options() Options
 | |
| 	// Register a handler
 | |
| 	Handle(h Handler) error
 | |
| 	// Create a new handler
 | |
| 	NewHandler(h interface{}, opts ...HandlerOption) Handler
 | |
| 	// Create a new subscriber
 | |
| 	NewSubscriber(topic string, h interface{}, opts ...SubscriberOption) Subscriber
 | |
| 	// Register a subscriber
 | |
| 	Subscribe(s Subscriber) error
 | |
| 	// Start the server
 | |
| 	Start() error
 | |
| 	// Stop the server
 | |
| 	Stop() error
 | |
| 	// Server implementation
 | |
| 	String() string
 | |
| }
 | |
| 
 | |
| /*
 | |
| // Router handle serving messages
 | |
| type Router interface {
 | |
| 	// ProcessMessage processes a message
 | |
| 	ProcessMessage(ctx context.Context, msg Message) error
 | |
| 	// ServeRequest processes a request to completion
 | |
| 	ServeRequest(ctx context.Context, req Request, rsp Response) error
 | |
| }
 | |
| */
 | |
| 
 | |
| // Message is an async message interface
 | |
| type Message interface {
 | |
| 	// Topic of the message
 | |
| 	Topic() string
 | |
| 	// The decoded payload value
 | |
| 	Body() interface{}
 | |
| 	// The content type of the payload
 | |
| 	ContentType() string
 | |
| 	// The raw headers of the message
 | |
| 	Header() metadata.Metadata
 | |
| 	// Codec used to decode the message
 | |
| 	Codec() codec.Codec
 | |
| }
 | |
| 
 | |
| // Request is a synchronous request interface
 | |
| type Request interface {
 | |
| 	// Service name requested
 | |
| 	Service() string
 | |
| 	// The action requested
 | |
| 	Method() string
 | |
| 	// Endpoint name requested
 | |
| 	Endpoint() string
 | |
| 	// Content type provided
 | |
| 	ContentType() string
 | |
| 	// Header of the request
 | |
| 	Header() metadata.Metadata
 | |
| 	// Body is the initial decoded value
 | |
| 	Body() interface{}
 | |
| 	// Read the undecoded request body
 | |
| 	Read() ([]byte, error)
 | |
| 	// The encoded message stream
 | |
| 	Codec() codec.Codec
 | |
| 	// Indicates whether its a stream
 | |
| 	Stream() bool
 | |
| }
 | |
| 
 | |
| // Response is the response writer for unencoded messages
 | |
| type Response interface {
 | |
| 	// Encoded writer
 | |
| 	Codec() codec.Codec
 | |
| 	// Write the header
 | |
| 	WriteHeader(md metadata.Metadata)
 | |
| 	// write a response directly to the client
 | |
| 	Write([]byte) error
 | |
| }
 | |
| 
 | |
| // Stream represents a stream established with a client.
 | |
| // A stream can be bidirectional which is indicated by the request.
 | |
| // The last error will be left in Error().
 | |
| // EOF indicates end of the stream.
 | |
| type Stream interface {
 | |
| 	// Context for the stream
 | |
| 	Context() context.Context
 | |
| 	// Request returns request
 | |
| 	Request() Request
 | |
| 	// Send will encode and send a request
 | |
| 	Send(msg interface{}) error
 | |
| 	// Recv will decode and read a response
 | |
| 	Recv(msg interface{}) error
 | |
| 	// SendMsg will encode and send a request
 | |
| 	SendMsg(msg interface{}) error
 | |
| 	// RecvMsg will decode and read a response
 | |
| 	RecvMsg(msg interface{}) error
 | |
| 	// Error returns stream error
 | |
| 	Error() error
 | |
| 	// Close closes the stream
 | |
| 	Close() error
 | |
| }
 | |
| 
 | |
| // Handler interface represents a request handler. It's generated
 | |
| // by passing any type of public concrete object with endpoints into server.NewHandler.
 | |
| // Most will pass in a struct.
 | |
| //
 | |
| // Example:
 | |
| //
 | |
| //      type Greeter struct {}
 | |
| //
 | |
| //      func (g *Greeter) Hello(context, request, response) error {
 | |
| //              return nil
 | |
| //      }
 | |
| //
 | |
| type Handler interface {
 | |
| 	Name() string
 | |
| 	Handler() interface{}
 | |
| 	Endpoints() []*register.Endpoint
 | |
| 	Options() HandlerOptions
 | |
| }
 | |
| 
 | |
| // Subscriber interface represents a subscription to a given topic using
 | |
| // a specific subscriber function or object with endpoints. It mirrors
 | |
| // the handler in its behaviour.
 | |
| type Subscriber interface {
 | |
| 	Topic() string
 | |
| 	Subscriber() interface{}
 | |
| 	Endpoints() []*register.Endpoint
 | |
| 	Options() SubscriberOptions
 | |
| }
 |