activity

package
v2.2.0-rc1+incompatible Latest Latest
Warning

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

 Go to latest Published: Dec 3, 2020 License: AGPL-3.0 Imports: 11 Imported by: 0

Documentation

Overview

Package activity is a generated protocol buffer package.

It is generated from these files: 

activitystream.proto

It has these top-level messages: 

Object
PostActivityRequest
PostActivityResponse
PostActivityEvent
StreamActivitiesRequest
StreamActivitiesResponse
Subscription
SubscribeRequest
SubscribeResponse
SearchSubscriptionsRequest
SearchSubscriptionsResponse
UnreadActivitiesRequest
UnreadActivitiesResponse
UserLastActivityRequest
UserLastActivityResponse
PurgeActivitiesRequest
PurgeActivitiesResponse

Package activity is a generated protocol buffer package.

It is generated from these files: 

activitystream.proto

It has these top-level messages: 

Object
PostActivityRequest
PostActivityResponse
PostActivityEvent
StreamActivitiesRequest
StreamActivitiesResponse
Subscription
SubscribeRequest
SubscribeResponse
SearchSubscriptionsRequest
SearchSubscriptionsResponse
UnreadActivitiesRequest
UnreadActivitiesResponse
UserLastActivityRequest
UserLastActivityResponse
PurgeActivitiesRequest
PurgeActivitiesResponse

Index

Constants

This section is empty.

Variables

View Source 
var ObjectType_name = map[int32]string{
	0:  "BaseObject",
	1:  "Activity",
	47: "Link",
	48: "Mention",
	49: "Collection",
	50: "OrderedCollection",
	51: "CollectionPage",
	52: "OrderedCollectionPage",
	2:  "Application",
	3:  "Group",
	4:  "Organization",
	5:  "Person",
	6:  "Service",
	7:  "Article",
	8:  "Audio",
	9:  "Document",
	10: "Event",
	11: "Image",
	12: "Note",
	13: "Page",
	14: "Place",
	15: "Profile",
	16: "Relationship",
	17: "Tombstone",
	18: "Video",
	19: "Accept",
	20: "Add",
	21: "Announce",
	22: "Arrive",
	23: "Block",
	24: "Create",
	25: "Delete",
	26: "Dislike",
	27: "Flag",
	28: "Follow",
	29: "Ignore",
	30: "Invite",
	31: "Join",
	32: "Leave",
	33: "Like",
	34: "Listen",
	35: "Move",
	36: "Offer",
	37: "Question",
	38: "Reject",
	39: "Read",
	40: "Remove",
	41: "TentativeReject",
	42: "TentativeAccept",
	43: "Travel",
	44: "Undo",
	45: "Update",
	58: "UpdateComment",
	59: "UpdateMeta",
	46: "View",
	53: "Workspace",
	54: "Digest",
	55: "Folder",
	56: "Cell",
	57: "Share",
}
View Source 
var ObjectType_value = map[string]int32{
	"BaseObject":            0,
	"Activity":              1,
	"Link":                  47,
	"Mention":               48,
	"Collection":            49,
	"OrderedCollection":     50,
	"CollectionPage":        51,
	"OrderedCollectionPage": 52,
	"Application":           2,
	"Group":                 3,
	"Organization":          4,
	"Person":                5,
	"Service":               6,
	"Article":               7,
	"Audio":                 8,
	"Document":              9,
	"Event":                 10,
	"Image":                 11,
	"Note":                  12,
	"Page":                  13,
	"Place":                 14,
	"Profile":               15,
	"Relationship":          16,
	"Tombstone":             17,
	"Video":                 18,
	"Accept":                19,
	"Add":                   20,
	"Announce":              21,
	"Arrive":                22,
	"Block":                 23,
	"Create":                24,
	"Delete":                25,
	"Dislike":               26,
	"Flag":                  27,
	"Follow":                28,
	"Ignore":                29,
	"Invite":                30,
	"Join":                  31,
	"Leave":                 32,
	"Like":                  33,
	"Listen":                34,
	"Move":                  35,
	"Offer":                 36,
	"Question":              37,
	"Reject":                38,
	"Read":                  39,
	"Remove":                40,
	"TentativeReject":       41,
	"TentativeAccept":       42,
	"Travel":                43,
	"Undo":                  44,
	"Update":                45,
	"UpdateComment":         58,
	"UpdateMeta":            59,
	"View":                  46,
	"Workspace":             53,
	"Digest":                54,
	"Folder":                55,
	"Cell":                  56,
	"Share":                 57,
}
View Source 
var OwnerType_name = map[int32]string{
	0: "NODE",
	1: "USER",
}
View Source 
var OwnerType_value = map[string]int32{
	"NODE": 0,
	"USER": 1,
}
View Source 
var StreamContext_name = map[int32]string{
	0: "MYFEED",
	1: "USER_ID",
	2: "NODE_ID",
}
View Source 
var StreamContext_value = map[string]int32{
	"MYFEED":  0,
	"USER_ID": 1,
	"NODE_ID": 2,
}
View Source 
var SummaryPointOfView_name = map[int32]string{
	0: "GENERIC",
	1: "ACTOR",
	2: "SUBJECT",
}
View Source 
var SummaryPointOfView_value = map[string]int32{
	"GENERIC": 0,
	"ACTOR":   1,
	"SUBJECT": 2,
}

Functions

func RegisterActivityServiceHandler 

func RegisterActivityServiceHandler(s server.Server, hdlr ActivityServiceHandler, opts ...server.HandlerOption)

Types

type ActivityService 

type ActivityService struct {
	ActivityServiceHandler
}

func (*ActivityService) PostActivity 

func (h *ActivityService) PostActivity(ctx context.Context, stream server.Streamer) error

func (*ActivityService) PurgeActivities 

func (h *ActivityService) PurgeActivities(ctx context.Context, in *PurgeActivitiesRequest, out *PurgeActivitiesResponse) error

func (*ActivityService) SearchSubscriptions 

