app

Documentation

Index

• type App
  • func NewApp(host string, port int, log logger.Logger, config *viper.Viper) (*App, error)
  • func (a *App) Run()
  • func (a *App) Stop()
• type Server
  • func NewServer(sender sender.Sender, logger logger.Logger) *Server
  • func (s *Server) SendEvent(ctx context.Context, req *pb.Event) (*pb.SendEventResponse, error)
  • func (s *Server) SendEvents(ctx context.Context, req *pb.SendEventsRequest) (*pb.SendEventsResponse, error)

Types

type App

type App struct {
	Server *Server // tests manipulate this field
	// contains filtered or unexported fields
}

App is the app structure

func NewApp

func NewApp(host string, port int, log logger.Logger, config *viper.Viper) (*App, error)

NewApp creates a new App object

func (*App) Run

func (a *App) Run()

Run runs the app

func (*App) Stop

func (a *App) Stop()

type Server

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

Server struct

func NewServer

func NewServer(sender sender.Sender, logger logger.Logger) *Server

NewServer returns a new grpc server

func (*Server) SendEvent

func (s *Server) SendEvent(
	ctx context.Context,
	req *pb.Event,
) (*pb.SendEventResponse, error)

func (*Server) SendEvents

func (s *Server) SendEvents(
	ctx context.Context,
	req *pb.SendEventsRequest,
) (*pb.SendEventsResponse, error)

SendEvents response might include FailureIndexes in case producer fails to send all events