server

Documentation

Index

• func Endpoints() pb.Endpoints
• func GRPCServerOptions() []grpctransport.ServerOption
• func HTTPServerOptions() []httptransport.ServerOption
• func Interrupt(errc chan<- error)
• func NATSSubscriberOptions() []natstransport.SubscriberOption
• func NewEndpoints(svc pb.EchoServer) pb.Endpoints
• func Run(cfg Config)
• type Config

Functions

func Endpoints

func Endpoints() pb.Endpoints

Endpoints application domain

func GRPCServerOptions

func GRPCServerOptions() []grpctransport.ServerOption

GRPCServerOptions GRPC 服务传输选项

func HTTPServerOptions

func HTTPServerOptions() []httptransport.ServerOption

HTTPServerOptions GRPC 服务传输选项

func Interrupt

func Interrupt(errc chan<- error)

Interrupt server interrupt

func NATSSubscriberOptions

func NATSSubscriberOptions() []natstransport.SubscriberOption

NATSSubscriberOptions NATS 订阅器选项

func NewEndpoints

func NewEndpoints(svc pb.EchoServer) pb.Endpoints

func Run

func Run(cfg Config)

Run starts a new http server, gRPC server, and a debug server with the passed config and logger

Types

type Config

type Config struct {
	HTTPAddr  string
	DebugAddr string
	GRPCAddr  string
	NATSAddr  string
	Debug     bool
}

Config contains the required fields for running a server