server

package

v1.0.7 Latest Latest Go to latest Published: May 15, 2025 License: MIT Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Server struct {
	pb.UnimplementedSuhaibMessageQueueServer
	// contains filtered or unexported fields
}

func NewServer(port, dbPath string, opts *ServerOptions) *Server

func (s *Server) BulkRetrieve(ctx context.Context, brr *pb.BulkRetrieveRequest) (*pb.BulkRetrieveResponse, error)

func (s *Server) Close()

func (s *Server) Connect(ctx context.Context, req *pb.ConnectRequest) (*pb.ConnectResponse, error)

Connect is a placeholder implementation for the Connect method required by the interface

func (s *Server) Consume(ctx context.Context, cr *pb.ConsumeRequest) (*pb.ConsumeResponse, error)

func (s *Server) CreateTopic(ctx context.Context, tr *pb.CreateTopicRequest) (*pb.CreateTopicResponse, error)

func (s *Server) Debug()

func (s *Server) DeleteUntilOffset(ctx context.Context, dr *pb.DeleteUntilOffsetRequest) (*pb.DeleteUntilOffsetResponse, error)

func (s *Server) GetDriver() database.DBDriverInterface

func (s *Server) GetEarliestMessageFromTopic(ctx context.Context, gr *pb.GetEarliestOffsetRequest) (*pb.GetEarliestOffsetResponse, error)

func (s *Server) GetEarliestOffset(ctx context.Context, gr *pb.GetEarliestOffsetRequest) (*pb.GetEarliestOffsetResponse, error)

func (s *Server) GetLatestMessageFromTopic(ctx context.Context, gr *pb.GetLatestOffsetRequest) (*pb.GetLatestOffsetResponse, error)

func (s *Server) GetLatestOffset(ctx context.Context, gr *pb.GetLatestOffsetRequest) (*pb.GetLatestOffsetResponse, error)

func (s *Server) Produce(ctx context.Context, pr *pb.ProduceRequest) (*pb.ProduceResponse, error)

func (s *Server) Start()

func (s *Server) StreamConsume(cr *pb.ConsumeRequest, cs pb.SuhaibMessageQueue_StreamConsumeServer) error

func (s *Server) StreamProduce(sp pb.SuhaibMessageQueue_StreamProduceServer) error

type ServerOptions struct {
	EnableMTLS     bool
	TLSConfig      *tls.Config
	MaxRecvMsgSize int
	MaxSendMsgSize int
}

ServerOptions allows for programmatic configuration of the server.

Path	Synopsis
database