app

Feb 20, 2018

Changes in this version

+ type App struct

+ func NewApp(host string, port int, log logrus.FieldLogger, config *viper.Viper) (*App, error)

+ func (a *App) MetricsReporterInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)

+ func (a *App) Run()

+ type Server struct

+ func NewServer(producer forwarder.Forwarder, log logrus.FieldLogger, config *viper.Viper) *Server

+ func (s *Server) SendEvent(ctx context.Context, event *pb.Event) (*pb.Response, error)