server

Documentation

Index

• type Server
  • func (s *Server) Health(ctx context.Context) commonpb.StateCode
  • func (s *Server) Init(ctx context.Context) (err error)
  • func (s *Server) Start()
  • func (s *Server) Stop()
• type ServerBuilder
  • func NewServerBuilder() *ServerBuilder
  • func (s *ServerBuilder) Build() *Server
  • func (b *ServerBuilder) WithDataCoordClient(dc types.DataCoordClient) *ServerBuilder
  • func (b *ServerBuilder) WithETCD(e *clientv3.Client) *ServerBuilder
  • func (b *ServerBuilder) WithGRPCServer(svr *grpc.Server) *ServerBuilder
  • func (b *ServerBuilder) WithMetaKV(kv kv.MetaKv) *ServerBuilder
  • func (b *ServerBuilder) WithRootCoordClient(rc types.RootCoordClient) *ServerBuilder
  • func (b *ServerBuilder) WithSession(session *sessionutil.Session) *ServerBuilder

Types

type Server

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

Server is the streamingnode server.

func (*Server) Health

func (s *Server) Health(ctx context.Context) commonpb.StateCode

Health returns the health status of the streamingnode server.

func (*Server) Init

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

Init initializes the streamingnode server.

func (*Server) Start

func (s *Server) Start()

Start starts the streamingnode server.

func (*Server) Stop

func (s *Server) Stop()

Stop stops the streamingnode server.

type ServerBuilder

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

ServerBuilder is used to build a server. All component should be initialized before server initialization should be added here.

func NewServerBuilder

func NewServerBuilder() *ServerBuilder

NewServerBuilder creates a new server builder.

func (*ServerBuilder) Build

func (s *ServerBuilder) Build() *Server

Build builds a streaming node server.

func (*ServerBuilder) WithDataCoordClient

func (b *ServerBuilder) WithDataCoordClient(dc types.DataCoordClient) *ServerBuilder

WithDataCoordClient sets data coord client to the server builder.

func (*ServerBuilder) WithETCD

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

WithETCD sets etcd client to the server builder.

func (*ServerBuilder) WithGRPCServer

func (b *ServerBuilder) WithGRPCServer(svr *grpc.Server) *ServerBuilder

WithGRPCServer sets grpc server to the server builder.

func (*ServerBuilder) WithMetaKV

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

WithMetaKV sets meta kv to the server builder.

func (*ServerBuilder) WithRootCoordClient

func (b *ServerBuilder) WithRootCoordClient(rc types.RootCoordClient) *ServerBuilder

WithRootCoordClient sets root coord client to the server builder.

func (*ServerBuilder) WithSession

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

WithSession sets session to the server builder.