server

Documentation

Index

• type EventLogRPCServer
  • func NewServer(conf conf.EventLogServerConf, log *logrus.Entry, storeManager store.Manager, ...) *EventLogRPCServer
  • func (s *EventLogRPCServer) Log(stream pb.EventLog_LogServer) error
  • func (s *EventLogRPCServer) Start() error
  • func (s *EventLogRPCServer) Stop()

Types

type EventLogRPCServer

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

func NewServer

func NewServer(conf conf.EventLogServerConf, log *logrus.Entry, storeManager store.Manager, listenErr chan error) *EventLogRPCServer

NewServer server

func (*EventLogRPCServer) Log

func (s *EventLogRPCServer) Log(stream pb.EventLog_LogServer) error

Log impl EventLogServerServer

func (*EventLogRPCServer) Start

func (s *EventLogRPCServer) Start() error

Start start grpc server

func (*EventLogRPCServer) Stop

func (s *EventLogRPCServer) Stop()

Stop stop