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
• 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
  • func (m *MetaProvider) Name() string
  • func (m *MetaProvider) ReadNodeStream(streamer tree.NodeProviderStreamer_ReadNodeStreamServer) error
• type MicroEventsSubscriber
  • func NewEventsSubscriber(ctx context.Context, 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) ProcessBuffer(cE ...*idm.ChangeEvent)

Variables

var (
	Name = common.ServiceGrpcNamespace_ + common.ServiceActivity
)

Types

type Handler

type Handler struct {
	proto.UnimplementedActivityServiceServer
	RuntimeCtx context.Context
	// contains filtered or unexported fields
}

func (*Handler) Name

func (h *Handler) Name() string

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 (e *MicroEventsSubscriber) LoadResources(ctx context.Context, roles map[string]*idm.Role, users map[string]*idm.User, workspaces map[string]*idm.Workspace) error

func (*MicroEventsSubscriber) ProcessBuffer

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