func (h *ActivityService) SearchSubscriptions(ctx context.Context, stream server.Streamer) error

func (*ActivityService) SetUserLastActivity 

func (h *ActivityService) SetUserLastActivity(ctx context.Context, in *UserLastActivityRequest, out *UserLastActivityResponse) error

func (*ActivityService) StreamActivities 

func (h *ActivityService) StreamActivities(ctx context.Context, stream server.Streamer) error

func (*ActivityService) Subscribe 

func (h *ActivityService) Subscribe(ctx context.Context, in *SubscribeRequest, out *SubscribeResponse) error

func (*ActivityService) UnreadActivitiesNumber 

func (h *ActivityService) UnreadActivitiesNumber(ctx context.Context, in *UnreadActivitiesRequest, out *UnreadActivitiesResponse) error

type ActivityServiceClient 

type ActivityServiceClient interface {
	PostActivity(ctx context.Context, opts ...client.CallOption) (ActivityService_PostActivityClient, error)
	StreamActivities(ctx context.Context, in *StreamActivitiesRequest, opts ...client.CallOption) (ActivityService_StreamActivitiesClient, error)
	UnreadActivitiesNumber(ctx context.Context, in *UnreadActivitiesRequest, opts ...client.CallOption) (*UnreadActivitiesResponse, error)
	PurgeActivities(ctx context.Context, in *PurgeActivitiesRequest, opts ...client.CallOption) (*PurgeActivitiesResponse, error)
	SetUserLastActivity(ctx context.Context, in *UserLastActivityRequest, opts ...client.CallOption) (*UserLastActivityResponse, error)
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...client.CallOption) (*SubscribeResponse, error)
	SearchSubscriptions(ctx context.Context, in *SearchSubscriptionsRequest, opts ...client.CallOption) (ActivityService_SearchSubscriptionsClient, error)
}

func NewActivityServiceClient 

func NewActivityServiceClient(serviceName string, c client.Client) ActivityServiceClient

type ActivityServiceHandler 

type ActivityServiceHandler interface {
	PostActivity(context.Context, ActivityService_PostActivityStream) error
	StreamActivities(context.Context, *StreamActivitiesRequest, ActivityService_StreamActivitiesStream) error
	UnreadActivitiesNumber(context.Context, *UnreadActivitiesRequest, *UnreadActivitiesResponse) error
	PurgeActivities(context.Context, *PurgeActivitiesRequest, *PurgeActivitiesResponse) error
	SetUserLastActivity(context.Context, *UserLastActivityRequest, *UserLastActivityResponse) error
	Subscribe(context.Context, *SubscribeRequest, *SubscribeResponse) error
	SearchSubscriptions(context.Context, *SearchSubscriptionsRequest, ActivityService_SearchSubscriptionsStream) error
}

type ActivityService_PostActivityClient 

type ActivityService_PostActivityClient interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*PostActivityRequest) error
}

type ActivityService_PostActivityStream 

type ActivityService_PostActivityStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*PostActivityRequest, error)
}

type ActivityService_SearchSubscriptionsClient 

type ActivityService_SearchSubscriptionsClient interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*SearchSubscriptionsResponse, error)
}

type ActivityService_SearchSubscriptionsStream 

type ActivityService_SearchSubscriptionsStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*SearchSubscriptionsResponse) error
}

type ActivityService_StreamActivitiesClient 

type ActivityService_StreamActivitiesClient interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*StreamActivitiesResponse, error)
}

type ActivityService_StreamActivitiesStream 

type ActivityService_StreamActivitiesStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*StreamActivitiesResponse) error
}

type Object 

