mz

Documentation

Index

• func AddRpcServer(handler AddRpcServerHandler)
• type AddRpcServerHandler
• type HttpService
  • func NewHttpService(opts ...ServiceOption) (*HttpService, error)
  • func (m *HttpService) Engine() *gin.Engine
  • func (m *HttpService) Run() error
• type IService
• type RPCServer
• type RpcService
  • func NewRpcService(opts ...ServiceOption) (*RpcService, error)
  • func (m *RpcService) AddRpcOptions(opts ...grpc.ServerOption)
  • func (m *RpcService) Run() error
• type Service
  • func (m *Service) Address() string
  • func (m *Service) Name() string
  • func (m *Service) Rpc(target string) *grpc.ClientConn
• type ServiceOption
  • func WithAddress(addr string) ServiceOption

Functions

func AddRpcServer

func AddRpcServer(handler AddRpcServerHandler)

Types

type AddRpcServerHandler

type AddRpcServerHandler func(server *RPCServer)

type HttpService

type HttpService struct {
	Service
	// contains filtered or unexported fields
}

func NewHttpService

func NewHttpService(opts ...ServiceOption) (*HttpService, error)

func (*HttpService) Engine

func (m *HttpService) Engine() *gin.Engine

func (*HttpService) Run

func (m *HttpService) Run() error

type IService

type IService interface {
	Name() string
	Address() string
	Run() error
	Rpc(target string) *grpc.ClientConn
	// contains filtered or unexported methods
}

type RPCServer

type RPCServer = grpc.Server

type RpcService

type RpcService struct {
	Service
	// contains filtered or unexported fields
}

func NewRpcService

func NewRpcService(opts ...ServiceOption) (*RpcService, error)

func (*RpcService) AddRpcOptions

func (m *RpcService) AddRpcOptions(opts ...grpc.ServerOption)

func (*RpcService) Run

func (m *RpcService) Run() error

type Service

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

func (*Service) Address

func (m *Service) Address() string

func (*Service) Name

func (m *Service) Name() string

func (*Service) Rpc

func (m *Service) Rpc(target string) *grpc.ClientConn

type ServiceOption

type ServiceOption func(service IService)

func WithAddress

func WithAddress(addr string) ServiceOption