server

Documentation

Overview

Package server provides tarian server functionality

Index

• func NewAlertmanagerClient(amURL *url.URL) *client.Alertmanager
• func SetLogger(l *zap.SugaredLogger)
• type AlertDispatcher
  • func NewAlertDispatcher(amURL *url.URL, alertEvaluationInterval time.Duration) *AlertDispatcher
  • func (a *AlertDispatcher) LoopSendAlerts(ctx context.Context, es store.EventStore)
  • func (a *AlertDispatcher) SendAlert(event *tarianpb.Event) error
• type ConfigServer
  • func NewConfigServer(constraintStore store.ConstraintStore, actionStore store.ActionStore) *ConfigServer
  • func (cs *ConfigServer) AddAction(ctx context.Context, request *tarianpb.AddActionRequest) (*tarianpb.AddActionResponse, error)
  • func (cs *ConfigServer) AddConstraint(ctx context.Context, request *tarianpb.AddConstraintRequest) (*tarianpb.AddConstraintResponse, error)
  • func (cs *ConfigServer) GetActions(ctx context.Context, request *tarianpb.GetActionsRequest) (*tarianpb.GetActionsResponse, error)
  • func (cs *ConfigServer) GetConstraints(ctx context.Context, request *tarianpb.GetConstraintsRequest) (*tarianpb.GetConstraintsResponse, error)
  • func (cs *ConfigServer) RemoveAction(ctx context.Context, request *tarianpb.RemoveActionRequest) (*tarianpb.RemoveActionResponse, error)
  • func (cs *ConfigServer) RemoveConstraint(ctx context.Context, request *tarianpb.RemoveConstraintRequest) (*tarianpb.RemoveConstraintResponse, error)
• type EventServer
  • func NewEventServer(s store.EventStore) *EventServer
  • func (es *EventServer) GetEvents(ctxt context.Context, request *tarianpb.GetEventsRequest) (*tarianpb.GetEventsResponse, error)
  • func (es *EventServer) IngestEvent(ctx context.Context, request *tarianpb.IngestEventRequest) (*tarianpb.IngestEventResponse, error)
• type Server
  • func NewServer(storeSet store.StoreSet, certFile string, privateKeyFile string) (*Server, error)
  • func (s *Server) Start(grpcListenAddress string) error
  • func (s *Server) StartAlertDispatcher()
  • func (s *Server) Stop()
  • func (s *Server) WithAlertDispatcher(alertManagerAddress *url.URL, alertEvaluationInterval time.Duration) *Server

Functions

func NewAlertmanagerClient

func NewAlertmanagerClient(amURL *url.URL) *client.Alertmanager

func SetLogger

func SetLogger(l *zap.SugaredLogger)

Types

type AlertDispatcher

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

func NewAlertDispatcher

func NewAlertDispatcher(amURL *url.URL, alertEvaluationInterval time.Duration) *AlertDispatcher

func (*AlertDispatcher) LoopSendAlerts

func (a *AlertDispatcher) LoopSendAlerts(ctx context.Context, es store.EventStore)

func (*AlertDispatcher) SendAlert

func (a *AlertDispatcher) SendAlert(event *tarianpb.Event) error

type ConfigServer

type ConfigServer struct {
	tarianpb.UnimplementedConfigServer
	// contains filtered or unexported fields
}

func NewConfigServer

func NewConfigServer(constraintStore store.ConstraintStore, actionStore store.ActionStore) *ConfigServer

func (*ConfigServer) AddAction

func (cs *ConfigServer) AddAction(ctx context.Context, request *tarianpb.AddActionRequest) (*tarianpb.AddActionResponse, error)

func (*ConfigServer) AddConstraint

func (cs *ConfigServer) AddConstraint(ctx context.Context, request *tarianpb.AddConstraintRequest) (*tarianpb.AddConstraintResponse, error)

func (*ConfigServer) GetActions

func (cs *ConfigServer) GetActions(ctx context.Context, request *tarianpb.GetActionsRequest) (*tarianpb.GetActionsResponse, error)

func (*ConfigServer) GetConstraints

func (cs *ConfigServer) GetConstraints(ctx context.Context, request *tarianpb.GetConstraintsRequest) (*tarianpb.GetConstraintsResponse, error)

func (*ConfigServer) RemoveAction

func (cs *ConfigServer) RemoveAction(ctx context.Context, request *tarianpb.RemoveActionRequest) (*tarianpb.RemoveActionResponse, error)

func (*ConfigServer) RemoveConstraint

func (cs *ConfigServer) RemoveConstraint(ctx context.Context, request *tarianpb.RemoveConstraintRequest) (*tarianpb.RemoveConstraintResponse, error)

type EventServer

type EventServer struct {
	tarianpb.UnimplementedEventServer
	// contains filtered or unexported fields
}

func NewEventServer

func NewEventServer(s store.EventStore) *EventServer

func (*EventServer) GetEvents

func (es *EventServer) GetEvents(ctxt context.Context, request *tarianpb.GetEventsRequest) (*tarianpb.GetEventsResponse, error)

func (*EventServer) IngestEvent

func (es *EventServer) IngestEvent(ctx context.Context, request *tarianpb.IngestEventRequest) (*tarianpb.IngestEventResponse, error)

type Server

type Server struct {
	GrpcServer      *grpc.Server
	EventServer     *EventServer
	ConfigServer    *ConfigServer
	AlertDispatcher *AlertDispatcher
	// contains filtered or unexported fields
}

func NewServer

func NewServer(storeSet store.StoreSet, certFile string, privateKeyFile string) (*Server, error)

func (*Server) Start

func (s *Server) Start(grpcListenAddress string) error

func (*Server) StartAlertDispatcher

func (s *Server) StartAlertDispatcher()

func (*Server) Stop

func (s *Server) Stop()

func (*Server) WithAlertDispatcher

func (s *Server) WithAlertDispatcher(alertManagerAddress *url.URL, alertEvaluationInterval time.Duration) *Server