grpc

Documentation

Overview

Package grpc provides a service for storing and CRUD-ing ACLs

Index

• func UpgradeTo120(ctx context.Context) error
• type Handler
  • func (h *Handler) CreateACL(ctx context.Context, req *idm.CreateACLRequest, resp *idm.CreateACLResponse) error
  • func (h *Handler) DeleteACL(ctx context.Context, req *idm.DeleteACLRequest, ...) error
  • func (h *Handler) ExpireACL(ctx context.Context, req *idm.ExpireACLRequest, resp *idm.ExpireACLResponse) error
  • func (h *Handler) ReadNodeStream(ctx context.Context, stream tree.NodeProviderStreamer_ReadNodeStreamStream) error
  • func (h *Handler) SearchACL(ctx context.Context, request *idm.SearchACLRequest, ...) error
  • func (h *Handler) StreamACL(ctx context.Context, streamer idm.ACLService_StreamACLStream) error
• type NodesCleaner
  • func (c *NodesCleaner) Handle(ctx context.Context, msg *tree.NodeChangeEvent) error
• type WsRolesCleaner
  • func (c *WsRolesCleaner) Handle(ctx context.Context, msg *idm.ChangeEvent) error

Functions

func UpgradeTo120

func UpgradeTo120(ctx context.Context) error

UpgradeTo120 looks for workspace roots and CellNode roots and set a "recycle_root" flag on them.

Types

type Handler

type Handler struct {
}

Handler definition

func (*Handler) CreateACL

func (h *Handler) CreateACL(ctx context.Context, req *idm.CreateACLRequest, resp *idm.CreateACLResponse) error

CreateACL in database

func (*Handler) DeleteACL

func (h *Handler) DeleteACL(ctx context.Context, req *idm.DeleteACLRequest, response *idm.DeleteACLResponse) error

DeleteACL from database

func (*Handler) ExpireACL

func (h *Handler) ExpireACL(ctx context.Context, req *idm.ExpireACLRequest, resp *idm.ExpireACLResponse) error

ExpireACL in database

func (*Handler) ReadNodeStream

func (h *Handler) ReadNodeStream(ctx context.Context, stream tree.NodeProviderStreamer_ReadNodeStreamStream) error

Implements ReadNodeStream to be a meta provider

func (*Handler) SearchACL

func (h *Handler) SearchACL(ctx context.Context, request *idm.SearchACLRequest, response idm.ACLService_SearchACLStream) error

SearchACL in database

func (*Handler) StreamACL

func (h *Handler) StreamACL(ctx context.Context, streamer idm.ACLService_StreamACLStream) error

StreamACL from database

type NodesCleaner

type NodesCleaner struct {
	Handler *Handler
}

func (*NodesCleaner) Handle

func (c *NodesCleaner) Handle(ctx context.Context, msg *tree.NodeChangeEvent) error

type WsRolesCleaner

type WsRolesCleaner struct {
	Handler *Handler
}

func (*WsRolesCleaner) Handle

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