producer

Documentation

Index

• type ProduceServer
  • func CreateProduceServer(walManager walmanager.Manager, ...) (*ProduceServer, error)
  • func (p *ProduceServer) Execute() error

Types

type ProduceServer

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

ProduceServer is a ProduceServer of log messages.

func CreateProduceServer

func CreateProduceServer(walManager walmanager.Manager, streamServer streamingpb.StreamingNodeHandlerService_ProduceServer) (*ProduceServer, error)

CreateProduceServer create a new producer. Expected message sequence: CreateProducer (Header) ProduceRequest 1 -> ProduceResponse Or Error 1 ProduceRequest 2 -> ProduceResponse Or Error 2 ProduceRequest 3 -> ProduceResponse Or Error 3 CloseProducer

func (*ProduceServer) Execute

func (p *ProduceServer) Execute() error

Execute starts the producer.