type Object struct {
	JsonLdContext string                     `protobuf:"bytes,53,opt,name=jsonLdContext,json=@context" json:"jsonLdContext,omitempty"`
	Type          ObjectType                 `protobuf:"varint,1,opt,name=type,enum=activity.ObjectType" json:"type,omitempty"`
	Id            string                     `protobuf:"bytes,2,opt,name=id" json:"id,omitempty"`
	Name          string                     `protobuf:"bytes,3,opt,name=name" json:"name,omitempty"`
	Summary       string                     `protobuf:"bytes,4,opt,name=summary" json:"summary,omitempty"`
	Context       *Object                    `protobuf:"bytes,5,opt,name=context" json:"context,omitempty"`
	Attachment    *Object                    `protobuf:"bytes,6,opt,name=attachment" json:"attachment,omitempty"`
	AttributedTo  *Object                    `protobuf:"bytes,7,opt,name=attributedTo" json:"attributedTo,omitempty"`
	Audience      *Object                    `protobuf:"bytes,8,opt,name=audience" json:"audience,omitempty"`
	Content       *Object                    `protobuf:"bytes,9,opt,name=content" json:"content,omitempty"`
	StartTime     *google_protobuf.Timestamp `protobuf:"bytes,10,opt,name=startTime" json:"startTime,omitempty"`
	EndTime       *google_protobuf.Timestamp `protobuf:"bytes,11,opt,name=endTime" json:"endTime,omitempty"`
	Published     *google_protobuf.Timestamp `protobuf:"bytes,12,opt,name=published" json:"published,omitempty"`
	Updated       *google_protobuf.Timestamp `protobuf:"bytes,13,opt,name=updated" json:"updated,omitempty"`
	Duration      *google_protobuf.Timestamp `protobuf:"bytes,14,opt,name=duration" json:"duration,omitempty"`
	Url           *Object                    `protobuf:"bytes,15,opt,name=url" json:"url,omitempty"`
	MediaType     string                     `protobuf:"bytes,16,opt,name=mediaType" json:"mediaType,omitempty"`
	Icon          *Object                    `protobuf:"bytes,17,opt,name=icon" json:"icon,omitempty"`
	Image         *Object                    `protobuf:"bytes,18,opt,name=image" json:"image,omitempty"`
	Preview       *Object                    `protobuf:"bytes,19,opt,name=preview" json:"preview,omitempty"`
	Location      *Object                    `protobuf:"bytes,20,opt,name=location" json:"location,omitempty"`
	InReplyTo     *Object                    `protobuf:"bytes,21,opt,name=inReplyTo" json:"inReplyTo,omitempty"`
	Replies       *Object                    `protobuf:"bytes,22,opt,name=replies" json:"replies,omitempty"`
	Tag           *Object                    `protobuf:"bytes,23,opt,name=tag" json:"tag,omitempty"`
	Generator     *Object                    `protobuf:"bytes,24,opt,name=generator" json:"generator,omitempty"`
	To            *Object                    `protobuf:"bytes,25,opt,name=to" json:"to,omitempty"`
	Bto           *Object                    `protobuf:"bytes,26,opt,name=bto" json:"bto,omitempty"`
	Cc            *Object                    `protobuf:"bytes,27,opt,name=cc" json:"cc,omitempty"`
	Bcc           *Object                    `protobuf:"bytes,28,opt,name=bcc" json:"bcc,omitempty"`
	// Activity Properties
	Actor      *Object `protobuf:"bytes,29,opt,name=actor" json:"actor,omitempty"`
	Object     *Object `protobuf:"bytes,30,opt,name=object" json:"object,omitempty"`
	Target     *Object `protobuf:"bytes,31,opt,name=target" json:"target,omitempty"`
	Result     *Object `protobuf:"bytes,32,opt,name=result" json:"result,omitempty"`
	Origin     *Object `protobuf:"bytes,33,opt,name=origin" json:"origin,omitempty"`
	Instrument *Object `protobuf:"bytes,34,opt,name=instrument" json:"instrument,omitempty"`
	// Link Properties
	Href     string `protobuf:"bytes,35,opt,name=href" json:"href,omitempty"`
	Rel      string `protobuf:"bytes,36,opt,name=rel" json:"rel,omitempty"`
	Hreflang string `protobuf:"bytes,37,opt,name=hreflang" json:"hreflang,omitempty"`
	Height   int32  `protobuf:"varint,38,opt,name=height" json:"height,omitempty"`
	Width    int32  `protobuf:"varint,39,opt,name=width" json:"width,omitempty"`
	// Question Properties
	OneOf  *Object                    `protobuf:"bytes,40,opt,name=oneOf" json:"oneOf,omitempty"`
	AnyOf  *Object                    `protobuf:"bytes,41,opt,name=anyOf" json:"anyOf,omitempty"`
	Closed *google_protobuf.Timestamp `protobuf:"bytes,42,opt,name=closed" json:"closed,omitempty"`
	// Relationship Properties
	Subject      *Object `protobuf:"bytes,43,opt,name=subject" json:"subject,omitempty"`
	Relationship *Object `protobuf:"bytes,44,opt,name=relationship" json:"relationship,omitempty"`
	// Tombstone Properties
	FormerType ObjectType                 `protobuf:"varint,45,opt,name=formerType,enum=activity.ObjectType" json:"formerType,omitempty"`
	Deleted    *google_protobuf.Timestamp `protobuf:"bytes,46,opt,name=deleted" json:"deleted,omitempty"`
	// Place Properties
	Accuracy  float32 `protobuf:"fixed32,47,opt,name=accuracy" json:"accuracy,omitempty"`
	Altitude  float32 `protobuf:"fixed32,48,opt,name=altitude" json:"altitude,omitempty"`
	Latitude  float32 `protobuf:"fixed32,49,opt,name=latitude" json:"latitude,omitempty"`
	Longitude float32 `protobuf:"fixed32,50,opt,name=longitude" json:"longitude,omitempty"`
	Radius    float32 `protobuf:"fixed32,51,opt,name=radius" json:"radius,omitempty"`
	Units     string  `protobuf:"bytes,52,opt,name=units" json:"units,omitempty"`
	// Collection Properties
	Items      []*Object `protobuf:"bytes,54,rep,name=items" json:"items,omitempty"`
	TotalItems int32     `protobuf:"varint,55,opt,name=totalItems" json:"totalItems,omitempty"`
	Current    *Object   `protobuf:"bytes,56,opt,name=current" json:"current,omitempty"`
	First      *Object   `protobuf:"bytes,57,opt,name=first" json:"first,omitempty"`
	Last       *Object   `protobuf:"bytes,58,opt,name=last" json:"last,omitempty"`
	PartOf     *Object   `protobuf:"bytes,59,opt,name=partOf" json:"partOf,omitempty"`
	Next       *Object   `protobuf:"bytes,60,opt,name=next" json:"next,omitempty"`
	Prev       *Object   `protobuf:"bytes,61,opt,name=prev" json:"prev,omitempty"`
}

func (*Object) Descriptor 

func (*Object) Descriptor() ([]byte, []int)

func (*Object) GetAccuracy 

func (m *Object) GetAccuracy() float32

func (*Object) GetActor 

func (m *Object) GetActor() *Object

func (*Object) GetAltitude 

func (m *Object) GetAltitude() float32

func (*Object) GetAnyOf 

func (m *Object) GetAnyOf() *Object

func (*Object) GetAttachment 

func (m *Object) GetAttachment() *Object

func (*Object) GetAttributedTo 

func (m *Object) GetAttributedTo() *Object

func (*Object) GetAudience 

func (m *Object) GetAudience() *Object

func (*Object) GetBcc 

func (m *Object) GetBcc() *Object

func (*Object) GetBto 

func (m *Object) GetBto() *Object

func (*Object) GetCc 

func (m *Object) GetCc() *Object

func (*Object) GetClosed 

func (m *Object) GetClosed() *google_protobuf.Timestamp

func (*Object) GetContent 

func (m *Object) GetContent() *Object

func (*Object) GetContext 

func (m *Object) GetContext() *Object

func (*Object) GetCurrent 

func (m *Object) GetCurrent() *Object

func (*Object) GetDeleted 

func (m *Object) GetDeleted() *google_protobuf.Timestamp

func (*Object) GetDuration 

