grpc

Documentation

Overview

Package grpc provides the persistence for workspaces

Index

• 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, ...) error
  • func (h *Handler) DeleteWorkspace(ctx context.Context, req *idm.DeleteWorkspaceRequest, ...) error
  • func (h *Handler) SearchWorkspace(ctx context.Context, request *idm.SearchWorkspaceRequest, ...) error
  • func (h *Handler) StreamWorkspace(ctx context.Context, streamer idm.WorkspaceService_StreamWorkspaceStream) error
• type WsCleaner
  • func NewWsCleaner(h *Handler, ctx context.Context) *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(wsId string, done chan string, timeout time.Duration) *AclBatcher

func (*AclBatcher) Start

func (a *AclBatcher) Start()

type Handler

type Handler struct{}

Handler definition

func (*Handler) CreateWorkspace

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

CreateWorkspace in database

func (*Handler) DeleteWorkspace

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

DeleteWorkspace from database

func (*Handler) SearchWorkspace

func (h *Handler) SearchWorkspace(ctx context.Context, request *idm.SearchWorkspaceRequest, response idm.WorkspaceService_SearchWorkspaceStream) error

SearchWorkspace in database

func (*Handler) StreamWorkspace

func (h *Handler) StreamWorkspace(ctx context.Context, streamer idm.WorkspaceService_StreamWorkspaceStream) error

StreamWorkspace from database

type WsCleaner

type WsCleaner struct {
	Handler *Handler
	// 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(h *Handler, ctx context.Context) *WsCleaner

func (*WsCleaner) Handle

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