server

Documentation

Index

• type Server
  • func New(consumer *kafka.Consumer, logger log.Logger, errorHandler emperror.Handler) *Server
  • func (s *Server) Incoming(_ *segmentiokafka.Message)
  • func (s *Server) Run()
  • func (s *Server) SetRequests(requests request.Requests)
  • func (s *Server) SetSQLClient(client *sql.Client)
  • func (s *Server) SetWorkload(workload workload.Workload)

Types

type Server

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

func New

func New(consumer *kafka.Consumer, logger log.Logger, errorHandler emperror.Handler) *Server

func (*Server) Incoming

func (s *Server) Incoming(_ *segmentiokafka.Message)

func (*Server) Run

func (s *Server) Run()

func (*Server) SetRequests

func (s *Server) SetRequests(requests request.Requests)

func (*Server) SetSQLClient

func (s *Server) SetSQLClient(client *sql.Client)

func (*Server) SetWorkload

func (s *Server) SetWorkload(workload workload.Workload)