activity

package
v4.4.0-rc2 Latest Latest
Warning

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

 Go to latest Published: Mar 25, 2024 License: AGPL-3.0 Imports: 17 Imported by: 0

Documentation

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",
	}
	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,
	}
)

Enum value maps for ObjectType.

View Source 
var (
	StreamContext_name = map[int32]string{
		0: "MYFEED",
		1: "USER_ID",
		2: "NODE_ID",
	}
	StreamContext_value = map[string]int32{
		"MYFEED":  0,
		"USER_ID": 1,
		"NODE_ID": 2,
	}
)

Enum value maps for StreamContext.

View Source 
var (
	SummaryPointOfView_name = map[int32]string{
		0: "GENERIC",
		1: "ACTOR",
		2: "SUBJECT",
	}
	SummaryPointOfView_value = map[string]int32{
		"GENERIC": 0,
		"ACTOR":   1,
		"SUBJECT": 2,
	}
)

Enum value maps for SummaryPointOfView.

View Source 
var (
	OwnerType_name = map[int32]string{
		0: "NODE",
		1: "USER",
	}
	OwnerType_value = map[string]int32{
		"NODE": 0,
		"USER": 1,
	}
)

Enum value maps for OwnerType.

View Source 
var ActivityService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "activity.ActivityService",
	HandlerType: (*ActivityServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "UnreadActivitiesNumber",
			Handler:    _ActivityService_UnreadActivitiesNumber_Handler,
		},
		{
			MethodName: "PurgeActivities",
			Handler:    _ActivityService_PurgeActivities_Handler,
		},
		{
			MethodName: "SetUserLastActivity",
			Handler:    _ActivityService_SetUserLastActivity_Handler,
		},
		{
			MethodName: "Subscribe",
			Handler:    _ActivityService_Subscribe_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "PostActivity",
			Handler:       _ActivityService_PostActivity_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "StreamActivities",
			Handler:       _ActivityService_StreamActivities_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SearchSubscriptions",
			Handler:       _ActivityService_SearchSubscriptions_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "cells-activitystream.proto",
}

ActivityService_ServiceDesc is the grpc.ServiceDesc for ActivityService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_cells_activitystream_proto protoreflect.FileDescriptor

Functions

func DeregisterActivityServiceEnhancedServer 

func DeregisterActivityServiceEnhancedServer(s grpc.ServiceRegistrar, name string)

func RegisterActivityServiceEnhancedServer 

func RegisterActivityServiceEnhancedServer(s grpc.ServiceRegistrar, srv NamedActivityServiceServer)

func RegisterActivityServiceServer 

func RegisterActivityServiceServer(s grpc.ServiceRegistrar, srv ActivityServiceServer)

Types

type ActivityServiceClient 

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

ActivityServiceClient is the client API for ActivityService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewActivityServiceClient 

func NewActivityServiceClient(cc grpc.ClientConnInterface) ActivityServiceClient

type ActivityServiceEnhancedServer 

type ActivityServiceEnhancedServer map[string]NamedActivityServiceServer

func (ActivityServiceEnhancedServer) PostActivity 

func (m ActivityServiceEnhancedServer) PostActivity(s ActivityService_PostActivityServer) error

func (ActivityServiceEnhancedServer) PurgeActivities 

func (m ActivityServiceEnhancedServer) PurgeActivities(ctx context.Context, r *PurgeActivitiesRequest) (*PurgeActivitiesResponse, error)

func (ActivityServiceEnhancedServer) SearchSubscriptions 

func (m ActivityServiceEnhancedServer) SearchSubscriptions(r *SearchSubscriptionsRequest, s ActivityService_SearchSubscriptionsServer) error

func (ActivityServiceEnhancedServer) SetUserLastActivity 

func (m ActivityServiceEnhancedServer) SetUserLastActivity(ctx context.Context, r *UserLastActivityRequest) (*UserLastActivityResponse, error)

func (ActivityServiceEnhancedServer) StreamActivities 

func (m ActivityServiceEnhancedServer) StreamActivities(r *StreamActivitiesRequest, s ActivityService_StreamActivitiesServer) error

func (ActivityServiceEnhancedServer) Subscribe 

func (m ActivityServiceEnhancedServer) Subscribe(ctx context.Context, r *SubscribeRequest) (*SubscribeResponse, error)

func (ActivityServiceEnhancedServer) UnreadActivitiesNumber 

