server

Documentation

Index

• type Server
  • func (s *Server) Init(ctx context.Context) (err error)
  • func (s *Server) RegisterGRPCService(grpcServer *grpc.Server)
  • func (s *Server) Start()
  • func (s *Server) Stop()
• type ServerBuilder
  • func NewServerBuilder() *ServerBuilder
  • func (s *ServerBuilder) Build() *Server
  • func (b *ServerBuilder) WithETCD(e *clientv3.Client) *ServerBuilder
  • func (b *ServerBuilder) WithMetaKV(metaKV kv.MetaKv) *ServerBuilder
  • func (b *ServerBuilder) WithSession(session sessionutil.SessionInterface) *ServerBuilder

Types

type Server

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

Server is the streamingcoord server.

func (*Server) Init

func (s *Server) Init(ctx context.Context) (err error)

Init initializes the streamingcoord server.

func (*Server) RegisterGRPCService

func (s *Server) RegisterGRPCService(grpcServer *grpc.Server)

registerGRPCService register all grpc service to grpc server.

func (*Server) Start

func (s *Server) Start()

Start starts the streamingcoord server.

func (*Server) Stop

func (s *Server) Stop()

Stop stops the streamingcoord server.

type ServerBuilder

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

func NewServerBuilder

func NewServerBuilder() *ServerBuilder

func (*ServerBuilder) Build

func (s *ServerBuilder) Build() *Server

func (*ServerBuilder) WithETCD

func (b *ServerBuilder) WithETCD(e *clientv3.Client) *ServerBuilder

func (*ServerBuilder) WithMetaKV

func (b *ServerBuilder) WithMetaKV(metaKV kv.MetaKv) *ServerBuilder

func (*ServerBuilder) WithSession

func (b *ServerBuilder) WithSession(session sessionutil.SessionInterface) *ServerBuilder