Versions in this module Expand all Collapse all v1 v1.6.1 Jul 9, 2019 Changes in this version + var ObjectType_name = map[int32]string + var ObjectType_value = map[string]int32 + var OwnerType_name = map[int32]string + var OwnerType_value = map[string]int32 + var StreamContext_name = map[int32]string + var StreamContext_value = map[string]int32 + var SummaryPointOfView_name = map[int32]string + var SummaryPointOfView_value = map[string]int32 + func RegisterActivityServiceHandler(s server.Server, hdlr ActivityServiceHandler, opts ...server.HandlerOption) + type ActivityService struct + func (h *ActivityService) PostActivity(ctx context.Context, stream server.Streamer) error + func (h *ActivityService) SearchSubscriptions(ctx context.Context, stream server.Streamer) error + func (h *ActivityService) SetUserLastActivity(ctx context.Context, in *UserLastActivityRequest, ...) error + func (h *ActivityService) StreamActivities(ctx context.Context, stream server.Streamer) error + func (h *ActivityService) Subscribe(ctx context.Context, in *SubscribeRequest, out *SubscribeResponse) error + func (h *ActivityService) UnreadActivitiesNumber(ctx context.Context, in *UnreadActivitiesRequest, ...) error + type ActivityServiceClient interface + PostActivity func(ctx context.Context, opts ...client.CallOption) (ActivityService_PostActivityClient, error) + SearchSubscriptions func(ctx context.Context, in *SearchSubscriptionsRequest, opts ...client.CallOption) (ActivityService_SearchSubscriptionsClient, error) + SetUserLastActivity func(ctx context.Context, in *UserLastActivityRequest, opts ...client.CallOption) (*UserLastActivityResponse, error) + StreamActivities func(ctx context.Context, in *StreamActivitiesRequest, opts ...client.CallOption) (ActivityService_StreamActivitiesClient, error) + Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...client.CallOption) (*SubscribeResponse, error) + UnreadActivitiesNumber func(ctx context.Context, in *UnreadActivitiesRequest, opts ...client.CallOption) (*UnreadActivitiesResponse, error) + func NewActivityServiceClient(serviceName string, c client.Client) ActivityServiceClient + type ActivityServiceHandler interface + PostActivity func(context.Context, ActivityService_PostActivityStream) error + SearchSubscriptions func(context.Context, *SearchSubscriptionsRequest, ...) error + SetUserLastActivity func(context.Context, *UserLastActivityRequest, *UserLastActivityResponse) error + StreamActivities func(context.Context, *StreamActivitiesRequest, ...) error + Subscribe func(context.Context, *SubscribeRequest, *SubscribeResponse) error + UnreadActivitiesNumber func(context.Context, *UnreadActivitiesRequest, *UnreadActivitiesResponse) error + type ActivityService_PostActivityClient interface + Close func() error + RecvMsg func(interface{}) error + Send func(*PostActivityRequest) error + SendMsg func(interface{}) error + type ActivityService_PostActivityStream interface + Close func() error + Recv func() (*PostActivityRequest, error) + RecvMsg func(interface{}) error + SendMsg func(interface{}) error + type ActivityService_SearchSubscriptionsClient interface + Close func() error + Recv func() (*SearchSubscriptionsResponse, error) + RecvMsg func(interface{}) error + SendMsg func(interface{}) error + type ActivityService_SearchSubscriptionsStream interface + Close func() error + RecvMsg func(interface{}) error + Send func(*SearchSubscriptionsResponse) error + SendMsg func(interface{}) error + type ActivityService_StreamActivitiesClient interface + Close func() error + Recv func() (*StreamActivitiesResponse, error) + RecvMsg func(interface{}) error + SendMsg func(interface{}) error + type ActivityService_StreamActivitiesStream interface + Close func() error + RecvMsg func(interface{}) error + Send func(*StreamActivitiesResponse) error + SendMsg func(interface{}) error + type Object struct + Accuracy float32 + Actor *Object + Altitude float32 + AnyOf *Object + Attachment *Object + AttributedTo *Object + Audience *Object + Bcc *Object + Bto *Object + Cc *Object + Closed *google_protobuf.Timestamp + Content *Object + Context *Object + Current *Object + Deleted *google_protobuf.Timestamp + Duration *google_protobuf.Timestamp + EndTime *google_protobuf.Timestamp + First *Object + FormerType ObjectType + Generator *Object + Height int32 + Href string + Hreflang string + Icon *Object + Id string + Image *Object + InReplyTo *Object + Instrument *Object + Items []*Object + JsonLdContext string + Last *Object + Latitude float32 + Location *Object + Longitude float32 + MediaType string + Name string + Next *Object + Object *Object + OneOf *Object + Origin *Object + PartOf *Object + Prev *Object + Preview *Object + Published *google_protobuf.Timestamp + Radius float32 + Rel string + Relationship *Object + Replies *Object + Result *Object + StartTime *google_protobuf.Timestamp + Subject *Object + Summary string + Tag *Object + Target *Object + To *Object + TotalItems int32 + Type ObjectType + Units string + Updated *google_protobuf.Timestamp + Url *Object + Width int32 + func (*Object) Descriptor() ([]byte, []int) + func (*Object) ProtoMessage() + func (m *Object) GetAccuracy() float32 + func (m *Object) GetActor() *Object + func (m *Object) GetAltitude() float32 + func (m *Object) GetAnyOf() *Object + func (m *Object) GetAttachment() *Object + func (m *Object) GetAttributedTo() *Object + func (m *Object) GetAudience() *Object + func (m *Object) GetBcc() *Object + func (m *Object) GetBto() *Object + func (m *Object) GetCc() *Object + func (m *Object) GetClosed() *google_protobuf.Timestamp + func (m *Object) GetContent() *Object + func (m *Object) GetContext() *Object + func (m *Object) GetCurrent() *Object + func (m *Object) GetDeleted() *google_protobuf.Timestamp + func (m *Object) GetDuration() *google_protobuf.Timestamp + func (m *Object) GetEndTime() *google_protobuf.Timestamp + func (m *Object) GetFirst() *Object + func (m *Object) GetFormerType() ObjectType + func (m *Object) GetGenerator() *Object + func (m *Object) GetHeight() int32 + func (m *Object) GetHref() string + func (m *Object) GetHreflang() string + func (m *Object) GetIcon() *Object + func (m *Object) GetId() string + func (m *Object) GetImage() *Object + func (m *Object) GetInReplyTo() *Object + func (m *Object) GetInstrument() *Object + func (m *Object) GetItems() []*Object + func (m *Object) GetJsonLdContext() string + func (m *Object) GetLast() *Object + func (m *Object) GetLatitude() float32 + func (m *Object) GetLocation() *Object + func (m *Object) GetLongitude() float32 + func (m *Object) GetMediaType() string + func (m *Object) GetName() string + func (m *Object) GetNext() *Object + func (m *Object) GetObject() *Object + func (m *Object) GetOneOf() *Object + func (m *Object) GetOrigin() *Object + func (m *Object) GetPartOf() *Object + func (m *Object) GetPrev() *Object + func (m *Object) GetPreview() *Object + func (m *Object) GetPublished() *google_protobuf.Timestamp + func (m *Object) GetRadius() float32 + func (m *Object) GetRel() string + func (m *Object) GetRelationship() *Object + func (m *Object) GetReplies() *Object + func (m *Object) GetResult() *Object + func (m *Object) GetStartTime() *google_protobuf.Timestamp + func (m *Object) GetSubject() *Object + func (m *Object) GetSummary() string + func (m *Object) GetTag() *Object + func (m *Object) GetTarget() *Object + func (m *Object) GetTo() *Object + func (m *Object) GetTotalItems() int32 + func (m *Object) GetType() ObjectType + func (m *Object) GetUnits() string + func (m *Object) GetUpdated() *google_protobuf.Timestamp + func (m *Object) GetUrl() *Object + func (m *Object) GetWidth() int32 + func (m *Object) Reset() + func (m *Object) String() string + type ObjectType int32 + const ObjectType_Accept + const ObjectType_Activity + const ObjectType_Add + const ObjectType_Announce + const ObjectType_Application + const ObjectType_Arrive + const ObjectType_Article + const ObjectType_Audio + const ObjectType_BaseObject + const ObjectType_Block + const ObjectType_Cell + const ObjectType_Collection + const ObjectType_CollectionPage + const ObjectType_Create + const ObjectType_Delete + const ObjectType_Digest + const ObjectType_Dislike + const ObjectType_Document + const ObjectType_Event + const ObjectType_Flag + const ObjectType_Folder + const ObjectType_Follow + const ObjectType_Group + const ObjectType_Ignore + const ObjectType_Image + const ObjectType_Invite + const ObjectType_Join + const ObjectType_Leave + const ObjectType_Like + const ObjectType_Link + const ObjectType_Listen + const ObjectType_Mention + const ObjectType_Move + const ObjectType_Note + const ObjectType_Offer + const ObjectType_OrderedCollection + const ObjectType_OrderedCollectionPage + const ObjectType_Organization + const ObjectType_Page + const ObjectType_Person + const ObjectType_Place + const ObjectType_Profile + const ObjectType_Question + const ObjectType_Read + const ObjectType_Reject + const ObjectType_Relationship + const ObjectType_Remove + const ObjectType_Service + const ObjectType_Share + const ObjectType_TentativeAccept + const ObjectType_TentativeReject + const ObjectType_Tombstone + const ObjectType_Travel + const ObjectType_Undo + const ObjectType_Update + const ObjectType_Video + const ObjectType_View + const ObjectType_Workspace + func (ObjectType) EnumDescriptor() ([]byte, []int) + func (x ObjectType) String() string + type OwnerType int32 + const OwnerType_NODE + const OwnerType_USER + func (OwnerType) EnumDescriptor() ([]byte, []int) + func (x OwnerType) String() string + type PostActivityEvent struct + Activity *Object + BoxName string + JsonType string + OwnerId string + OwnerType OwnerType + func (*PostActivityEvent) Descriptor() ([]byte, []int) + func (*PostActivityEvent) ProtoMessage() + func (m *PostActivityEvent) GetActivity() *Object + func (m *PostActivityEvent) GetBoxName() string + func (m *PostActivityEvent) GetJsonType() string + func (m *PostActivityEvent) GetOwnerId() string + func (m *PostActivityEvent) GetOwnerType() OwnerType + func (m *PostActivityEvent) Reset() + func (m *PostActivityEvent) String() string + func (p *PostActivityEvent) MarshalLogObject(encoder zapcore.ObjectEncoder) error + func (p *PostActivityEvent) Zap() zapcore.Field + type PostActivityRequest struct + Object *Object + func (*PostActivityRequest) Descriptor() ([]byte, []int) + func (*PostActivityRequest) ProtoMessage() + func (m *PostActivityRequest) GetObject() *Object + func (m *PostActivityRequest) Reset() + func (m *PostActivityRequest) String() string + type PostActivityResponse struct + func (*PostActivityResponse) Descriptor() ([]byte, []int) + func (*PostActivityResponse) ProtoMessage() + func (m *PostActivityResponse) Reset() + func (m *PostActivityResponse) String() string + type SearchSubscriptionsRequest struct + ObjectIds []string + ObjectTypes []OwnerType + UserIds []string + func (*SearchSubscriptionsRequest) Descriptor() ([]byte, []int) + func (*SearchSubscriptionsRequest) ProtoMessage() + func (m *SearchSubscriptionsRequest) GetObjectIds() []string + func (m *SearchSubscriptionsRequest) GetObjectTypes() []OwnerType + func (m *SearchSubscriptionsRequest) GetUserIds() []string + func (m *SearchSubscriptionsRequest) Reset() + func (m *SearchSubscriptionsRequest) String() string + type SearchSubscriptionsResponse struct + Subscription *Subscription + func (*SearchSubscriptionsResponse) Descriptor() ([]byte, []int) + func (*SearchSubscriptionsResponse) ProtoMessage() + func (m *SearchSubscriptionsResponse) GetSubscription() *Subscription + func (m *SearchSubscriptionsResponse) Reset() + func (m *SearchSubscriptionsResponse) String() string + type StreamActivitiesRequest struct + AsDigest bool + BoxName string + Context StreamContext + ContextData string + Language string + Limit int64 + Offset int64 + PointOfView SummaryPointOfView + StreamFilter string + UnreadCountOnly bool + func (*StreamActivitiesRequest) Descriptor() ([]byte, []int) + func (*StreamActivitiesRequest) ProtoMessage() + func (m *StreamActivitiesRequest) GetAsDigest() bool + func (m *StreamActivitiesRequest) GetBoxName() string + func (m *StreamActivitiesRequest) GetContext() StreamContext + func (m *StreamActivitiesRequest) GetContextData() string + func (m *StreamActivitiesRequest) GetLanguage() string + func (m *StreamActivitiesRequest) GetLimit() int64 + func (m *StreamActivitiesRequest) GetOffset() int64 + func (m *StreamActivitiesRequest) GetPointOfView() SummaryPointOfView + func (m *StreamActivitiesRequest) GetStreamFilter() string + func (m *StreamActivitiesRequest) GetUnreadCountOnly() bool + func (m *StreamActivitiesRequest) Reset() + func (m *StreamActivitiesRequest) String() string + func (s *StreamActivitiesRequest) MarshalLogObject(encoder zapcore.ObjectEncoder) error + func (s *StreamActivitiesRequest) Zap() zapcore.Field + type StreamActivitiesResponse struct + Activity *Object + func (*StreamActivitiesResponse) Descriptor() ([]byte, []int) + func (*StreamActivitiesResponse) ProtoMessage() + func (m *StreamActivitiesResponse) GetActivity() *Object + func (m *StreamActivitiesResponse) Reset() + func (m *StreamActivitiesResponse) String() string + type StreamContext int32 + const StreamContext_MYFEED + const StreamContext_NODE_ID + const StreamContext_USER_ID + func (StreamContext) EnumDescriptor() ([]byte, []int) + func (x StreamContext) String() string + type SubscribeRequest struct + Subscription *Subscription + func (*SubscribeRequest) Descriptor() ([]byte, []int) + func (*SubscribeRequest) ProtoMessage() + func (m *SubscribeRequest) GetSubscription() *Subscription + func (m *SubscribeRequest) Reset() + func (m *SubscribeRequest) String() string + type SubscribeResponse struct + Subscription *Subscription + func (*SubscribeResponse) Descriptor() ([]byte, []int) + func (*SubscribeResponse) ProtoMessage() + func (m *SubscribeResponse) GetSubscription() *Subscription + func (m *SubscribeResponse) Reset() + func (m *SubscribeResponse) String() string + type Subscription struct + Events []string + ObjectId string + ObjectType OwnerType + UserId string + func (*Subscription) Descriptor() ([]byte, []int) + func (*Subscription) ProtoMessage() + func (m *Subscription) GetEvents() []string + func (m *Subscription) GetObjectId() string + func (m *Subscription) GetObjectType() OwnerType + func (m *Subscription) GetUserId() string + func (m *Subscription) Reset() + func (m *Subscription) String() string + func (s *Subscription) MarshalLogObject(encoder zapcore.ObjectEncoder) error + func (s *Subscription) Zap() zapcore.Field + type SummaryPointOfView int32 + const SummaryPointOfView_ACTOR + const SummaryPointOfView_GENERIC + const SummaryPointOfView_SUBJECT + func (SummaryPointOfView) EnumDescriptor() ([]byte, []int) + func (x SummaryPointOfView) String() string + type UnreadActivitiesRequest struct + UserId string + func (*UnreadActivitiesRequest) Descriptor() ([]byte, []int) + func (*UnreadActivitiesRequest) ProtoMessage() + func (m *UnreadActivitiesRequest) GetUserId() string + func (m *UnreadActivitiesRequest) Reset() + func (m *UnreadActivitiesRequest) String() string + type UnreadActivitiesResponse struct + Number int32 + func (*UnreadActivitiesResponse) Descriptor() ([]byte, []int) + func (*UnreadActivitiesResponse) ProtoMessage() + func (m *UnreadActivitiesResponse) GetNumber() int32 + func (m *UnreadActivitiesResponse) Reset() + func (m *UnreadActivitiesResponse) String() string + type UserLastActivityRequest struct + ActivityId string + BoxName string + UserId string + func (*UserLastActivityRequest) Descriptor() ([]byte, []int) + func (*UserLastActivityRequest) ProtoMessage() + func (m *UserLastActivityRequest) GetActivityId() string + func (m *UserLastActivityRequest) GetBoxName() string + func (m *UserLastActivityRequest) GetUserId() string + func (m *UserLastActivityRequest) Reset() + func (m *UserLastActivityRequest) String() string + type UserLastActivityResponse struct + Success bool + func (*UserLastActivityResponse) Descriptor() ([]byte, []int) + func (*UserLastActivityResponse) ProtoMessage() + func (m *UserLastActivityResponse) GetSuccess() bool + func (m *UserLastActivityResponse) Reset() + func (m *UserLastActivityResponse) String() string Incompatible versions in this module v2.0.6+incompatible Apr 23, 2020
Go to main page