grpc

Documentation

Index

• type Handler
  • func (h *Handler) PostActivity(stream proto.ActivityService_PostActivityServer) error
  • func (h *Handler) PurgeActivities(ctx context.Context, request *proto.PurgeActivitiesRequest) (*proto.PurgeActivitiesResponse, error)
  • func (h *Handler) SearchSubscriptions(request *proto.SearchSubscriptionsRequest, ...) error
  • func (h *Handler) SetUserLastActivity(ctx context.Context, request *proto.UserLastActivityRequest) (*proto.UserLastActivityResponse, error)
  • func (h *Handler) StreamActivities(request *proto.StreamActivitiesRequest, ...) error
  • func (h *Handler) Subscribe(ctx context.Context, request *proto.SubscribeRequest) (*proto.SubscribeResponse, error)
  • func (h *Handler) UnreadActivitiesNumber(ctx context.Context, request *proto.UnreadActivitiesRequest) (*proto.UnreadActivitiesResponse, error)
• type MetaProvider
  • func (m *MetaProvider) ReadNodeStream(streamer tree.NodeProviderStreamer_ReadNodeStreamServer) error
• type MicroEventsSubscriber
  • func NewEventsSubscriber(ctx context.Context, handlerName string) *MicroEventsSubscriber
  • func (e *MicroEventsSubscriber) HandleIdmChange(ctx context.Context, msg *idm.ChangeEvent) error
  • func (e *MicroEventsSubscriber) HandleNodeChange(ctx context.Context, msg *tree.NodeChangeEvent) error
  • func (e *MicroEventsSubscriber) LoadResources(ctx context.Context, roles map[string]*idm.Role, users map[string]*idm.User, ...) error
  • func (e *MicroEventsSubscriber) ProcessIdmBatch(ctx context.Context, cE ...broker.Message)

Types

type Handler

type Handler struct {
	proto.UnimplementedActivityServiceServer
}

func (*Handler) PostActivity

func (h *Handler) PostActivity(stream proto.ActivityService_PostActivityServer) error

func (*Handler) PurgeActivities

func (h *Handler) PurgeActivities(ctx context.Context, request *proto.PurgeActivitiesRequest) (*proto.PurgeActivitiesResponse, error)

func (*Handler) SearchSubscriptions

func (h *Handler) SearchSubscriptions(request *proto.SearchSubscriptionsRequest, stream proto.ActivityService_SearchSubscriptionsServer) error

func (*Handler) SetUserLastActivity

func (h *Handler) SetUserLastActivity(ctx context.Context, request *proto.UserLastActivityRequest) (*proto.UserLastActivityResponse, error)

func (*Handler) StreamActivities

func (h *Handler) StreamActivities(request *proto.StreamActivitiesRequest, stream proto.ActivityService_StreamActivitiesServer) error

func (*Handler) Subscribe

func (h *Handler) Subscribe(ctx context.Context, request *proto.SubscribeRequest) (*proto.SubscribeResponse, error)

func (*Handler) UnreadActivitiesNumber

func (h *Handler) UnreadActivitiesNumber(ctx context.Context, request *proto.UnreadActivitiesRequest) (*proto.UnreadActivitiesResponse, error)

type MetaProvider

type MetaProvider struct {
	tree.UnimplementedNodeProviderStreamerServer
}

func (*MetaProvider) ReadNodeStream

func (m *MetaProvider) ReadNodeStream(streamer tree.NodeProviderStreamer_ReadNodeStreamServer) error

type MicroEventsSubscriber

type MicroEventsSubscriber struct {
	sync.Mutex
	RuntimeCtx context.Context
	// contains filtered or unexported fields
}

func NewEventsSubscriber

func NewEventsSubscriber(ctx context.Context, handlerName string) *MicroEventsSubscriber

func (*MicroEventsSubscriber) HandleIdmChange

func (e *MicroEventsSubscriber) HandleIdmChange(ctx context.Context, msg *idm.ChangeEvent) error

func (*MicroEventsSubscriber) HandleNodeChange

func (e *MicroEventsSubscriber) HandleNodeChange(ctx context.Context, msg *tree.NodeChangeEvent) error

HandleNodeChange processes the received events and sends them to the subscriber

func (*MicroEventsSubscriber) LoadResources

func (e *MicroEventsSubscriber) LoadResources(ctx context.Context, roles map[string]*idm.Role, users map[string]*idm.User, workspaces map[string]*idm.Workspace) error

func (*MicroEventsSubscriber) ProcessIdmBatch

func (e *MicroEventsSubscriber) ProcessIdmBatch(ctx context.Context, cE ...broker.Message)