func (m *Object) GetDuration() *google_protobuf.Timestamp

func (*Object) GetEndTime 

func (m *Object) GetEndTime() *google_protobuf.Timestamp

func (*Object) GetFirst 

func (m *Object) GetFirst() *Object

func (*Object) GetFormerType 

func (m *Object) GetFormerType() ObjectType

func (*Object) GetGenerator 

func (m *Object) GetGenerator() *Object

func (*Object) GetHeight 

func (m *Object) GetHeight() int32

func (*Object) GetHref 

func (m *Object) GetHref() string

func (*Object) GetHreflang 

func (m *Object) GetHreflang() string

func (*Object) GetIcon 

func (m *Object) GetIcon() *Object

func (*Object) GetId 

func (m *Object) GetId() string

func (*Object) GetImage 

func (m *Object) GetImage() *Object

func (*Object) GetInReplyTo 

func (m *Object) GetInReplyTo() *Object

func (*Object) GetInstrument 

func (m *Object) GetInstrument() *Object

func (*Object) GetItems 

func (m *Object) GetItems() []*Object

func (*Object) GetJsonLdContext 

func (m *Object) GetJsonLdContext() string

func (*Object) GetLast 

func (m *Object) GetLast() *Object

func (*Object) GetLatitude 

func (m *Object) GetLatitude() float32

func (*Object) GetLocation 

func (m *Object) GetLocation() *Object

func (*Object) GetLongitude 

func (m *Object) GetLongitude() float32

func (*Object) GetMediaType 

func (m *Object) GetMediaType() string

func (*Object) GetName 

func (m *Object) GetName() string

func (*Object) GetNext 

func (m *Object) GetNext() *Object

func (*Object) GetObject 

func (m *Object) GetObject() *Object

func (*Object) GetOneOf 

func (m *Object) GetOneOf() *Object

func (*Object) GetOrigin 

func (m *Object) GetOrigin() *Object

func (*Object) GetPartOf 

func (m *Object) GetPartOf() *Object

func (*Object) GetPrev 

func (m *Object) GetPrev() *Object

func (*Object) GetPreview 

func (m *Object) GetPreview() *Object

func (*Object) GetPublished 

func (m *Object) GetPublished() *google_protobuf.Timestamp

func (*Object) GetRadius 

func (m *Object) GetRadius() float32

func (*Object) GetRel 

func (m *Object) GetRel() string

func (*Object) GetRelationship 

func (m *Object) GetRelationship() *Object

func (*Object) GetReplies 

func (m *Object) GetReplies() *Object

func (*Object) GetResult 

func (m *Object) GetResult() *Object

func (*Object) GetStartTime 

func (m *Object) GetStartTime() *google_protobuf.Timestamp

func (*Object) GetSubject 

func (m *Object) GetSubject() *Object

func (*Object) GetSummary 

func (m *Object) GetSummary() string

func (*Object) GetTag 

func (m *Object) GetTag() *Object

func (*Object) GetTarget 

func (m *Object) GetTarget() *Object

func (*Object) GetTo 

func (m *Object) GetTo() *Object

func (*Object) GetTotalItems 

func (m *Object) GetTotalItems() int32

func (*Object) GetType 

func (m *Object) GetType() ObjectType

func (*Object) GetUnits 

func (m *Object) GetUnits() string

func (*Object) GetUpdated 

func (m *Object) GetUpdated() *google_protobuf.Timestamp

func (*Object) GetUrl 

func (m *Object) GetUrl() *Object

func (*Object) GetWidth 

func (m *Object) GetWidth() int32

func (*Object) ProtoMessage 

func (*Object) ProtoMessage()

func (*Object) Reset 

func (m *Object) Reset()

func (*Object) String 

func (m *Object) String() string

func (*Object) Validate 

func (this *Object) Validate() error

type ObjectType 

type ObjectType int32
const (
	ObjectType_BaseObject ObjectType = 0
	ObjectType_Activity   ObjectType = 1
	ObjectType_Link       ObjectType = 47
	ObjectType_Mention    ObjectType = 48
	// CollectionTypes
	ObjectType_Collection            ObjectType = 49
	ObjectType_OrderedCollection     ObjectType = 50
	ObjectType_CollectionPage        ObjectType = 51
	ObjectType_OrderedCollectionPage ObjectType = 52
	// Actor Types
	ObjectType_Application  ObjectType = 2
	ObjectType_Group        ObjectType = 3
	ObjectType_Organization ObjectType = 4
	ObjectType_Person       ObjectType = 5
	ObjectType_Service      ObjectType = 6
	// Objects Types
	ObjectType_Article      ObjectType = 7
	ObjectType_Audio        ObjectType = 8
	ObjectType_Document     ObjectType = 9
	ObjectType_Event        ObjectType = 10
	ObjectType_Image        ObjectType = 11
	ObjectType_Note         ObjectType = 12
	ObjectType_Page         ObjectType = 13
	ObjectType_Place        ObjectType = 14
	ObjectType_Profile      ObjectType = 15
	ObjectType_Relationship ObjectType = 16
	ObjectType_Tombstone    ObjectType = 17
	ObjectType_Video        ObjectType = 18
	// Activity Types
	ObjectType_Accept          ObjectType = 19
	ObjectType_Add             ObjectType = 20
	ObjectType_Announce        ObjectType = 21
	ObjectType_Arrive          ObjectType = 22
	ObjectType_Block           ObjectType = 23
	ObjectType_Create          ObjectType = 24
	ObjectType_Delete          ObjectType = 25
	ObjectType_Dislike         ObjectType = 26
	ObjectType_Flag            ObjectType = 27
	ObjectType_Follow          ObjectType = 28
	ObjectType_Ignore          ObjectType = 29
	ObjectType_Invite          ObjectType = 30
	ObjectType_Join            ObjectType = 31
	ObjectType_Leave           ObjectType = 32
	ObjectType_Like            ObjectType = 33
	ObjectType_Listen          ObjectType = 34
	ObjectType_Move            ObjectType = 35
	ObjectType_Offer           ObjectType = 36
	ObjectType_Question        ObjectType = 37
	ObjectType_Reject          ObjectType = 38
	ObjectType_Read            ObjectType = 39
	ObjectType_Remove          ObjectType = 40
	ObjectType_TentativeReject ObjectType = 41
	ObjectType_TentativeAccept ObjectType = 42
	ObjectType_Travel          ObjectType = 43
	ObjectType_Undo            ObjectType = 44
	ObjectType_Update          ObjectType = 45
	ObjectType_UpdateComment   ObjectType = 58
	ObjectType_UpdateMeta      ObjectType = 59
	ObjectType_View            ObjectType = 46
	// Pydio Types
	ObjectType_Workspace ObjectType = 53
	ObjectType_Digest    ObjectType = 54
	ObjectType_Folder    ObjectType = 55
	ObjectType_Cell      ObjectType = 56
	ObjectType_Share     ObjectType = 57
)

