Versions in this module Expand all Collapse all v1 v1.6.1 Jul 9, 2019 Changes in this version + var Name = common.SERVICE_GRPC_NAMESPACE_ + common.SERVICE_ACTIVITY + func RegisterDigestJob(ctx context.Context) error + type Handler struct + 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 struct + func (m *MetaProvider) ReadNodeStream(ctx context.Context, streamer tree.NodeProviderStreamer_ReadNodeStreamStream) error + type MicroEventsSubscriber struct + 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) []string + func (e *MicroEventsSubscriber) ProcessBuffer(cE ...*idm.ChangeEvent) Incompatible versions in this module v2.0.6+incompatible Apr 23, 2020