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: <- CreateVChannelConsumer 1 -> CreateVChannelConsuemr 1 -> ConsumeMessage 1.1 <- CreateVChannelConsumer 2 -> ConsumeMessage 1.2 -> CreateVChannelConsumer 2 -> ConsumeMessage 2.1 -> ConsumeMessage 2.2 -> ConsumeMessage 1.3 <- CloseVChannelConsumer 1 -> CloseVChannelConsumer 1 -> ConsumeMessage 2.3 <- CloseVChannelConsumer 2 -> CloseVChannelConsumer 2 CloseConsumer:

func (*ConsumeServer) Execute

func (c *ConsumeServer) Execute() error

Execute executes the consumer.