func (ObjectType) EnumDescriptor 

func (ObjectType) EnumDescriptor() ([]byte, []int)

func (ObjectType) String 

func (x ObjectType) String() string

type OwnerType 

type OwnerType int32
const (
	OwnerType_NODE OwnerType = 0
	OwnerType_USER OwnerType = 1
)

func (OwnerType) EnumDescriptor 

func (OwnerType) EnumDescriptor() ([]byte, []int)

func (OwnerType) String 

func (x OwnerType) String() string

type PostActivityEvent 

type PostActivityEvent struct {
	JsonType  string    `protobuf:"bytes,1,opt,name=jsonType,json=@type" json:"jsonType,omitempty"`
	OwnerType OwnerType `protobuf:"varint,2,opt,name=OwnerType,enum=activity.OwnerType" json:"OwnerType,omitempty"`
	OwnerId   string    `protobuf:"bytes,3,opt,name=OwnerId" json:"OwnerId,omitempty"`
	BoxName   string    `protobuf:"bytes,4,opt,name=BoxName" json:"BoxName,omitempty"`
	Activity  *Object   `protobuf:"bytes,5,opt,name=Activity" json:"Activity,omitempty"`
}

func (*PostActivityEvent) Descriptor 

func (*PostActivityEvent) Descriptor() ([]byte, []int)

func (*PostActivityEvent) GetActivity 

func (m *PostActivityEvent) GetActivity() *Object

func (*PostActivityEvent) GetBoxName 

func (m *PostActivityEvent) GetBoxName() string

func (*PostActivityEvent) GetJsonType 

func (m *PostActivityEvent) GetJsonType() string

func (*PostActivityEvent) GetOwnerId 

func (m *PostActivityEvent) GetOwnerId() string

func (*PostActivityEvent) GetOwnerType 

func (m *PostActivityEvent) GetOwnerType() OwnerType

func (*PostActivityEvent) MarshalLogObject added in v1.5.0 

func (p *PostActivityEvent) MarshalLogObject(encoder zapcore.ObjectEncoder) error

MarshalLogObject implements custom marshalling for logs

func (*PostActivityEvent) ProtoMessage 

func (*PostActivityEvent) ProtoMessage()

func (*PostActivityEvent) Reset 

func (m *PostActivityEvent) Reset()

func (*PostActivityEvent) String 

func (m *PostActivityEvent) String() string

func (*PostActivityEvent) Validate 

func (this *PostActivityEvent) Validate() error

func (*PostActivityEvent) Zap 

func (p *PostActivityEvent) Zap() zapcore.Field

Zap simply returns a zapcore.Field object populated with this PostActivityEvent under a standard key

type PostActivityRequest 

type PostActivityRequest struct {
	Object *Object `protobuf:"bytes,1,opt,name=Object" json:"Object,omitempty"`
}

func (*PostActivityRequest) Descriptor 

func (*PostActivityRequest) Descriptor() ([]byte, []int)

func (*PostActivityRequest) GetObject 

func (m *PostActivityRequest) GetObject() *Object

func (*PostActivityRequest) ProtoMessage 

func (*PostActivityRequest) ProtoMessage()

func (*PostActivityRequest) Reset 

func (m *PostActivityRequest) Reset()

func (*PostActivityRequest) String 

func (m *PostActivityRequest) String() string

func (*PostActivityRequest) Validate 

func (this *PostActivityRequest) Validate() error

type PostActivityResponse 

type PostActivityResponse struct {
}

func (*PostActivityResponse) Descriptor 

func (*PostActivityResponse) Descriptor() ([]byte, []int)

func (*PostActivityResponse) ProtoMessage 

func (*PostActivityResponse) ProtoMessage()

func (*PostActivityResponse) Reset 

func (m *PostActivityResponse) Reset()

func (*PostActivityResponse) String 

func (m *PostActivityResponse) String() string

func (*PostActivityResponse) Validate 

func (this *PostActivityResponse) Validate() error

type PurgeActivitiesRequest 

type PurgeActivitiesRequest struct {
	// ObjectType
	OwnerType OwnerType `protobuf:"varint,1,opt,name=OwnerType,enum=activity.OwnerType" json:"OwnerType,omitempty"`
	// Object Id, use * to browse all
	OwnerID string `protobuf:"bytes,2,opt,name=OwnerID" json:"OwnerID,omitempty"`
	// Box Name
	BoxName string `protobuf:"bytes,3,opt,name=BoxName" json:"BoxName,omitempty"`
	// Keep at least this number of records
	MinCount int32 `protobuf:"varint,4,opt,name=minCount" json:"minCount,omitempty"`
	// Keep max number of records
	MaxCount int32 `protobuf:"varint,5,opt,name=maxCount" json:"maxCount,omitempty"`
	// Remove records updated before...
	UpdatedBeforeTimestamp int32 `protobuf:"varint,6,opt,name=updatedBeforeTimestamp" json:"updatedBeforeTimestamp,omitempty"`
}