func (m ActivityServiceEnhancedServer) UnreadActivitiesNumber(ctx context.Context, r *UnreadActivitiesRequest) (*UnreadActivitiesResponse, error)

type ActivityServiceServer 

type ActivityServiceServer interface {
	PostActivity(ActivityService_PostActivityServer) error
	StreamActivities(*StreamActivitiesRequest, ActivityService_StreamActivitiesServer) 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(*SearchSubscriptionsRequest, ActivityService_SearchSubscriptionsServer) error
	// contains filtered or unexported methods
}

ActivityServiceServer is the server API for ActivityService service. All implementations must embed UnimplementedActivityServiceServer for forward compatibility

type ActivityService_PostActivityClient 

type ActivityService_PostActivityClient interface {
	Send(*PostActivityRequest) error
	CloseAndRecv() (*PostActivityResponse, error)
	grpc.ClientStream
}

type ActivityService_PostActivityServer 

type ActivityService_PostActivityServer interface {
	SendAndClose(*PostActivityResponse) error
	Recv() (*PostActivityRequest, error)
	grpc.ServerStream
}

type ActivityService_SearchSubscriptionsClient 

type ActivityService_SearchSubscriptionsClient interface {
	Recv() (*SearchSubscriptionsResponse, error)
	grpc.ClientStream
}

type ActivityService_SearchSubscriptionsServer 

type ActivityService_SearchSubscriptionsServer interface {
	Send(*SearchSubscriptionsResponse) error
	grpc.ServerStream
}

type ActivityService_StreamActivitiesClient 

type ActivityService_StreamActivitiesClient interface {
	Recv() (*StreamActivitiesResponse, error)
	grpc.ClientStream
}

type ActivityService_StreamActivitiesServer 

type ActivityService_StreamActivitiesServer interface {
	Send(*StreamActivitiesResponse) error
	grpc.ServerStream
}

type NamedActivityServiceServer 

type NamedActivityServiceServer interface {
	ActivityServiceServer
	Name() string
}

type Object 

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

func (*Object) Descriptor deprecated 

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

Deprecated: Use Object.ProtoReflect.Descriptor instead.

func (*Object) GetAccuracy 

func (x *Object) GetAccuracy() float32

func (*Object) GetActor 

func (x *Object) GetActor() *Object

func (*Object) GetAltitude 

func (x *Object) GetAltitude() float32

func (*Object) GetAnyOf 

func (x *Object) GetAnyOf() *Object

func (*Object) GetAttachment 

func (x *Object) GetAttachment() *Object

func (*Object) GetAttributedTo 

func (x *Object) GetAttributedTo() *Object

func (*Object) GetAudience 

func (x *Object) GetAudience() *Object

func (*Object) GetBcc 

func (x *Object) GetBcc() *Object

func (*Object) GetBto 

func (x *Object) GetBto() *Object

func (*Object) GetCc 

func (x *Object) GetCc() *Object

func (*Object) GetClosed 

func (x *Object) GetClosed() *timestamppb.Timestamp

func (*Object) GetContent 

func (x *Object) GetContent() *Object

func (*Object) GetContext 

func (x *Object) GetContext() *Object

func (*Object) GetCurrent 

func (x *Object) GetCurrent() *Object

func (*Object) GetDeleted 

func (x *Object) GetDeleted() *timestamppb.Timestamp

func (*Object) GetDuration 

func (x *Object) GetDuration() *timestamppb.Timestamp

func (*Object) GetEndTime 

func (x *Object) GetEndTime() *timestamppb.Timestamp

func (*Object) GetFirst 

func (x *Object) GetFirst() *Object

func (*Object) GetFormerType 

func (x *Object) GetFormerType() ObjectType

func (*Object) GetGenerator 

func (x *Object) GetGenerator() *Object

func (*Object) GetHeight 

func (x *Object) GetHeight() int32

func (*Object) GetHref 

func (x *Object) GetHref() string

func (*Object) GetHreflang 

func (x *Object) GetHreflang() string

func (*Object) GetIcon 

func (x *Object) GetIcon() *Object

func (*Object) GetId 

func (x *Object) GetId() string

func (*Object) GetImage 

func (x *Object) GetImage() *Object

func (*Object) GetInReplyTo 

func (x *Object) GetInReplyTo() *Object

func (*Object) GetInstrument 

func (x *Object) GetInstrument() *Object

func (*Object) GetItems 

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

func (*Object) GetJsonLdContext 

func (x *Object) GetJsonLdContext() string

func (*Object) GetLast 

