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
- type 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)
Constants ¶
This section is empty.
Variables ¶
View Source
var (
Name = common.SERVICE_GRPC_NAMESPACE_ + common.SERVICE_ACTIVITY
)
Functions ¶
func RegisterDigestJob ¶
Types ¶
type Handler ¶
type Handler struct {
// contains filtered or unexported fields
}
func (*Handler) PostActivity ¶
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 ¶
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 (*MicroEventsSubscriber) ParentsFromCache ¶
func (*MicroEventsSubscriber) ProcessBuffer ¶
func (e *MicroEventsSubscriber) ProcessBuffer(cE ...*idm.ChangeEvent)
Source Files
Click to show internal directories.
Click to hide internal directories.