scheduler

Documentation

Index

• type Handler
• type Server
  • func NewServer(r *hosting.WebServer, opts ...ServerOption) (*Server, error)
  • func (s *Server) Subscribe(subscription string, handler Handler)
• type ServerOption
  • func WithAudience(audience string) ServerOption
  • func WithServiceAccount(serviceAccount string) ServerOption

Types

type Handler

type Handler func(ctx context.Context) error

type Server

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

func NewServer

func NewServer(r *hosting.WebServer, opts ...ServerOption) (*Server, error)

func (*Server) Subscribe

func (s *Server) Subscribe(subscription string, handler Handler)

type ServerOption

type ServerOption func(s *Server)

func WithAudience

func WithAudience(audience string) ServerOption

func WithServiceAccount

func WithServiceAccount(serviceAccount string) ServerOption