server

Documentation

Index

• type GRPCOption
• type ListenerOption
  • func DefaultListenerOption() ListenerOption
• type Option
  • func DefaultOption(S2SBoardCastAddr, S2CBoardCastAddr, GraphQueryBoardCastAddr string, ...) (option Option, err error)
• type Server
  • func New(ServerInfo *pb.ServerInfo, option Option) *Server
  • func (s *Server) Run(ctx context.Context, option ListenerOption) (err error)

Types

type GRPCOption

type GRPCOption struct {
	S2SRegistryOption   registry.GRPCRegistryOption
	S2CRegistryOption   registry.GRPCRegistryOption
	S2SRegistrantOption registrant.GRPCRegistrantOption
	GraphQueryOption    graph.GraphQueryOption
}

type ListenerOption

type ListenerOption struct {
	S2SListenNetwork, S2SListenAddr               string
	S2CListenNetwork, S2CListenAddr               string
	GraphQueryListenNetwork, GraphQueryListenAddr string
}

func DefaultListenerOption

func DefaultListenerOption() ListenerOption

type Option

type Option struct {
	ServiceOption server.Option
	GRPCOption    GRPCOption
	// contains filtered or unexported fields
}

func DefaultOption

func DefaultOption(S2SBoardCastAddr, S2CBoardCastAddr, GraphQueryBoardCastAddr string, initServer *pb.S2SInfo) (option Option, err error)

type Server

type Server struct {
	*server.Server
	// contains filtered or unexported fields
}

func New

func New(ServerInfo *pb.ServerInfo, option Option) *Server

func (*Server) Run

func (s *Server) Run(ctx context.Context, option ListenerOption) (err error)