grpc

Documentation

Overview

Package grpc is the persistence service for all activities.

It is listening to many events broadcasted by the application and storing them inside associated feeds, depending on the event context, owner, object type, etc... Persistence is implemented on a Bolt database.

Index

• Variables
• func RegisterDigestJob(ctx context.Context) error
• type Handler
  • func (h *Handler) PostActivity(ctx context.Context, stream proto.ActivityService_PostActivityStream) error
  • func (h *Handler) SearchSubscriptions(ctx context.Context, request *proto.SearchSubscriptionsRequest, ...) error
  • func (h *Handler) SetUserLastActivity(ctx context.Context, request *proto.UserLastActivityRequest, ...) error
  • func (h *Handler) StreamActivities(ctx context.Context, request *proto.StreamActivitiesRequest, ...) error
  • func (h *Handler) Subscribe(ctx context.Context, request *proto.SubscribeRequest, ...) (err error)
  • func (h *Handler) UnreadActivitiesNumber(ctx context.Context, request *proto.UnreadActivitiesRequest, ...) error
• type MetaProvider
  • func (m *MetaProvider) ReadNodeStream(ctx context.Context, streamer tree.NodeProviderStreamer_ReadNodeStreamStream) error
• type MicroEventsSubscriber
  • func NewEventsSubscriber(dao activity.DAO) *MicroEventsSubscriber
  • func (e *MicroEventsSubscriber) DebounceAclsEvents()
  • 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) ParentsFromCache(ctx context.Context, node *tree.Node, isDel bool) (*tree.Node, []string)
  • func (e *MicroEventsSubscriber) ProcessBuffer(cE ...*idm.ChangeEvent)

Variables

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

Functions

func RegisterDigestJob

func RegisterDigestJob(ctx context.Context) error

Types

type Handler

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

func (*Handler) PostActivity

func (h *Handler) PostActivity(ctx context.Context, stream proto.ActivityService_PostActivityStream) error

func (*Handler) SearchSubscriptions

func (h *Handler) SearchSubscriptions(ctx context.Context, request *proto.SearchSubscriptionsRequest, stream proto.ActivityService_SearchSubscriptionsStream) error

func (*Handler) SetUserLastActivity

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

func (*Handler) StreamActivities

func (h *Handler) StreamActivities(ctx context.Context, request *proto.StreamActivitiesRequest, stream proto.ActivityService_StreamActivitiesStream) error

func (*Handler) Subscribe

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

func (*Handler) UnreadActivitiesNumber

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

type MetaProvider

type MetaProvider struct {
}

func (*MetaProvider) ReadNodeStream

func (m *MetaProvider) ReadNodeStream(ctx context.Context, streamer tree.NodeProviderStreamer_ReadNodeStreamStream) error

type MicroEventsSubscriber

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

func NewEventsSubscriber

func NewEventsSubscriber(dao activity.DAO) *MicroEventsSubscriber

func (*MicroEventsSubscriber) DebounceAclsEvents

func (e *MicroEventsSubscriber) DebounceAclsEvents()

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

Handle 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) ParentsFromCache

func (e *MicroEventsSubscriber) ParentsFromCache(ctx context.Context, node *tree.Node, isDel bool) (*tree.Node, []string)

func (*MicroEventsSubscriber) ProcessBuffer

func (e *MicroEventsSubscriber) ProcessBuffer(cE ...*idm.ChangeEvent)