func (*PurgeActivitiesRequest) Descriptor 

func (*PurgeActivitiesRequest) Descriptor() ([]byte, []int)

func (*PurgeActivitiesRequest) GetBoxName 

func (m *PurgeActivitiesRequest) GetBoxName() string

func (*PurgeActivitiesRequest) GetMaxCount 

func (m *PurgeActivitiesRequest) GetMaxCount() int32

func (*PurgeActivitiesRequest) GetMinCount 

func (m *PurgeActivitiesRequest) GetMinCount() int32

func (*PurgeActivitiesRequest) GetOwnerID 

func (m *PurgeActivitiesRequest) GetOwnerID() string

func (*PurgeActivitiesRequest) GetOwnerType 

func (m *PurgeActivitiesRequest) GetOwnerType() OwnerType

func (*PurgeActivitiesRequest) GetUpdatedBeforeTimestamp 

func (m *PurgeActivitiesRequest) GetUpdatedBeforeTimestamp() int32

func (*PurgeActivitiesRequest) ProtoMessage 

func (*PurgeActivitiesRequest) ProtoMessage()

func (*PurgeActivitiesRequest) Reset 

func (m *PurgeActivitiesRequest) Reset()

func (*PurgeActivitiesRequest) String 

func (m *PurgeActivitiesRequest) String() string

func (*PurgeActivitiesRequest) Validate 

func (this *PurgeActivitiesRequest) Validate() error

type PurgeActivitiesResponse 

type PurgeActivitiesResponse struct {
	// If request succeeded
	Success bool `protobuf:"varint,1,opt,name=Success" json:"Success,omitempty"`
	// Number of rows deleted
	DeletedCount int32 `protobuf:"varint,2,opt,name=DeletedCount" json:"DeletedCount,omitempty"`
}

func (*PurgeActivitiesResponse) Descriptor 

func (*PurgeActivitiesResponse) Descriptor() ([]byte, []int)

func (*PurgeActivitiesResponse) GetDeletedCount 

func (m *PurgeActivitiesResponse) GetDeletedCount() int32

func (*PurgeActivitiesResponse) GetSuccess 

func (m *PurgeActivitiesResponse) GetSuccess() bool

func (*PurgeActivitiesResponse) ProtoMessage 

func (*PurgeActivitiesResponse) ProtoMessage()

func (*PurgeActivitiesResponse) Reset 

func (m *PurgeActivitiesResponse) Reset()

func (*PurgeActivitiesResponse) String 

func (m *PurgeActivitiesResponse) String() string

func (*PurgeActivitiesResponse) Validate 

func (this *PurgeActivitiesResponse) Validate() error

type SearchSubscriptionsRequest 

type SearchSubscriptionsRequest struct {
	// List of UserIds for which we want to list
	UserIds []string `protobuf:"bytes,1,rep,name=UserIds" json:"UserIds,omitempty"`
	// Filter by type of objects
	ObjectTypes []OwnerType `protobuf:"varint,2,rep,packed,name=ObjectTypes,enum=activity.OwnerType" json:"ObjectTypes,omitempty"`
	// Filter by object Ids
	ObjectIds []string `protobuf:"bytes,3,rep,name=ObjectIds" json:"ObjectIds,omitempty"`
}

func (*SearchSubscriptionsRequest) Descriptor 

func (*SearchSubscriptionsRequest) Descriptor() ([]byte, []int)

func (*SearchSubscriptionsRequest) GetObjectIds 

func (m *SearchSubscriptionsRequest) GetObjectIds() []string

func (*SearchSubscriptionsRequest) GetObjectTypes 

func (m *SearchSubscriptionsRequest) GetObjectTypes() []OwnerType

func (*SearchSubscriptionsRequest) GetUserIds 

func (m *SearchSubscriptionsRequest) GetUserIds() []string

func (*SearchSubscriptionsRequest) ProtoMessage 

func (*SearchSubscriptionsRequest) ProtoMessage()

func (*SearchSubscriptionsRequest) Reset 

func (m *SearchSubscriptionsRequest) Reset()

func (*SearchSubscriptionsRequest) String 

func (m *SearchSubscriptionsRequest) String() string

func (*SearchSubscriptionsRequest) Validate 

func (this *SearchSubscriptionsRequest) Validate() error

type SearchSubscriptionsResponse 

type SearchSubscriptionsResponse struct {
	Subscription *Subscription `protobuf:"bytes,1,opt,name=Subscription" json:"Subscription,omitempty"`
}

func (*SearchSubscriptionsResponse) Descriptor 

func (*SearchSubscriptionsResponse) Descriptor() ([]byte, []int)

func (*SearchSubscriptionsResponse) GetSubscription 

func (m *SearchSubscriptionsResponse) GetSubscription() *Subscription

func (*SearchSubscriptionsResponse) ProtoMessage 

func (*SearchSubscriptionsResponse) ProtoMessage()

func (*SearchSubscriptionsResponse) Reset 

func (m *SearchSubscriptionsResponse) Reset()

func (*SearchSubscriptionsResponse) String 

func (m *SearchSubscriptionsResponse) String() string

func (*SearchSubscriptionsResponse) Validate 

func (this *SearchSubscriptionsResponse) Validate() error

type StreamActivitiesRequest 

