server

Documentation

Index

• Variables
• func Entry(port int, adminPort int, iam iam.IAM, seerOpts base.ServiceOptions, ...) error
• func RandStringBytesMaskImprSrcUnsafe(n int) string
• type Server
  • func NewServer(iam iam.IAM, seerOpts base.ServiceOptions, sources sources.Sources, ...) *Server
  • func (s *Server) AdminListenAndServe(port int) error
  • func (s *Server) DeleteUser(ctx context.Context, req api.DeleteUser) (_ *api.Void, err error)
  • func (s *Server) ListenAndServe(port int) error
  • func (s *Server) Login(ctx context.Context, req api.LoginRequest) (*api.LoginResponse, error)
  • func (s *Server) ProjectAccess(ctx context.Context, userID string, projectID string) error
  • func (s *Server) PushEvent(ctx context.Context, req api.Event) (*api.Void, error)
• type Subscription

Variables

var (
	ErrMissingAccessToken = errors.New("missing AccessToken in header")
)

var NoProjectAccess = errors.New("no project access")

Functions

func Entry

func Entry(
	port int,
	adminPort int,
	iam iam.IAM,
	seerOpts base.ServiceOptions,
	sources sources.Sources,
	compiler compiler.Compiler,
	filter filter.Filter,
	slideshow base.ServiceOptions,
	pubSub pubsub.PubSub,
	corsHeader string,
	log *zap.Logger,
) error

func RandStringBytesMaskImprSrcUnsafe

func RandStringBytesMaskImprSrcUnsafe(n int) string

Types

type Server

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

func NewServer

func NewServer(
	iam iam.IAM,
	seerOpts base.ServiceOptions,
	sources sources.Sources,
	compiler compiler.Compiler,
	filter filter.Filter,
	slideshow base.ServiceOptions,
	pub pubsub.Publisher,
	corsHeader string,
	log *zap.Logger,
) *Server

func (*Server) AdminListenAndServe

func (s *Server) AdminListenAndServe(port int) error

func (*Server) DeleteUser

func (s *Server) DeleteUser(ctx context.Context, req api.DeleteUser) (_ *api.Void, err error)

func (*Server) ListenAndServe

func (s *Server) ListenAndServe(port int) error

func (*Server) Login

func (s *Server) Login(
	ctx context.Context,
	req api.LoginRequest,
) (*api.LoginResponse, error)

func (*Server) ProjectAccess

func (s *Server) ProjectAccess(
	ctx context.Context,
	userID string,
	projectID string,
) error

func (*Server) PushEvent

func (s *Server) PushEvent(
	ctx context.Context,
	req api.Event,
) (*api.Void, error)

type Subscription

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