grpc

Documentation

Overview

Package grpc provides persistence layer for user-defined metadata

Index

• Variables
• type Cleaner
  • func NewCleaner(dao dao.DAO) *Cleaner
  • func (c *Cleaner) Handle(ctx context.Context, msg *idm.ChangeEvent) error
• type Handler
  • func NewHandler() *Handler
  • func (h *Handler) ListUserMetaNamespace(ctx context.Context, request *idm.ListUserMetaNamespaceRequest, ...) error
  • func (h *Handler) ReadNodeStream(ctx context.Context, stream tree.NodeProviderStreamer_ReadNodeStreamStream) error
  • func (h *Handler) SearchUserMeta(ctx context.Context, request *idm.SearchUserMetaRequest, ...) error
  • func (h *Handler) Stop()
  • func (h *Handler) UpdateUserMeta(ctx context.Context, request *idm.UpdateUserMetaRequest, ...) error
  • func (h *Handler) UpdateUserMetaNamespace(ctx context.Context, request *idm.UpdateUserMetaNamespaceRequest, ...) error

Variables

var (
	Name = common.SERVICE_GRPC_NAMESPACE_ + common.SERVICE_USER_META
)

Types

type Cleaner

type Cleaner struct {
	Dao meta.DAO
}

Cleaner cleans bookmarks on user deletion

func NewCleaner

func NewCleaner(dao dao.DAO) *Cleaner

func (*Cleaner) Handle

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

type Handler

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

Handler definition.

func NewHandler

func NewHandler() *Handler

func (*Handler) ListUserMetaNamespace

func (h *Handler) ListUserMetaNamespace(ctx context.Context, request *idm.ListUserMetaNamespaceRequest, stream idm.UserMetaService_ListUserMetaNamespaceStream) error

List all namespaces from underlying DAO.

func (*Handler) ReadNodeStream

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

Implements ReadNodeStream to be a meta provider.

func (*Handler) SearchUserMeta

func (h *Handler) SearchUserMeta(ctx context.Context, request *idm.SearchUserMetaRequest, stream idm.UserMetaService_SearchUserMetaStream) error

SearchUserMeta retrieves meta based on various criteria.

func (*Handler) Stop

func (h *Handler) Stop()

func (*Handler) UpdateUserMeta

func (h *Handler) UpdateUserMeta(ctx context.Context, request *idm.UpdateUserMetaRequest, response *idm.UpdateUserMetaResponse) error

UpdateUserMeta adds, updates or deletes user meta.

func (*Handler) UpdateUserMetaNamespace

func (h *Handler) UpdateUserMetaNamespace(ctx context.Context, request *idm.UpdateUserMetaNamespaceRequest, response *idm.UpdateUserMetaNamespaceResponse) error

Update/Delete a namespace.