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 (e *MicroEventsSubscriber) Handle(ctx context.Context, msg *tree.NodeChangeEvent) error

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 {
	// contains filtered or unexported fields
}

func (*MicroEventsSubscriber) Handle

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

Handle processes the received events and sends them to the subscriber