type StreamActivitiesRequest struct {
	// Define the context of the stream
	Context StreamContext `protobuf:"varint,1,opt,name=Context,enum=activity.StreamContext" json:"Context,omitempty"`
	// Value for the context (e.g. User Id, Node Id)
	ContextData string `protobuf:"bytes,2,opt,name=ContextData" json:"ContextData,omitempty"`
	// Json-encoded filter
	StreamFilter string `protobuf:"bytes,3,opt,name=StreamFilter" json:"StreamFilter,omitempty"`
	// Target inbox or outbox for the given object
	BoxName string `protobuf:"bytes,4,opt,name=BoxName" json:"BoxName,omitempty"`
	// Count last activities that were not loaded yet
	UnreadCountOnly bool `protobuf:"varint,5,opt,name=UnreadCountOnly" json:"UnreadCountOnly,omitempty"`
	// Start listing at a given position
	Offset int64 `protobuf:"varint,6,opt,name=Offset" json:"Offset,omitempty"`
	// Limit the number of results
	Limit int64 `protobuf:"varint,7,opt,name=Limit" json:"Limit,omitempty"`
	// Compute a digest of all unread activities
	AsDigest bool `protobuf:"varint,8,opt,name=AsDigest" json:"AsDigest,omitempty"`
	// Provide context for building the human-readable strings of each activity
	PointOfView SummaryPointOfView `protobuf:"varint,9,opt,name=PointOfView,enum=activity.SummaryPointOfView" json:"PointOfView,omitempty"`
	// Provide language information for building the human-readable strings.
	Language string `protobuf:"bytes,10,opt,name=Language" json:"Language,omitempty"`
}

func (*StreamActivitiesRequest) Descriptor 

func (*StreamActivitiesRequest) Descriptor() ([]byte, []int)

func (*StreamActivitiesRequest) GetAsDigest 

func (m *StreamActivitiesRequest) GetAsDigest() bool

func (*StreamActivitiesRequest) GetBoxName 

func (m *StreamActivitiesRequest) GetBoxName() string

func (*StreamActivitiesRequest) GetContext 

func (m *StreamActivitiesRequest) GetContext() StreamContext

func (*StreamActivitiesRequest) GetContextData 

func (m *StreamActivitiesRequest) GetContextData() string

func (*StreamActivitiesRequest) GetLanguage 

func (m *StreamActivitiesRequest) GetLanguage() string

func (*StreamActivitiesRequest) GetLimit 

func (m *StreamActivitiesRequest) GetLimit() int64

func (*StreamActivitiesRequest) GetOffset 

func (m *StreamActivitiesRequest) GetOffset() int64

func (*StreamActivitiesRequest) GetPointOfView 

func (m *StreamActivitiesRequest) GetPointOfView() SummaryPointOfView

func (*StreamActivitiesRequest) GetStreamFilter 

func (m *StreamActivitiesRequest) GetStreamFilter() string

func (*StreamActivitiesRequest) GetUnreadCountOnly 

func (m *StreamActivitiesRequest) GetUnreadCountOnly() bool

func (*StreamActivitiesRequest) MarshalLogObject added in v1.5.0 

func (s *StreamActivitiesRequest) MarshalLogObject(encoder zapcore.ObjectEncoder) error

MarshalLogObject implements custom marshalling for logs

func (*StreamActivitiesRequest) ProtoMessage 

func (*StreamActivitiesRequest) ProtoMessage()

func (*StreamActivitiesRequest) Reset 

func (m *StreamActivitiesRequest) Reset()

func (*StreamActivitiesRequest) String 

func (m *StreamActivitiesRequest) String() string

func (*StreamActivitiesRequest) Validate 

func (this *StreamActivitiesRequest) Validate() error

func (*StreamActivitiesRequest) Zap 

func (s *StreamActivitiesRequest) Zap() zapcore.Field

Zap simply returns a zapcore.Field object populated with this StreamActivitiesRequest under a standard key

type StreamActivitiesResponse 

type StreamActivitiesResponse struct {
	Activity *Object `protobuf:"bytes,1,opt,name=activity" json:"activity,omitempty"`
}

func (*StreamActivitiesResponse) Descriptor 

func (*StreamActivitiesResponse) Descriptor() ([]byte, []int)

func (*StreamActivitiesResponse) GetActivity 

func (m *StreamActivitiesResponse) GetActivity() *Object

func (*StreamActivitiesResponse) ProtoMessage 

func (*StreamActivitiesResponse) ProtoMessage()

func (*StreamActivitiesResponse) Reset 

func (m *StreamActivitiesResponse) Reset()

func (*StreamActivitiesResponse) String 

func (m *StreamActivitiesResponse) String() string

func (*StreamActivitiesResponse) Validate 

func (this *StreamActivitiesResponse) Validate() error

type StreamContext 

type StreamContext int32
const (
	StreamContext_MYFEED  StreamContext = 0
	StreamContext_USER_ID StreamContext = 1
	StreamContext_NODE_ID StreamContext = 2
)

func (StreamContext) EnumDescriptor 

func (StreamContext) EnumDescriptor() ([]byte, []int)

func (StreamContext) String 

func (x StreamContext) String() string

type SubscribeRequest 

type SubscribeRequest struct {
	// Place a new subscription
	Subscription *Subscription `protobuf:"bytes,1,opt,name=Subscription" json:"Subscription,omitempty"`
}

func (*SubscribeRequest) Descriptor 

func (*SubscribeRequest) Descriptor() ([]byte, []int)

func (*SubscribeRequest) GetSubscription 

func (m *SubscribeRequest) GetSubscription() *Subscription

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) Reset 

func (m *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (m *SubscribeRequest) String() string

func (*SubscribeRequest) Validate 

func (this *SubscribeRequest) Validate() error

type SubscribeResponse 

type SubscribeResponse struct {
	Subscription *Subscription `protobuf:"bytes,1,opt,name=Subscription" json:"Subscription,omitempty"`
}

func (*SubscribeResponse) Descriptor 

func (*SubscribeResponse) Descriptor() ([]byte, []int)

func (*SubscribeResponse) GetSubscription 

func (m *SubscribeResponse) GetSubscription() *Subscription

func (*SubscribeResponse) ProtoMessage 

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) Reset 

func (m *SubscribeResponse) Reset()

func (*SubscribeResponse) String 

func (m *SubscribeResponse) String() string

func (*SubscribeResponse) Validate 

func (this *SubscribeResponse) Validate() error

type Subscription 