func (x *Object) GetLast() *Object

func (*Object) GetLatitude 

func (x *Object) GetLatitude() float32

func (*Object) GetLocation 

func (x *Object) GetLocation() *Object

func (*Object) GetLongitude 

func (x *Object) GetLongitude() float32

func (*Object) GetMarkdown 

func (x *Object) GetMarkdown() string

func (*Object) GetMediaType 

func (x *Object) GetMediaType() string

func (*Object) GetName 

func (x *Object) GetName() string

func (*Object) GetNext 

func (x *Object) GetNext() *Object

func (*Object) GetObject 

func (x *Object) GetObject() *Object

func (*Object) GetOneOf 

func (x *Object) GetOneOf() *Object

func (*Object) GetOrigin 

func (x *Object) GetOrigin() *Object

func (*Object) GetPartOf 

func (x *Object) GetPartOf() *Object

func (*Object) GetPrev 

func (x *Object) GetPrev() *Object

func (*Object) GetPreview 

func (x *Object) GetPreview() *Object

func (*Object) GetPublished 

func (x *Object) GetPublished() *timestamppb.Timestamp

func (*Object) GetRadius 

func (x *Object) GetRadius() float32

func (*Object) GetRel 

func (x *Object) GetRel() string

func (*Object) GetRelationship 

func (x *Object) GetRelationship() *Object

func (*Object) GetReplies 

func (x *Object) GetReplies() *Object

func (*Object) GetResult 

func (x *Object) GetResult() *Object

func (*Object) GetStartTime 

func (x *Object) GetStartTime() *timestamppb.Timestamp

func (*Object) GetSubject 

func (x *Object) GetSubject() *Object

func (*Object) GetSummary 

func (x *Object) GetSummary() string

func (*Object) GetTag 

func (x *Object) GetTag() *Object

func (*Object) GetTarget 

func (x *Object) GetTarget() *Object

func (*Object) GetTo 

func (x *Object) GetTo() *Object

func (*Object) GetTotalItems 

func (x *Object) GetTotalItems() int32

func (*Object) GetType 

func (x *Object) GetType() ObjectType

func (*Object) GetUnits 

func (x *Object) GetUnits() string

func (*Object) GetUpdated 

func (x *Object) GetUpdated() *timestamppb.Timestamp

func (*Object) GetUrl 

func (x *Object) GetUrl() *Object

func (*Object) GetWidth 

func (x *Object) GetWidth() int32

func (*Object) ProtoMessage 

func (*Object) ProtoMessage()

func (*Object) ProtoReflect 

func (x *Object) ProtoReflect() protoreflect.Message

func (*Object) Reset 

func (x *Object) Reset()

func (*Object) String 

func (x *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) Descriptor 

func (ObjectType) Descriptor() protoreflect.EnumDescriptor

func (ObjectType) Enum 

func (x ObjectType) Enum() *ObjectType

func (ObjectType) EnumDescriptor deprecated 

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

Deprecated: Use ObjectType.Descriptor instead.

func (ObjectType) Number 

func (x ObjectType) Number() protoreflect.EnumNumber

func (ObjectType) String 

func (x ObjectType) String() string

func (ObjectType) Type 

func (ObjectType) Type() protoreflect.EnumType

type OwnerType 

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

func (OwnerType) Descriptor 

func (OwnerType) Descriptor() protoreflect.EnumDescriptor

func (OwnerType) Enum 

func (x OwnerType) Enum() *OwnerType

func (OwnerType) EnumDescriptor deprecated 

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

Deprecated: Use OwnerType.Descriptor instead.

func (OwnerType) Number 

func (x OwnerType) Number() protoreflect.EnumNumber

func (OwnerType) String 

func (x OwnerType) String() string

func (OwnerType) Type 

func (OwnerType) Type() protoreflect.EnumType

type PostActivityEvent 

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

func (*PostActivityEvent) Descriptor deprecated 

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

Deprecated: Use PostActivityEvent.ProtoReflect.Descriptor instead.

func (*PostActivityEvent) GetActivity 

func (x *PostActivityEvent) GetActivity() *Object

func (*PostActivityEvent) GetBoxName 

func (x *PostActivityEvent) GetBoxName() string

func (*PostActivityEvent) GetJsonType 

func (x *PostActivityEvent) GetJsonType() string

func (*PostActivityEvent) GetOwnerId 

func (x *PostActivityEvent) GetOwnerId() string

func (*PostActivityEvent) GetOwnerType 

