grpc

Documentation

Overview

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

Index

• Variables
• func UpgradeTo120(ctx context.Context) error
• type Handler
  • func NewHandler(_ context.Context, dao acl.DAO) *Handler
  • func (h *Handler) CreateACL(ctx context.Context, req *idm.CreateACLRequest) (*idm.CreateACLResponse, error)
  • func (h *Handler) DeleteACL(ctx context.Context, req *idm.DeleteACLRequest) (*idm.DeleteACLResponse, error)
  • func (h *Handler) ExpireACL(ctx context.Context, req *idm.ExpireACLRequest) (*idm.ExpireACLResponse, error)
  • func (h *Handler) Name() string
  • func (h *Handler) ReadNodeStream(stream tree.NodeProviderStreamer_ReadNodeStreamServer) error
  • func (h *Handler) RestoreACL(ctx context.Context, req *idm.RestoreACLRequest) (*idm.RestoreACLResponse, error)
  • func (h *Handler) SearchACL(request *idm.SearchACLRequest, response idm.ACLService_SearchACLServer) error
  • func (h *Handler) StreamACL(streamer idm.ACLService_StreamACLServer) error
• type WsRolesCleaner
  • func (c *WsRolesCleaner) Handle(ctx context.Context, msg *idm.ChangeEvent) error

Variables

var ServiceName = common.ServiceGrpcNamespace_ + common.ServiceAcl

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 {
	idm.UnimplementedACLServiceServer
	tree.UnimplementedNodeProviderStreamerServer
	// contains filtered or unexported fields
}

Handler definition

func NewHandler

func NewHandler(_ context.Context, dao acl.DAO) *Handler

func (*Handler) CreateACL

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

CreateACL in database

func (*Handler) DeleteACL

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

DeleteACL from database

func (*Handler) ExpireACL

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

ExpireACL in database

func (*Handler) Name

func (h *Handler) Name() string

func (*Handler) ReadNodeStream

func (h *Handler) ReadNodeStream(stream tree.NodeProviderStreamer_ReadNodeStreamServer) error

ReadNodeStream implements method to be a MetaProvider

func (*Handler) RestoreACL

func (h *Handler) RestoreACL(ctx context.Context, req *idm.RestoreACLRequest) (*idm.RestoreACLResponse, error)

RestoreACL in database

func (*Handler) SearchACL

func (h *Handler) SearchACL(request *idm.SearchACLRequest, response idm.ACLService_SearchACLServer) error

SearchACL in database

func (*Handler) StreamACL

func (h *Handler) StreamACL(streamer idm.ACLService_StreamACLServer) error

StreamACL from database

type WsRolesCleaner

type WsRolesCleaner struct {
	Handler *Handler
}

func (*WsRolesCleaner) Handle

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