grpc

package
v1.0.1 Latest Latest
Warning

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

Go to latest
Published: Jun 18, 2018 License: AGPL-3.0 Imports: 20 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) 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 {
	// contains filtered or unexported fields
}

func (*MicroEventsSubscriber) Handle

Handle processes the received events and sends them to the subscriber

Jump to

Keyboard shortcuts

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