grpc

package
v2.2.7+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 6, 2021 License: AGPL-3.0 Imports: 33 Imported by: 0

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

Constants

This section is empty.

Variables

Functions

func RegisterDigestJob

func RegisterDigestJob(ctx context.Context) error

Types

type Handler

type Handler struct {
	// contains filtered or unexported fields
}

func (*Handler) PostActivity

func (*Handler) PurgeActivities

func (h *Handler) PurgeActivities(ctx context.Context, request *proto.PurgeActivitiesRequest, response *proto.PurgeActivitiesResponse) error

func (*Handler) SetUserLastActivity

func (h *Handler) SetUserLastActivity(ctx context.Context, request *proto.UserLastActivityRequest, response *proto.UserLastActivityResponse) error

func (*Handler) StreamActivities

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

type MicroEventsSubscriber

type MicroEventsSubscriber struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewEventsSubscriber added in v1.5.0

func NewEventsSubscriber(dao activity.DAO) *MicroEventsSubscriber

func (*MicroEventsSubscriber) DebounceAclsEvents added in v1.5.0

func (e *MicroEventsSubscriber) DebounceAclsEvents()

func (*MicroEventsSubscriber) HandleIdmChange added in v1.5.0

func (e *MicroEventsSubscriber) HandleIdmChange(ctx context.Context, msg *idm.ChangeEvent) error

func (*MicroEventsSubscriber) HandleNodeChange added in v1.5.0

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 added in v1.5.0

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 added in v1.5.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL