server

package

v0.0.2 Latest Latest Go to latest Published: Nov 26, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type PipelanerServer struct {
	service.UnimplementedPipelanerServer
	// contains filtered or unexported fields
}

func NewServer(logger *zerolog.Logger, bufferSize int64) *PipelanerServer

func (s *PipelanerServer) Recv() <-chan *service.Message

func (s *PipelanerServer) Sink(_ context.Context, message *service.Message) (*emptypb.Empty, error)

func (s *PipelanerServer) SinkStream(stream service.Pipelaner_SinkStreamServer) error