func (x *PostActivityEvent) GetOwnerType() OwnerType

func (*PostActivityEvent) MarshalLogObject 

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

MarshalLogObject implements custom marshalling for logs

func (*PostActivityEvent) ProtoMessage 

func (*PostActivityEvent) ProtoMessage()

func (*PostActivityEvent) ProtoReflect 

func (x *PostActivityEvent) ProtoReflect() protoreflect.Message

func (*PostActivityEvent) Reset 

func (x *PostActivityEvent) Reset()

func (*PostActivityEvent) String 

func (x *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 {
	OwnerType OwnerType `protobuf:"varint,1,opt,name=OwnerType,proto3,enum=activity.OwnerType" json:"OwnerType,omitempty"`
	OwnerId   string    `protobuf:"bytes,2,opt,name=OwnerId,proto3" json:"OwnerId,omitempty"`
	BoxName   string    `protobuf:"bytes,3,opt,name=BoxName,proto3" json:"BoxName,omitempty"`
	Activity  *Object   `protobuf:"bytes,4,opt,name=Activity,proto3" json:"Activity,omitempty"`
	// contains filtered or unexported fields
}

func (*PostActivityRequest) Descriptor deprecated 

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

Deprecated: Use PostActivityRequest.ProtoReflect.Descriptor instead.

func (*PostActivityRequest) GetActivity 

func (x *PostActivityRequest) GetActivity() *Object

func (*PostActivityRequest) GetBoxName 

func (x *PostActivityRequest) GetBoxName() string

func (*PostActivityRequest) GetOwnerId 

func (x *PostActivityRequest) GetOwnerId() string

func (*PostActivityRequest) GetOwnerType 

func (x *PostActivityRequest) GetOwnerType() OwnerType

func (*PostActivityRequest) ProtoMessage 

func (*PostActivityRequest) ProtoMessage()

func (*PostActivityRequest) ProtoReflect 

func (x *PostActivityRequest) ProtoReflect() protoreflect.Message

func (*PostActivityRequest) Reset 

func (x *PostActivityRequest) Reset()

func (*PostActivityRequest) String 

func (x *PostActivityRequest) String() string

func (*PostActivityRequest) Validate 

func (this *PostActivityRequest) Validate() error

type PostActivityResponse 

type PostActivityResponse struct {
	Success bool `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
	// contains filtered or unexported fields
}

func (*PostActivityResponse) Descriptor deprecated 

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

Deprecated: Use PostActivityResponse.ProtoReflect.Descriptor instead.

func (*PostActivityResponse) GetSuccess 

func (x *PostActivityResponse) GetSuccess() bool

func (*PostActivityResponse) ProtoMessage 

func (*PostActivityResponse) ProtoMessage()

func (*PostActivityResponse) ProtoReflect 

func (x *PostActivityResponse) ProtoReflect() protoreflect.Message

func (*PostActivityResponse) Reset 

func (x *PostActivityResponse) Reset()

func (*PostActivityResponse) String 

func (x *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,proto3,enum=activity.OwnerType" json:"OwnerType,omitempty"`
	// Object Id, use * to browse all
	OwnerID string `protobuf:"bytes,2,opt,name=OwnerID,proto3" json:"OwnerID,omitempty"`
	// Box Name
	BoxName string `protobuf:"bytes,3,opt,name=BoxName,proto3" json:"BoxName,omitempty"`
	// Keep at least this number of records
	MinCount int32 `protobuf:"varint,4,opt,name=minCount,proto3" json:"minCount,omitempty"`
	// Keep max number of records
	MaxCount int32 `protobuf:"varint,5,opt,name=maxCount,proto3" json:"maxCount,omitempty"`
	// Remove records updated before...
	UpdatedBeforeTimestamp int32 `protobuf:"varint,6,opt,name=updatedBeforeTimestamp,proto3" json:"updatedBeforeTimestamp,omitempty"`
	// Trigger DB compaction after purge
	CompactDB bool `protobuf:"varint,8,opt,name=CompactDB,proto3" json:"CompactDB,omitempty"`
	// Clear original DB after compaction
	ClearBackups bool `protobuf:"varint,7,opt,name=ClearBackups,proto3" json:"ClearBackups,omitempty"`
	// contains filtered or unexported fields
}

func (*PurgeActivitiesRequest) Descriptor deprecated 

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

Deprecated: Use PurgeActivitiesRequest.ProtoReflect.Descriptor instead.

func (*PurgeActivitiesRequest) GetBoxName 

func (x *PurgeActivitiesRequest) GetBoxName() string

func (*PurgeActivitiesRequest) GetClearBackups 

func (x *PurgeActivitiesRequest) GetClearBackups() bool

func (*PurgeActivitiesRequest) GetCompactDB 

func (x *PurgeActivitiesRequest) GetCompactDB() bool

func (*PurgeActivitiesRequest) GetMaxCount 

func (x *PurgeActivitiesRequest) GetMaxCount() int32

func (*PurgeActivitiesRequest) GetMinCount 

func (x *PurgeActivitiesRequest) GetMinCount() int32

func (*PurgeActivitiesRequest) GetOwnerID 

func (x *PurgeActivitiesRequest) GetOwnerID() string

func (*PurgeActivitiesRequest) GetOwnerType 

func (x *PurgeActivitiesRequest) GetOwnerType() OwnerType

func (*PurgeActivitiesRequest) GetUpdatedBeforeTimestamp 

func (x *PurgeActivitiesRequest) GetUpdatedBeforeTimestamp() int32

func (*PurgeActivitiesRequest) ProtoMessage 

func (*PurgeActivitiesRequest) ProtoMessage()

func (*PurgeActivitiesRequest) ProtoReflect 

func (x *PurgeActivitiesRequest) ProtoReflect() protoreflect.Message

func (*PurgeActivitiesRequest) Reset 

func (x *PurgeActivitiesRequest) Reset()

func (*PurgeActivitiesRequest) String 

func (x *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,proto3" json:"Success,omitempty"`
	// Number of rows deleted
	DeletedCount int32 `protobuf:"varint,2,opt,name=DeletedCount,proto3" json:"DeletedCount,omitempty"`
	// contains filtered or unexported fields
}

func (*PurgeActivitiesResponse) Descriptor deprecated 

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

Deprecated: Use PurgeActivitiesResponse.ProtoReflect.Descriptor instead.

func (*PurgeActivitiesResponse) GetDeletedCount 

func (x *PurgeActivitiesResponse) GetDeletedCount() int32

func (*PurgeActivitiesResponse) GetSuccess 

func (x *PurgeActivitiesResponse) GetSuccess() bool

func (*PurgeActivitiesResponse) ProtoMessage 

func (*PurgeActivitiesResponse) ProtoMessage()

func (*PurgeActivitiesResponse) ProtoReflect 

func (x *PurgeActivitiesResponse) ProtoReflect() protoreflect.Message

func (*PurgeActivitiesResponse) Reset 

func (x *PurgeActivitiesResponse) Reset()

func (*PurgeActivitiesResponse) String 

func (x *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,proto3" json:"UserIds,omitempty"`
	// Filter by type of objects
	ObjectTypes []OwnerType `protobuf:"varint,2,rep,packed,name=ObjectTypes,proto3,enum=activity.OwnerType" json:"ObjectTypes,omitempty"`
	// Filter by object Ids
	ObjectIds []string `protobuf:"bytes,3,rep,name=ObjectIds,proto3" json:"ObjectIds,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchSubscriptionsRequest) Descriptor deprecated 

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

Deprecated: Use SearchSubscriptionsRequest.ProtoReflect.Descriptor instead.

func (*SearchSubscriptionsRequest) GetObjectIds 

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

func (*SearchSubscriptionsRequest) GetObjectTypes 

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

func (*SearchSubscriptionsRequest) GetUserIds 

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

func (*SearchSubscriptionsRequest) ProtoMessage 

func (*SearchSubscriptionsRequest) ProtoMessage()

func (*SearchSubscriptionsRequest) ProtoReflect 

func (x *SearchSubscriptionsRequest) ProtoReflect() protoreflect.Message

func (*SearchSubscriptionsRequest) Reset 

func (x *SearchSubscriptionsRequest) Reset()

func (*SearchSubscriptionsRequest) String 

func (x *SearchSubscriptionsRequest) String() string

func (*SearchSubscriptionsRequest) Validate 

func (this *SearchSubscriptionsRequest) Validate() error

type SearchSubscriptionsResponse 

type SearchSubscriptionsResponse struct {
	Subscription *Subscription `protobuf:"bytes,1,opt,name=Subscription,proto3" json:"Subscription,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchSubscriptionsResponse) Descriptor deprecated 

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

Deprecated: Use SearchSubscriptionsResponse.ProtoReflect.Descriptor instead.

func (*SearchSubscriptionsResponse) GetSubscription 

func (x *SearchSubscriptionsResponse) GetSubscription() *Subscription

func (*SearchSubscriptionsResponse) ProtoMessage 

func (*SearchSubscriptionsResponse) ProtoMessage()

func (*SearchSubscriptionsResponse) ProtoReflect 

func (x *SearchSubscriptionsResponse) ProtoReflect() protoreflect.Message

func (*SearchSubscriptionsResponse) Reset 

func (x *SearchSubscriptionsResponse) Reset()

func (*SearchSubscriptionsResponse) String 

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

func (*StreamActivitiesRequest) Descriptor deprecated 

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

Deprecated: Use StreamActivitiesRequest.ProtoReflect.Descriptor instead.

func (*StreamActivitiesRequest) GetAsDigest 

func (x *StreamActivitiesRequest) GetAsDigest() bool

func (*StreamActivitiesRequest) GetBoxName 

func (x *StreamActivitiesRequest) GetBoxName() string

func (*StreamActivitiesRequest) GetContext 

func (x *StreamActivitiesRequest) GetContext() StreamContext

func (*StreamActivitiesRequest) GetContextData 

func (x *StreamActivitiesRequest) GetContextData() string

func (*StreamActivitiesRequest) GetLanguage 

func (x *StreamActivitiesRequest) GetLanguage() string

func (*StreamActivitiesRequest) GetLimit 

func (x *StreamActivitiesRequest) GetLimit() int64

func (*StreamActivitiesRequest) GetOffset 

func (x *StreamActivitiesRequest) GetOffset() int64

func (*StreamActivitiesRequest) GetPointOfView 

func (x *StreamActivitiesRequest) GetPointOfView() SummaryPointOfView

func (*StreamActivitiesRequest) GetStreamFilter 

func (x *StreamActivitiesRequest) GetStreamFilter() string

func (*StreamActivitiesRequest) GetUnreadCountOnly 

func (x *StreamActivitiesRequest) GetUnreadCountOnly() bool

func (*StreamActivitiesRequest) MarshalLogObject 

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

MarshalLogObject implements custom marshalling for logs

func (*StreamActivitiesRequest) ProtoMessage 

func (*StreamActivitiesRequest) ProtoMessage()

func (*StreamActivitiesRequest) ProtoReflect 

func (x *StreamActivitiesRequest) ProtoReflect() protoreflect.Message

func (*StreamActivitiesRequest) Reset 

func (x *StreamActivitiesRequest) Reset()

func (*StreamActivitiesRequest) String 

func (x *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,proto3" json:"activity,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamActivitiesResponse) Descriptor deprecated 

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

Deprecated: Use StreamActivitiesResponse.ProtoReflect.Descriptor instead.

func (*StreamActivitiesResponse) GetActivity 

func (x *StreamActivitiesResponse) GetActivity() *Object

func (*StreamActivitiesResponse) ProtoMessage 

func (*StreamActivitiesResponse) ProtoMessage()

func (*StreamActivitiesResponse) ProtoReflect 

func (x *StreamActivitiesResponse) ProtoReflect() protoreflect.Message

func (*StreamActivitiesResponse) Reset 

func (x *StreamActivitiesResponse) Reset()

func (*StreamActivitiesResponse) String 

func (x *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) Descriptor 

func (StreamContext) Descriptor() protoreflect.EnumDescriptor

func (StreamContext) Enum 

func (x StreamContext) Enum() *StreamContext

func (StreamContext) EnumDescriptor deprecated 

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

Deprecated: Use StreamContext.Descriptor instead.

func (StreamContext) Number 

func (x StreamContext) Number() protoreflect.EnumNumber

func (StreamContext) String 

func (x StreamContext) String() string

func (StreamContext) Type 

func (StreamContext) Type() protoreflect.EnumType

type SubscribeRequest 

type SubscribeRequest struct {

	// Place a new subscription
	Subscription *Subscription `protobuf:"bytes,1,opt,name=Subscription,proto3" json:"Subscription,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.

func (*SubscribeRequest) GetSubscription 

func (x *SubscribeRequest) GetSubscription() *Subscription

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoReflect 

func (x *SubscribeRequest) ProtoReflect() protoreflect.Message

func (*SubscribeRequest) Reset 

func (x *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (x *SubscribeRequest) String() string

func (*SubscribeRequest) Validate 

func (this *SubscribeRequest) Validate() error

type SubscribeResponse 

type SubscribeResponse struct {
	Subscription *Subscription `protobuf:"bytes,1,opt,name=Subscription,proto3" json:"Subscription,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeResponse) Descriptor deprecated 

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

Deprecated: Use SubscribeResponse.ProtoReflect.Descriptor instead.

func (*SubscribeResponse) GetSubscription 

func (x *SubscribeResponse) GetSubscription() *Subscription

func (*SubscribeResponse) ProtoMessage 

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) ProtoReflect 

func (x *SubscribeResponse) ProtoReflect() protoreflect.Message

func (*SubscribeResponse) Reset 

func (x *SubscribeResponse) Reset()

func (*SubscribeResponse) String 

func (x *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,proto3" json:"UserId,omitempty"`
	// Type of owner
	ObjectType OwnerType `protobuf:"varint,2,opt,name=ObjectType,proto3,enum=activity.OwnerType" json:"ObjectType,omitempty"`
	// If of the owner
	ObjectId string `protobuf:"bytes,3,opt,name=ObjectId,proto3" json:"ObjectId,omitempty"`
	// List of events to listen to
	Events []string `protobuf:"bytes,4,rep,name=Events,proto3" json:"Events,omitempty"`
	// contains filtered or unexported fields
}

func (*Subscription) Descriptor deprecated 

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

Deprecated: Use Subscription.ProtoReflect.Descriptor instead.

func (*Subscription) GetEvents 

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

func (*Subscription) GetObjectId 

func (x *Subscription) GetObjectId() string

func (*Subscription) GetObjectType 

func (x *Subscription) GetObjectType() OwnerType

func (*Subscription) GetUserId 

func (x *Subscription) GetUserId() string

func (*Subscription) MarshalLogObject 

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

MarshalLogObject implements custom marshalling for logs

func (*Subscription) ProtoMessage 

func (*Subscription) ProtoMessage()

func (*Subscription) ProtoReflect 

func (x *Subscription) ProtoReflect() protoreflect.Message

func (*Subscription) Reset 

func (x *Subscription) Reset()

func (*Subscription) String 

func (x *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) Descriptor 

func (SummaryPointOfView) Descriptor() protoreflect.EnumDescriptor

func (SummaryPointOfView) Enum 

func (x SummaryPointOfView) Enum() *SummaryPointOfView

func (SummaryPointOfView) EnumDescriptor deprecated 

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

Deprecated: Use SummaryPointOfView.Descriptor instead.

func (SummaryPointOfView) Number 

func (x SummaryPointOfView) Number() protoreflect.EnumNumber

func (SummaryPointOfView) String 

func (x SummaryPointOfView) String() string

func (SummaryPointOfView) Type 

func (SummaryPointOfView) Type() protoreflect.EnumType

type UnimplementedActivityServiceServer 

type UnimplementedActivityServiceServer struct {
}

UnimplementedActivityServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedActivityServiceServer) PostActivity 

func (UnimplementedActivityServiceServer) PostActivity(ActivityService_PostActivityServer) error

func (UnimplementedActivityServiceServer) PurgeActivities 

func (UnimplementedActivityServiceServer) PurgeActivities(context.Context, *PurgeActivitiesRequest) (*PurgeActivitiesResponse, error)

func (UnimplementedActivityServiceServer) SearchSubscriptions 

func (UnimplementedActivityServiceServer) SearchSubscriptions(*SearchSubscriptionsRequest, ActivityService_SearchSubscriptionsServer) error

func (UnimplementedActivityServiceServer) SetUserLastActivity 

func (UnimplementedActivityServiceServer) SetUserLastActivity(context.Context, *UserLastActivityRequest) (*UserLastActivityResponse, error)

func (UnimplementedActivityServiceServer) StreamActivities 

func (UnimplementedActivityServiceServer) StreamActivities(*StreamActivitiesRequest, ActivityService_StreamActivitiesServer) error

func (UnimplementedActivityServiceServer) Subscribe 

func (UnimplementedActivityServiceServer) Subscribe(context.Context, *SubscribeRequest) (*SubscribeResponse, error)

func (UnimplementedActivityServiceServer) UnreadActivitiesNumber 

func (UnimplementedActivityServiceServer) UnreadActivitiesNumber(context.Context, *UnreadActivitiesRequest) (*UnreadActivitiesResponse, error)

type UnreadActivitiesRequest 

type UnreadActivitiesRequest struct {

	// Get the number of unread activities for this user
	UserId string `protobuf:"bytes,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	// contains filtered or unexported fields
}

func (*UnreadActivitiesRequest) Descriptor deprecated 

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

Deprecated: Use UnreadActivitiesRequest.ProtoReflect.Descriptor instead.

func (*UnreadActivitiesRequest) GetUserId 

func (x *UnreadActivitiesRequest) GetUserId() string

func (*UnreadActivitiesRequest) ProtoMessage 

func (*UnreadActivitiesRequest) ProtoMessage()

func (*UnreadActivitiesRequest) ProtoReflect 

func (x *UnreadActivitiesRequest) ProtoReflect() protoreflect.Message

func (*UnreadActivitiesRequest) Reset 

func (x *UnreadActivitiesRequest) Reset()

func (*UnreadActivitiesRequest) String 

func (x *UnreadActivitiesRequest) String() string

func (*UnreadActivitiesRequest) Validate 

func (this *UnreadActivitiesRequest) Validate() error

type UnreadActivitiesResponse 

type UnreadActivitiesResponse struct {
	Number int32 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
	// contains filtered or unexported fields
}

func (*UnreadActivitiesResponse) Descriptor deprecated 

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

Deprecated: Use UnreadActivitiesResponse.ProtoReflect.Descriptor instead.

func (*UnreadActivitiesResponse) GetNumber 

func (x *UnreadActivitiesResponse) GetNumber() int32

func (*UnreadActivitiesResponse) ProtoMessage 

func (*UnreadActivitiesResponse) ProtoMessage()

func (*UnreadActivitiesResponse) ProtoReflect 

func (x *UnreadActivitiesResponse) ProtoReflect() protoreflect.Message

func (*UnreadActivitiesResponse) Reset 

func (x *UnreadActivitiesResponse) Reset()

func (*UnreadActivitiesResponse) String 

func (x *UnreadActivitiesResponse) String() string

func (*UnreadActivitiesResponse) Validate 

func (this *UnreadActivitiesResponse) Validate() error

type UnsafeActivityServiceServer 

type UnsafeActivityServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeActivityServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ActivityServiceServer will result in compilation errors.

type UserLastActivityRequest 

type UserLastActivityRequest struct {

	// Current user Id
	UserId string `protobuf:"bytes,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	// Inbox or Outbox
	BoxName string `protobuf:"bytes,2,opt,name=BoxName,proto3" json:"BoxName,omitempty"`
	// Id of the last known activity
	ActivityId string `protobuf:"bytes,3,opt,name=ActivityId,proto3" json:"ActivityId,omitempty"`
	// contains filtered or unexported fields
}

func (*UserLastActivityRequest) Descriptor deprecated 

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

Deprecated: Use UserLastActivityRequest.ProtoReflect.Descriptor instead.

func (*UserLastActivityRequest) GetActivityId 

func (x *UserLastActivityRequest) GetActivityId() string

func (*UserLastActivityRequest) GetBoxName 

func (x *UserLastActivityRequest) GetBoxName() string

func (*UserLastActivityRequest) GetUserId 

func (x *UserLastActivityRequest) GetUserId() string

func (*UserLastActivityRequest) ProtoMessage 

func (*UserLastActivityRequest) ProtoMessage()

func (*UserLastActivityRequest) ProtoReflect 

func (x *UserLastActivityRequest) ProtoReflect() protoreflect.Message

func (*UserLastActivityRequest) Reset 

func (x *UserLastActivityRequest) Reset()

func (*UserLastActivityRequest) String 

func (x *UserLastActivityRequest) String() string

func (*UserLastActivityRequest) Validate 

func (this *UserLastActivityRequest) Validate() error

type UserLastActivityResponse 

type UserLastActivityResponse struct {
	Success bool `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
	// contains filtered or unexported fields
}

func (*UserLastActivityResponse) Descriptor deprecated 

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

Deprecated: Use UserLastActivityResponse.ProtoReflect.Descriptor instead.

func (*UserLastActivityResponse) GetSuccess 

func (x *UserLastActivityResponse) GetSuccess() bool

func (*UserLastActivityResponse) ProtoMessage 

func (*UserLastActivityResponse) ProtoMessage()

func (*UserLastActivityResponse) ProtoReflect 

func (x *UserLastActivityResponse) ProtoReflect() protoreflect.Message

func (*UserLastActivityResponse) Reset 

func (x *UserLastActivityResponse) Reset()

func (*UserLastActivityResponse) String 

func (x *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.