server

Documentation

Index

• func RunGRPCServer(db storage.Client, c *config.Notifications) error
• type Server
  • func New(db storage.Client) *Server
  • func (s *Server) AddRule(context.Context, *notifications.Rule) (*notifications.RuleAddResponse, error)
  • func (s *Server) DeleteRule(context.Context, *notifications.RuleIdentifier) (*notifications.RuleDeleteResponse, error)
  • func (s *Server) GetRule(context.Context, *notifications.RuleIdentifier) (*notifications.RuleGetResponse, error)
  • func (s *Server) Health() *health.Service
  • func (s *Server) ListRules(context.Context, *notifications.Empty) (*notifications.RuleListResponse, error)
  • func (s *Server) Notify(context.Context, *notifications.Event) (*notifications.Response, error)
  • func (s *Server) UpdateRule(context.Context, *notifications.Rule) (*notifications.RuleUpdateResponse, error)
  • func (s *Server) ValidateWebhook(context.Context, *notifications.URLValidationRequest) (*notifications.URLValidationResponse, error)
  • func (s *Server) Version(context.Context, *notifications.VersionRequest) (*notifications.VersionResponse, error)

Functions

func RunGRPCServer

func RunGRPCServer(db storage.Client, c *config.Notifications) error

Types

type Server

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

func New

func New(db storage.Client) *Server

func (*Server) AddRule

func (s *Server) AddRule(context.Context, *notifications.Rule) (*notifications.RuleAddResponse, error)

func (*Server) DeleteRule

func (s *Server) DeleteRule(context.Context, *notifications.RuleIdentifier) (*notifications.RuleDeleteResponse, error)

func (*Server) GetRule

func (s *Server) GetRule(context.Context, *notifications.RuleIdentifier) (*notifications.RuleGetResponse, error)

func (*Server) Health

func (s *Server) Health() *health.Service

func (*Server) ListRules

func (s *Server) ListRules(context.Context, *notifications.Empty) (*notifications.RuleListResponse, error)

func (*Server) Notify

func (s *Server) Notify(context.Context, *notifications.Event) (*notifications.Response, error)

func (*Server) UpdateRule

func (s *Server) UpdateRule(context.Context, *notifications.Rule) (*notifications.RuleUpdateResponse, error)

func (*Server) ValidateWebhook

func (s *Server) ValidateWebhook(context.Context, *notifications.URLValidationRequest) (*notifications.URLValidationResponse, error)

func (*Server) Version

func (s *Server) Version(context.Context, *notifications.VersionRequest) (*notifications.VersionResponse, error)