outgoing

Documentation

Index

• type Server
  • func New(id string) *Server
  • func (s *Server) ProcessEventGroup(ctx context.Context, key *datastore.Key, g event.EventGroup) error
  • func (s *Server) RemoveEventGroup(ctx context.Context, key *datastore.Key, g event.EventGroup) error
  • func (s *Server) Run(ctx context.Context) error

Types

type Server

type Server struct {
	CheckInterval time.Duration
	Clock         clock.Clock
	ProjectID     string
}

func New

func New(id string) *Server

func (*Server) ProcessEventGroup

func (s *Server) ProcessEventGroup(ctx context.Context, key *datastore.Key, g event.EventGroup) error

func (*Server) RemoveEventGroup

func (s *Server) RemoveEventGroup(ctx context.Context, key *datastore.Key, g event.EventGroup) error

func (*Server) Run

func (s *Server) Run(ctx context.Context) error