grpc

Documentation

Overview

Package grpc provides the persistence for workspaces

Index

• Constants
• func NewHandler(ctx context.Context, dao workspace.DAO) idm.NamedWorkspaceServiceServer
• type AclBatcher
  • func NewAclBatcher(wsId string, done chan string, timeout time.Duration) *AclBatcher
  • func (a *AclBatcher) Start()
• type 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) Name() string
  • 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

Constants

const (
	ServiceName = common.ServiceGrpcNamespace_ + common.ServiceWorkspace
)

Functions

func NewHandler

func NewHandler(ctx context.Context, dao workspace.DAO) idm.NamedWorkspaceServiceServer

Types

type AclBatcher

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

func NewAclBatcher

func NewAclBatcher(wsId string, done chan string, timeout time.Duration) *AclBatcher

func (*AclBatcher) Start

func (a *AclBatcher) Start()

type Handler

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

Handler definition

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) Name

func (h *Handler) Name() string

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