server

package

v0.10.3-0...-96d0e78 Latest Latest Go to latest Published: Nov 14, 2025 License: Apache-2.0 Imports: 20 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Server is the streamingcoord server.

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

RegisterGRPCService register all grpc service to grpc server.

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

Init initializes the streamingcoord server.

func (s *Server) Stop()

Close closes the streamingcoord server.

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

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) WithMixCoordClient(mixCoordClient *syncutil.Future[types.MixCoordClient]) *ServerBuilder

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