type Subscription struct {
	// Id of the user for this subscription
	UserId string `protobuf:"bytes,1,opt,name=UserId" json:"UserId,omitempty"`
	// Type of owner
	ObjectType OwnerType `protobuf:"varint,2,opt,name=ObjectType,enum=activity.OwnerType" json:"ObjectType,omitempty"`
	// If of the owner
	ObjectId string `protobuf:"bytes,3,opt,name=ObjectId" json:"ObjectId,omitempty"`
	// List of events to listen to
	Events []string `protobuf:"bytes,4,rep,name=Events" json:"Events,omitempty"`
}

func (*Subscription) Descriptor 

func (*Subscription) Descriptor() ([]byte, []int)

func (*Subscription) GetEvents 

func (m *Subscription) GetEvents() []string

func (*Subscription) GetObjectId 

func (m *Subscription) GetObjectId() string

func (*Subscription) GetObjectType 

func (m *Subscription) GetObjectType() OwnerType

func (*Subscription) GetUserId 

func (m *Subscription) GetUserId() string

func (*Subscription) MarshalLogObject added in v1.5.0 

func (s *Subscription) MarshalLogObject(encoder zapcore.ObjectEncoder) error

MarshalLogObject implements custom marshalling for logs

func (*Subscription) ProtoMessage 

func (*Subscription) ProtoMessage()

func (*Subscription) Reset 

func (m *Subscription) Reset()

func (*Subscription) String 

func (m *Subscription) String() string

func (*Subscription) Validate 

func (this *Subscription) Validate() error

func (*Subscription) Zap 

func (s *Subscription) Zap() zapcore.Field

Zap simply returns a zapcore.Field object populated with this Activity Subscription under a standard key

type SummaryPointOfView 

type SummaryPointOfView int32
const (
	SummaryPointOfView_GENERIC SummaryPointOfView = 0
	SummaryPointOfView_ACTOR   SummaryPointOfView = 1
	SummaryPointOfView_SUBJECT SummaryPointOfView = 2
)

func (SummaryPointOfView) EnumDescriptor 

func (SummaryPointOfView) EnumDescriptor() ([]byte, []int)

func (SummaryPointOfView) String 

func (x SummaryPointOfView) String() string

type UnreadActivitiesRequest 

type UnreadActivitiesRequest struct {
	// Get the number of unread activities for this user
	UserId string `protobuf:"bytes,1,opt,name=UserId" json:"UserId,omitempty"`
}

func (*UnreadActivitiesRequest) Descriptor 

func (*UnreadActivitiesRequest) Descriptor() ([]byte, []int)

func (*UnreadActivitiesRequest) GetUserId 

func (m *UnreadActivitiesRequest) GetUserId() string

func (*UnreadActivitiesRequest) ProtoMessage 

func (*UnreadActivitiesRequest) ProtoMessage()

func (*UnreadActivitiesRequest) Reset 

func (m *UnreadActivitiesRequest) Reset()

func (*UnreadActivitiesRequest) String 

func (m *UnreadActivitiesRequest) String() string

func (*UnreadActivitiesRequest) Validate 

func (this *UnreadActivitiesRequest) Validate() error

type UnreadActivitiesResponse 

type UnreadActivitiesResponse struct {
	Number int32 `protobuf:"varint,1,opt,name=number" json:"number,omitempty"`
}

func (*UnreadActivitiesResponse) Descriptor 

func (*UnreadActivitiesResponse) Descriptor() ([]byte, []int)

func (*UnreadActivitiesResponse) GetNumber 

func (m *UnreadActivitiesResponse) GetNumber() int32

func (*UnreadActivitiesResponse) ProtoMessage 

func (*UnreadActivitiesResponse) ProtoMessage()

func (*UnreadActivitiesResponse) Reset 

func (m *UnreadActivitiesResponse) Reset()

func (*UnreadActivitiesResponse) String 

func (m *UnreadActivitiesResponse) String() string

func (*UnreadActivitiesResponse) Validate 

func (this *UnreadActivitiesResponse) Validate() error

type UserLastActivityRequest 

type UserLastActivityRequest struct {
	// Current user Id
	UserId string `protobuf:"bytes,1,opt,name=UserId" json:"UserId,omitempty"`
	// Inbox or Outbox
	BoxName string `protobuf:"bytes,2,opt,name=BoxName" json:"BoxName,omitempty"`
	// Id of the last known activity
	ActivityId string `protobuf:"bytes,3,opt,name=ActivityId" json:"ActivityId,omitempty"`
}

func (*UserLastActivityRequest) Descriptor 

func (*UserLastActivityRequest) Descriptor() ([]byte, []int)

func (*UserLastActivityRequest) GetActivityId 

func (m *UserLastActivityRequest) GetActivityId() string

func (*UserLastActivityRequest) GetBoxName 

func (m *UserLastActivityRequest) GetBoxName() string

func (*UserLastActivityRequest) GetUserId 

func (m *UserLastActivityRequest) GetUserId() string

func (*UserLastActivityRequest) ProtoMessage 

func (*UserLastActivityRequest) ProtoMessage()

func (*UserLastActivityRequest) Reset 

func (m *UserLastActivityRequest) Reset()

func (*UserLastActivityRequest) String 

func (m *UserLastActivityRequest) String() string

func (*UserLastActivityRequest) Validate 

func (this *UserLastActivityRequest) Validate() error

type UserLastActivityResponse 

type UserLastActivityResponse struct {
	Success bool `protobuf:"varint,1,opt,name=Success" json:"Success,omitempty"`
}

func (*UserLastActivityResponse) Descriptor 

func (*UserLastActivityResponse) Descriptor() ([]byte, []int)

func (*UserLastActivityResponse) GetSuccess 

func (m *UserLastActivityResponse) GetSuccess() bool

func (*UserLastActivityResponse) ProtoMessage 

func (*UserLastActivityResponse) ProtoMessage()

func (*UserLastActivityResponse) Reset 

func (m *UserLastActivityResponse) Reset()

func (*UserLastActivityResponse) String 

func (m *UserLastActivityResponse) String() string

func (*UserLastActivityResponse) Validate 

func (this *UserLastActivityResponse) Validate() error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.