grpc

Documentation

Index

• type AclBatcher
  • func NewAclBatcher(ctx context.Context, wsId string, done chan contextualWsID, ...) *AclBatcher
  • func (a *AclBatcher) Start()
• type Handler
  • func NewHandler() *Handler
  • func (h *Handler) CreateWorkspace(ctx context.Context, req *idm.CreateWorkspaceRequest) (*idm.CreateWorkspaceResponse, error)
  • func (h *Handler) DeleteWorkspace(ctx context.Context, req *idm.DeleteWorkspaceRequest) (*idm.DeleteWorkspaceResponse, error)
  • func (h *Handler) ModifyLogin(ctx context.Context, req *service.ModifyLoginRequest) (*service.ModifyLoginResponse, error)
  • func (h *Handler) SearchWorkspace(request *idm.SearchWorkspaceRequest, ...) error
  • func (h *Handler) StreamWorkspace(streamer idm.WorkspaceService_StreamWorkspaceServer) error
• type WsCleaner
  • func NewWsCleaner(ctx context.Context, h idm.WorkspaceServiceServer) *WsCleaner
  • func (c *WsCleaner) Handle(ctx context.Context, msg *idm.ChangeEvent) error

Types

type AclBatcher

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

func NewAclBatcher

func NewAclBatcher(ctx context.Context, wsId string, done chan contextualWsID, timeout time.Duration) *AclBatcher

func (*AclBatcher) Start

func (a *AclBatcher) Start()

type Handler

type Handler struct {
	idm.UnimplementedWorkspaceServiceServer
	service.UnimplementedLoginModifierServer
}

Handler definition

func NewHandler

func NewHandler() *Handler

func (*Handler) CreateWorkspace

func (h *Handler) CreateWorkspace(ctx context.Context, req *idm.CreateWorkspaceRequest) (*idm.CreateWorkspaceResponse, error)

CreateWorkspace in database

func (*Handler) DeleteWorkspace

func (h *Handler) DeleteWorkspace(ctx context.Context, req *idm.DeleteWorkspaceRequest) (*idm.DeleteWorkspaceResponse, error)

DeleteWorkspace from database

func (*Handler) ModifyLogin

func (h *Handler) ModifyLogin(ctx context.Context, req *service.ModifyLoginRequest) (*service.ModifyLoginResponse, error)

func (*Handler) SearchWorkspace

func (h *Handler) SearchWorkspace(request *idm.SearchWorkspaceRequest, response idm.WorkspaceService_SearchWorkspaceServer) error

SearchWorkspace in database

func (*Handler) StreamWorkspace

func (h *Handler) StreamWorkspace(streamer idm.WorkspaceService_StreamWorkspaceServer) error

StreamWorkspace from database

type WsCleaner

type WsCleaner struct {
	Handler idm.WorkspaceServiceServer
	// contains filtered or unexported fields
}

WsCleaner subscribe to ACL:Delete events to clean workspaces that do not have any ACLs anymore

func NewWsCleaner

func NewWsCleaner(ctx context.Context, h idm.WorkspaceServiceServer) *WsCleaner

func (*WsCleaner) Handle

func (c *WsCleaner) Handle(ctx context.Context, msg *idm.ChangeEvent) error