consumer

Documentation

Index

• type ConsumeServer
  • func CreateConsumeServer(walManager walmanager.Manager, ...) (*ConsumeServer, error)
  • func (c *ConsumeServer) Execute() error

Types

type ConsumeServer

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

ConsumeServer is a ConsumeServer of log messages.

func CreateConsumeServer

func CreateConsumeServer(walManager walmanager.Manager, streamServer streamingpb.StreamingNodeHandlerService_ConsumeServer) (*ConsumeServer, error)

CreateConsumeServer create a new consumer. Expected message sequence: CreateConsumeServer: -> ConsumeResponse 1 -> ConsumeResponse 2 -> ConsumeResponse 3 CloseConsumer:

func (*ConsumeServer) Execute

func (c *ConsumeServer) Execute() error

Execute executes the consumer.