grpc

package
v3.0.0-rc1+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 20, 2021 License: AGPL-3.0 Imports: 21 Imported by: 0

Documentation

Overview

Package grpc provides the persistence for workspaces

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AclBatcher added in v1.2.0

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

func NewAclBatcher added in v1.2.0

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

func (*AclBatcher) Start added in v1.2.0

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

SearchWorkspace in database

func (*Handler) StreamWorkspace

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

StreamWorkspace from database

type WsCleaner added in v1.2.0

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 added in v1.2.0

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

func (*WsCleaner) Handle added in v1.2.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL