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
- type Handler
- func (h *Handler) Name() string
- 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
- 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) ProcessBuffer(cE ...*idm.ChangeEvent)
Constants ¶
This section is empty.
Variables ¶
View Source
var (
Name = common.ServiceGrpcNamespace_ + common.ServiceActivity
)
Functions ¶
This section is empty.
Types ¶
type Handler ¶
type Handler struct {
proto.UnimplementedActivityServiceServer
RuntimeCtx context.Context
// contains filtered or unexported fields
}
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
RuntimeCtx context.Context
// contains filtered or unexported fields
}
func (*MetaProvider) Name ¶
func (m *MetaProvider) Name() string
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, 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
HandleNodeChange processes the received events and sends them to the subscriber
func (*MicroEventsSubscriber) LoadResources ¶
func (*MicroEventsSubscriber) ProcessBuffer ¶
func (e *MicroEventsSubscriber) ProcessBuffer(cE ...*idm.ChangeEvent)
Source Files
Click to show internal directories.
Click to hide internal directories.