microgo

README

microgo

Documentation

Index

• Variables
• func RegisterEncoder(enc Encoder)
• func RegisterServer(servers ...Server)
• func Run() error
• type Call
• type Client
  • func NewClient(name string, options ...ClientOption) *Client
  • func (client *Client) BroadcastCall(ctx context.Context, contentType, method string, input []byte) (map[string][]byte, map[string]error)
  • func (client *Client) Call(ctx context.Context, host, contentType, method string, input []byte) (out []byte, err error)
• type ClientOption
  • func WithClientOptionHosts(hosts ...string) ClientOption
• type CompressType
• type Discovery
• type Encoder
  • func GetEncoder(name string) Encoder
• type Message
• type MessageContentType
• type MessageType
• type ReadData
• type Registry
• type Server
  • func NewHttpServer(name string, mux http.Handler) Server
  • func NewTCPServer(name string, impl any, call Call) Server
• type ServerHTTP
  • func (srv *ServerHTTP) Addr() string
  • func (srv *ServerHTTP) Name() string
  • func (srv *ServerHTTP) ServeHTTP(rw http.ResponseWriter, req *http.Request)
  • func (srv *ServerHTTP) Start() error
  • func (srv *ServerHTTP) Stop() error
• type ServerTCP
  • func (srv *ServerTCP) Addr() string
  • func (srv *ServerTCP) Name() string
  • func (srv *ServerTCP) Start() error
  • func (srv *ServerTCP) Stop() error

Variables

var (
	ErrNotSupportContentType = fmt.Errorf("not support content type")
	ErrFullBodyLen           = fmt.Errorf("full body lenght")
	ErrBadConnection         = fmt.Errorf("bad connection")
	ErrNotFoundConnection    = fmt.Errorf("not found connection")
)

Functions

func RegisterEncoder

func RegisterEncoder(enc Encoder)

func RegisterServer

func RegisterServer(servers ...Server)

func Run

func Run() error

Types

type Call

type Call func(ctx context.Context, impl any, enc Encoder, method string, input []byte) (output []byte, err error)

type Client

type Client struct {
	// contains filtered or unexported fields
}

func NewClient

func NewClient(name string, options ...ClientOption) *Client

func (*Client) BroadcastCall

func (client *Client) BroadcastCall(ctx context.Context, contentType, method string, input []byte) (map[string][]byte, map[string]error)

func (*Client) Call

func (client *Client) Call(ctx context.Context, host, contentType, method string, input []byte) (out []byte, err error)

type ClientOption

type ClientOption func(client *Client)

func WithClientOptionHosts

func WithClientOptionHosts(hosts ...string) ClientOption

type CompressType

type CompressType uint8

const (
	CompressType_Gzip CompressType = 0x10
)

type Discovery

type Discovery interface {
	QueryRoute(name string) ([]string, error)
}

type Encoder

type Encoder interface {
	Marshal(v any) ([]byte, error)
	Unmarshal(bs []byte, v any) error
	Name() string
}

func GetEncoder

func GetEncoder(name string) Encoder

type Message

type Message struct {
	BodyLen      int32
	Type         MessageType
	ContentType  MessageContentType
	CompressType CompressType
	Data         *pb.Message
}

type MessageContentType

type MessageContentType uint8

const (
	MessageContentType_Json  MessageContentType = 0x01
	MessageContentType_Proto MessageContentType = 0x02
)

type MessageType

type MessageType uint8

const (
	MessageType_Ping MessageType = 0x10
	MessageType_Data MessageType = 0x20
)

type ReadData

type ReadData struct {
	// contains filtered or unexported fields
}

type Registry

type Registry interface {
	Register(name string, addr string) error
	UnRegister(name string, addr string) error
	KeepAlive(name string, addr string) error
}

type Server

type Server interface {
	Start() error
	Stop() error
	Name() string
	Addr() string
}

func NewHttpServer

func NewHttpServer(name string, mux http.Handler) Server

func NewTCPServer

func NewTCPServer(name string, impl any, call Call) Server

type ServerHTTP

type ServerHTTP struct {
	// contains filtered or unexported fields
}

func (*ServerHTTP) Addr

func (srv *ServerHTTP) Addr() string

func (*ServerHTTP) Name

func (srv *ServerHTTP) Name() string

func (*ServerHTTP) ServeHTTP

func (srv *ServerHTTP) ServeHTTP(rw http.ResponseWriter, req *http.Request)

func (*ServerHTTP) Start

func (srv *ServerHTTP) Start() error

func (*ServerHTTP) Stop

func (srv *ServerHTTP) Stop() error

type ServerTCP

type ServerTCP struct {
	// contains filtered or unexported fields
}

func (*ServerTCP) Addr

func (srv *ServerTCP) Addr() string

func (*ServerTCP) Name

func (srv *ServerTCP) Name() string

func (*ServerTCP) Start

func (srv *ServerTCP) Start() error

func (*ServerTCP) Stop

func (srv *ServerTCP) Stop() error