Documentation ¶
Overview ¶
Package activity is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Package activity is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Package activity is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Package activity is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- func RegisterActivityHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterActivityHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ActivityClient) error
- func RegisterActivityHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterActivityHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ActivityServer) error
- func RegisterActivityServer(s grpc.ServiceRegistrar, srv ActivityServer)
- func RegisterFriendshipHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterFriendshipHandlerClient(ctx context.Context, mux *runtime.ServeMux, client FriendshipClient) error
- func RegisterFriendshipHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterFriendshipHandlerServer(ctx context.Context, mux *runtime.ServeMux, server FriendshipServer) error
- func RegisterFriendshipServer(s grpc.ServiceRegistrar, srv FriendshipServer)
- func RegisterInboxHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterInboxHandlerClient(ctx context.Context, mux *runtime.ServeMux, client InboxClient) error
- func RegisterInboxHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterInboxHandlerServer(ctx context.Context, mux *runtime.ServeMux, server InboxServer) error
- func RegisterInboxServer(s grpc.ServiceRegistrar, srv InboxServer)
- func RegisterOutboxHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterOutboxHandlerClient(ctx context.Context, mux *runtime.ServeMux, client OutboxClient) error
- func RegisterOutboxHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterOutboxHandlerServer(ctx context.Context, mux *runtime.ServeMux, server OutboxServer) error
- func RegisterOutboxServer(s grpc.ServiceRegistrar, srv OutboxServer)
- type ActivityClient
- type ActivityRequest
- func (*ActivityRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ActivityRequest) GetBody() string
- func (x *ActivityRequest) GetTO() string
- func (x *ActivityRequest) GetType() string
- func (*ActivityRequest) ProtoMessage()
- func (x *ActivityRequest) ProtoReflect() protoreflect.Message
- func (x *ActivityRequest) Reset()
- func (x *ActivityRequest) String() string
- type ActivityResponse
- func (*ActivityResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ActivityResponse) GetCode() string
- func (x *ActivityResponse) GetFailures() []string
- func (x *ActivityResponse) GetStatus() string
- func (x *ActivityResponse) GetSuccesses() []string
- func (*ActivityResponse) ProtoMessage()
- func (x *ActivityResponse) ProtoReflect() protoreflect.Message
- func (x *ActivityResponse) Reset()
- func (x *ActivityResponse) String() string
- type ActivityServer
- type ArticleCreateActivityRequest
- func (*ArticleCreateActivityRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ArticleCreateActivityRequest) GetAccountId() int64
- func (x *ArticleCreateActivityRequest) GetActorId() int64
- func (x *ArticleCreateActivityRequest) GetArticle() *article.CreateRequest
- func (x *ArticleCreateActivityRequest) GetArticleId() int64
- func (*ArticleCreateActivityRequest) ProtoMessage()
- func (x *ArticleCreateActivityRequest) ProtoReflect() protoreflect.Message
- func (x *ArticleCreateActivityRequest) Reset()
- func (x *ArticleCreateActivityRequest) String() string
- type DeleteInboxRequest
- func (*DeleteInboxRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteInboxRequest) GetInboxId() int64
- func (*DeleteInboxRequest) ProtoMessage()
- func (x *DeleteInboxRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteInboxRequest) Reset()
- func (x *DeleteInboxRequest) String() string
- type DeleteInboxResponse
- func (*DeleteInboxResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteInboxResponse) GetCode() string
- func (x *DeleteInboxResponse) GetStatus() string
- func (*DeleteInboxResponse) ProtoMessage()
- func (x *DeleteInboxResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteInboxResponse) Reset()
- func (x *DeleteInboxResponse) String() string
- type FriendshipClient
- type FriendshipResponse
- func (*FriendshipResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FriendshipResponse) GetActors() []*actor.ActorData
- func (x *FriendshipResponse) GetCode() string
- func (*FriendshipResponse) ProtoMessage()
- func (x *FriendshipResponse) ProtoReflect() protoreflect.Message
- func (x *FriendshipResponse) Reset()
- func (x *FriendshipResponse) String() string
- type FriendshipServer
- type GetInboxRequest
- type GetInboxResponse
- func (*GetInboxResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetInboxResponse) GetCode() string
- func (x *GetInboxResponse) GetInbox() *Inboxes
- func (x *GetInboxResponse) GetStatus() string
- func (*GetInboxResponse) ProtoMessage()
- func (x *GetInboxResponse) ProtoReflect() protoreflect.Message
- func (x *GetInboxResponse) Reset()
- func (x *GetInboxResponse) String() string
- type GetInboxesResponse
- func (*GetInboxesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetInboxesResponse) GetCode() string
- func (x *GetInboxesResponse) GetInboxes() []*Inboxes
- func (x *GetInboxesResponse) GetStatus() string
- func (*GetInboxesResponse) ProtoMessage()
- func (x *GetInboxesResponse) ProtoReflect() protoreflect.Message
- func (x *GetInboxesResponse) Reset()
- func (x *GetInboxesResponse) String() string
- type GetOutboxRequest
- type GetOutboxResponse
- func (*GetOutboxResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetOutboxResponse) GetContext() string
- func (x *GetOutboxResponse) GetFirst() string
- func (x *GetOutboxResponse) GetId() string
- func (x *GetOutboxResponse) GetLast() string
- func (x *GetOutboxResponse) GetTotalItems() string
- func (x *GetOutboxResponse) GetType() string
- func (*GetOutboxResponse) ProtoMessage()
- func (x *GetOutboxResponse) ProtoReflect() protoreflect.Message
- func (x *GetOutboxResponse) Reset()
- func (x *GetOutboxResponse) String() string
- type GetOutboxesPublicRequest
- func (*GetOutboxesPublicRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetOutboxesPublicRequest) GetUsername() string
- func (*GetOutboxesPublicRequest) ProtoMessage()
- func (x *GetOutboxesPublicRequest) ProtoReflect() protoreflect.Message
- func (x *GetOutboxesPublicRequest) Reset()
- func (x *GetOutboxesPublicRequest) String() string
- type GetOutboxesPublicResponse
- func (*GetOutboxesPublicResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetOutboxesPublicResponse) GetOutboxes() []*OutboxData
- func (*GetOutboxesPublicResponse) ProtoMessage()
- func (x *GetOutboxesPublicResponse) ProtoReflect() protoreflect.Message
- func (x *GetOutboxesPublicResponse) Reset()
- func (x *GetOutboxesPublicResponse) String() string
- type GetOutboxesResponse
- func (*GetOutboxesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetOutboxesResponse) GetCode() string
- func (x *GetOutboxesResponse) GetOutboxes() []*OutboxData
- func (*GetOutboxesResponse) ProtoMessage()
- func (x *GetOutboxesResponse) ProtoReflect() protoreflect.Message
- func (x *GetOutboxesResponse) Reset()
- func (x *GetOutboxesResponse) String() string
- type InboxClient
- type InboxRequest
- func (*InboxRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InboxRequest) GetData() []byte
- func (x *InboxRequest) GetName() string
- func (*InboxRequest) ProtoMessage()
- func (x *InboxRequest) ProtoReflect() protoreflect.Message
- func (x *InboxRequest) Reset()
- func (x *InboxRequest) String() string
- type InboxResponse
- func (*InboxResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InboxResponse) GetCode() string
- func (x *InboxResponse) GetStatus() string
- func (*InboxResponse) ProtoMessage()
- func (x *InboxResponse) ProtoReflect() protoreflect.Message
- func (x *InboxResponse) Reset()
- func (x *InboxResponse) String() string
- type InboxServer
- type Inboxes
- func (*Inboxes) Descriptor() ([]byte, []int)deprecated
- func (x *Inboxes) GetActivityId() string
- func (x *Inboxes) GetActorId() string
- func (x *Inboxes) GetBody() string
- func (x *Inboxes) GetFrom() string
- func (x *Inboxes) GetId() string
- func (x *Inboxes) GetType() string
- func (x *Inboxes) GetViewed() bool
- func (*Inboxes) ProtoMessage()
- func (x *Inboxes) ProtoReflect() protoreflect.Message
- func (x *Inboxes) Reset()
- func (x *Inboxes) String() string
- type OutboxClient
- type OutboxData
- func (*OutboxData) Descriptor() ([]byte, []int)deprecated
- func (x *OutboxData) GetActivityId() string
- func (x *OutboxData) GetActorId() int64
- func (x *OutboxData) GetAudience() string
- func (x *OutboxData) GetBcc() string
- func (x *OutboxData) GetBody() string
- func (x *OutboxData) GetBto() string
- func (x *OutboxData) GetCc() string
- func (x *OutboxData) GetId() int64
- func (x *OutboxData) GetTo() string
- func (x *OutboxData) GetTypes() string
- func (*OutboxData) ProtoMessage()
- func (x *OutboxData) ProtoReflect() protoreflect.Message
- func (x *OutboxData) Reset()
- func (x *OutboxData) String() string
- type OutboxServer
- type UnimplementedActivityServer
- type UnimplementedFriendshipServer
- func (UnimplementedFriendshipServer) GetFollower(context.Context, *emptypb.Empty) (*FriendshipResponse, error)
- func (UnimplementedFriendshipServer) GetFollowing(context.Context, *emptypb.Empty) (*FriendshipResponse, error)
- func (UnimplementedFriendshipServer) GetFriend(context.Context, *emptypb.Empty) (*FriendshipResponse, error)
- type UnimplementedInboxServer
- func (UnimplementedInboxServer) DeleteInbox(context.Context, *DeleteInboxRequest) (*DeleteInboxResponse, error)
- func (UnimplementedInboxServer) GetInbox(context.Context, *GetInboxRequest) (*GetInboxResponse, error)
- func (UnimplementedInboxServer) GetInboxes(context.Context, *emptypb.Empty) (*GetInboxesResponse, error)
- func (UnimplementedInboxServer) Inbox(context.Context, *InboxRequest) (*InboxResponse, error)
- func (UnimplementedInboxServer) ViewedInbox(context.Context, *ViewedInboxRequest) (*ViewedInboxResponse, error)
- type UnimplementedOutboxServer
- func (UnimplementedOutboxServer) GetOutbox(context.Context, *GetOutboxRequest) (*GetOutboxResponse, error)
- func (UnimplementedOutboxServer) GetOutboxes(context.Context, *emptypb.Empty) (*GetOutboxesResponse, error)
- func (UnimplementedOutboxServer) GetOutboxesPublic(context.Context, *GetOutboxesPublicRequest) (*GetOutboxesPublicResponse, error)
- type UnsafeActivityServer
- type UnsafeFriendshipServer
- type UnsafeInboxServer
- type UnsafeOutboxServer
- type ViewedInboxRequest
- func (*ViewedInboxRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ViewedInboxRequest) GetInboxId() int64
- func (*ViewedInboxRequest) ProtoMessage()
- func (x *ViewedInboxRequest) ProtoReflect() protoreflect.Message
- func (x *ViewedInboxRequest) Reset()
- func (x *ViewedInboxRequest) String() string
- type ViewedInboxResponse
- func (*ViewedInboxResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ViewedInboxResponse) GetCode() string
- func (x *ViewedInboxResponse) GetStatus() string
- func (*ViewedInboxResponse) ProtoMessage()
- func (x *ViewedInboxResponse) ProtoReflect() protoreflect.Message
- func (x *ViewedInboxResponse) Reset()
- func (x *ViewedInboxResponse) String() string
Constants ¶
This section is empty.
Variables ¶
var Activity_ServiceDesc = grpc.ServiceDesc{ ServiceName: "hvx.api.v1alpha1.activity.proto.Activity", HandlerType: (*ActivityServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Activity", Handler: _Activity_Activity_Handler, }, { MethodName: "ArticleCreateActivity", Handler: _Activity_ArticleCreateActivity_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "proto/v1alpha1/activity/activity.proto", }
Activity_ServiceDesc is the grpc.ServiceDesc for Activity service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_proto_v1alpha1_activity_activity_proto protoreflect.FileDescriptor
var File_proto_v1alpha1_activity_friendship_proto protoreflect.FileDescriptor
var File_proto_v1alpha1_activity_inbox_proto protoreflect.FileDescriptor
var File_proto_v1alpha1_activity_outbox_proto protoreflect.FileDescriptor
var Friendship_ServiceDesc = grpc.ServiceDesc{ ServiceName: "hvx.api.v1alpha1.activity.proto.Friendship", HandlerType: (*FriendshipServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetFollower", Handler: _Friendship_GetFollower_Handler, }, { MethodName: "GetFollowing", Handler: _Friendship_GetFollowing_Handler, }, { MethodName: "GetFriend", Handler: _Friendship_GetFriend_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "proto/v1alpha1/activity/friendship.proto", }
Friendship_ServiceDesc is the grpc.ServiceDesc for Friendship service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Inbox_ServiceDesc = grpc.ServiceDesc{ ServiceName: "hvx.api.v1alpha1.activity.proto.Inbox", HandlerType: (*InboxServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Inbox", Handler: _Inbox_Inbox_Handler, }, { MethodName: "GetInbox", Handler: _Inbox_GetInbox_Handler, }, { MethodName: "GetInboxes", Handler: _Inbox_GetInboxes_Handler, }, { MethodName: "DeleteInbox", Handler: _Inbox_DeleteInbox_Handler, }, { MethodName: "ViewedInbox", Handler: _Inbox_ViewedInbox_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "proto/v1alpha1/activity/inbox.proto", }
Inbox_ServiceDesc is the grpc.ServiceDesc for Inbox service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Outbox_ServiceDesc = grpc.ServiceDesc{ ServiceName: "hvx.api.v1alpha1.activity.proto.Outbox", HandlerType: (*OutboxServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetOutboxesPublic", Handler: _Outbox_GetOutboxesPublic_Handler, }, { MethodName: "GetOutbox", Handler: _Outbox_GetOutbox_Handler, }, { MethodName: "GetOutboxes", Handler: _Outbox_GetOutboxes_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "proto/v1alpha1/activity/outbox.proto", }
Outbox_ServiceDesc is the grpc.ServiceDesc for Outbox service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterActivityHandler ¶
func RegisterActivityHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterActivityHandler registers the http handlers for service Activity to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterActivityHandlerClient ¶
func RegisterActivityHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ActivityClient) error
RegisterActivityHandlerClient registers the http handlers for service Activity to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ActivityClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ActivityClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ActivityClient" to call the correct interceptors.
func RegisterActivityHandlerFromEndpoint ¶
func RegisterActivityHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterActivityHandlerFromEndpoint is same as RegisterActivityHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterActivityHandlerServer ¶
func RegisterActivityHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ActivityServer) error
RegisterActivityHandlerServer registers the http handlers for service Activity to "mux". UnaryRPC :call ActivityServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterActivityHandlerFromEndpoint instead.
func RegisterActivityServer ¶
func RegisterActivityServer(s grpc.ServiceRegistrar, srv ActivityServer)
func RegisterFriendshipHandler ¶
func RegisterFriendshipHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterFriendshipHandler registers the http handlers for service Friendship to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterFriendshipHandlerClient ¶
func RegisterFriendshipHandlerClient(ctx context.Context, mux *runtime.ServeMux, client FriendshipClient) error
RegisterFriendshipHandlerClient registers the http handlers for service Friendship to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "FriendshipClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "FriendshipClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "FriendshipClient" to call the correct interceptors.
func RegisterFriendshipHandlerFromEndpoint ¶
func RegisterFriendshipHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterFriendshipHandlerFromEndpoint is same as RegisterFriendshipHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterFriendshipHandlerServer ¶
func RegisterFriendshipHandlerServer(ctx context.Context, mux *runtime.ServeMux, server FriendshipServer) error
RegisterFriendshipHandlerServer registers the http handlers for service Friendship to "mux". UnaryRPC :call FriendshipServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterFriendshipHandlerFromEndpoint instead.
func RegisterFriendshipServer ¶
func RegisterFriendshipServer(s grpc.ServiceRegistrar, srv FriendshipServer)
func RegisterInboxHandler ¶
RegisterInboxHandler registers the http handlers for service Inbox to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterInboxHandlerClient ¶
func RegisterInboxHandlerClient(ctx context.Context, mux *runtime.ServeMux, client InboxClient) error
RegisterInboxHandlerClient registers the http handlers for service Inbox to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "InboxClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "InboxClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "InboxClient" to call the correct interceptors.
func RegisterInboxHandlerFromEndpoint ¶
func RegisterInboxHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterInboxHandlerFromEndpoint is same as RegisterInboxHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterInboxHandlerServer ¶
func RegisterInboxHandlerServer(ctx context.Context, mux *runtime.ServeMux, server InboxServer) error
RegisterInboxHandlerServer registers the http handlers for service Inbox to "mux". UnaryRPC :call InboxServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterInboxHandlerFromEndpoint instead.
func RegisterInboxServer ¶
func RegisterInboxServer(s grpc.ServiceRegistrar, srv InboxServer)
func RegisterOutboxHandler ¶
RegisterOutboxHandler registers the http handlers for service Outbox to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterOutboxHandlerClient ¶
func RegisterOutboxHandlerClient(ctx context.Context, mux *runtime.ServeMux, client OutboxClient) error
RegisterOutboxHandlerClient registers the http handlers for service Outbox to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "OutboxClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "OutboxClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "OutboxClient" to call the correct interceptors.
func RegisterOutboxHandlerFromEndpoint ¶
func RegisterOutboxHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterOutboxHandlerFromEndpoint is same as RegisterOutboxHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterOutboxHandlerServer ¶
func RegisterOutboxHandlerServer(ctx context.Context, mux *runtime.ServeMux, server OutboxServer) error
RegisterOutboxHandlerServer registers the http handlers for service Outbox to "mux". UnaryRPC :call OutboxServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterOutboxHandlerFromEndpoint instead.
func RegisterOutboxServer ¶
func RegisterOutboxServer(s grpc.ServiceRegistrar, srv OutboxServer)
Types ¶
type ActivityClient ¶
type ActivityClient interface { // Activity base activity API. Activity(ctx context.Context, in *ActivityRequest, opts ...grpc.CallOption) (*ActivityResponse, error) // ArticleCreateActivity Create article activity interface. ArticleCreateActivity(ctx context.Context, in *ArticleCreateActivityRequest, opts ...grpc.CallOption) (*ActivityResponse, error) }
ActivityClient is the client API for Activity 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 NewActivityClient ¶
func NewActivityClient(cc grpc.ClientConnInterface) ActivityClient
type ActivityRequest ¶
type ActivityRequest struct { // This interface is designed for simple Activitypub request interfaces, for complex activities a more complex interface should be implemented. // For example, the type of article creation activity does not use this API and should use ArticleCreateActivity. TO string `protobuf:"bytes,1,opt,name=TO,json=to,proto3" json:"TO,omitempty"` // activity type. Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` // body data that will have the final request for server-to-server interaction. Body string `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"` // contains filtered or unexported fields }
func (*ActivityRequest) Descriptor
deprecated
func (*ActivityRequest) Descriptor() ([]byte, []int)
Deprecated: Use ActivityRequest.ProtoReflect.Descriptor instead.
func (*ActivityRequest) GetBody ¶
func (x *ActivityRequest) GetBody() string
func (*ActivityRequest) GetTO ¶
func (x *ActivityRequest) GetTO() string
func (*ActivityRequest) GetType ¶
func (x *ActivityRequest) GetType() string
func (*ActivityRequest) ProtoMessage ¶
func (*ActivityRequest) ProtoMessage()
func (*ActivityRequest) ProtoReflect ¶
func (x *ActivityRequest) ProtoReflect() protoreflect.Message
func (*ActivityRequest) Reset ¶
func (x *ActivityRequest) Reset()
func (*ActivityRequest) String ¶
func (x *ActivityRequest) String() string
type ActivityResponse ¶
type ActivityResponse struct { Code string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"` Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` // return delivery status, success or failure Successes []string `protobuf:"bytes,3,rep,name=successes,proto3" json:"successes,omitempty"` Failures []string `protobuf:"bytes,4,rep,name=failures,proto3" json:"failures,omitempty"` // contains filtered or unexported fields }
func (*ActivityResponse) Descriptor
deprecated
func (*ActivityResponse) Descriptor() ([]byte, []int)
Deprecated: Use ActivityResponse.ProtoReflect.Descriptor instead.
func (*ActivityResponse) GetCode ¶
func (x *ActivityResponse) GetCode() string
func (*ActivityResponse) GetFailures ¶
func (x *ActivityResponse) GetFailures() []string
func (*ActivityResponse) GetStatus ¶
func (x *ActivityResponse) GetStatus() string
func (*ActivityResponse) GetSuccesses ¶
func (x *ActivityResponse) GetSuccesses() []string
func (*ActivityResponse) ProtoMessage ¶
func (*ActivityResponse) ProtoMessage()
func (*ActivityResponse) ProtoReflect ¶
func (x *ActivityResponse) ProtoReflect() protoreflect.Message
func (*ActivityResponse) Reset ¶
func (x *ActivityResponse) Reset()
func (*ActivityResponse) String ¶
func (x *ActivityResponse) String() string
type ActivityServer ¶
type ActivityServer interface { // Activity base activity API. Activity(context.Context, *ActivityRequest) (*ActivityResponse, error) // ArticleCreateActivity Create article activity interface. ArticleCreateActivity(context.Context, *ArticleCreateActivityRequest) (*ActivityResponse, error) }
ActivityServer is the server API for Activity service. All implementations should embed UnimplementedActivityServer for forward compatibility
type ArticleCreateActivityRequest ¶
type ArticleCreateActivityRequest struct { AccountId int64 `protobuf:"varint,1,opt,name=accountId,proto3" json:"accountId,omitempty"` ActorId int64 `protobuf:"varint,2,opt,name=actorId,proto3" json:"actorId,omitempty"` ArticleId int64 `protobuf:"varint,3,opt,name=articleId,proto3" json:"articleId,omitempty"` Article *article.CreateRequest `protobuf:"bytes,4,opt,name=article,proto3" json:"article,omitempty"` // contains filtered or unexported fields }
func (*ArticleCreateActivityRequest) Descriptor
deprecated
func (*ArticleCreateActivityRequest) Descriptor() ([]byte, []int)
Deprecated: Use ArticleCreateActivityRequest.ProtoReflect.Descriptor instead.
func (*ArticleCreateActivityRequest) GetAccountId ¶
func (x *ArticleCreateActivityRequest) GetAccountId() int64
func (*ArticleCreateActivityRequest) GetActorId ¶
func (x *ArticleCreateActivityRequest) GetActorId() int64
func (*ArticleCreateActivityRequest) GetArticle ¶
func (x *ArticleCreateActivityRequest) GetArticle() *article.CreateRequest
func (*ArticleCreateActivityRequest) GetArticleId ¶
func (x *ArticleCreateActivityRequest) GetArticleId() int64
func (*ArticleCreateActivityRequest) ProtoMessage ¶
func (*ArticleCreateActivityRequest) ProtoMessage()
func (*ArticleCreateActivityRequest) ProtoReflect ¶
func (x *ArticleCreateActivityRequest) ProtoReflect() protoreflect.Message
func (*ArticleCreateActivityRequest) Reset ¶
func (x *ArticleCreateActivityRequest) Reset()
func (*ArticleCreateActivityRequest) String ¶
func (x *ArticleCreateActivityRequest) String() string
type DeleteInboxRequest ¶
type DeleteInboxRequest struct { InboxId int64 `protobuf:"varint,1,opt,name=inboxId,proto3" json:"inboxId,omitempty"` // contains filtered or unexported fields }
func (*DeleteInboxRequest) Descriptor
deprecated
func (*DeleteInboxRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteInboxRequest.ProtoReflect.Descriptor instead.
func (*DeleteInboxRequest) GetInboxId ¶
func (x *DeleteInboxRequest) GetInboxId() int64
func (*DeleteInboxRequest) ProtoMessage ¶
func (*DeleteInboxRequest) ProtoMessage()
func (*DeleteInboxRequest) ProtoReflect ¶
func (x *DeleteInboxRequest) ProtoReflect() protoreflect.Message
func (*DeleteInboxRequest) Reset ¶
func (x *DeleteInboxRequest) Reset()
func (*DeleteInboxRequest) String ¶
func (x *DeleteInboxRequest) String() string
type DeleteInboxResponse ¶
type DeleteInboxResponse struct { Code string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"` Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
func (*DeleteInboxResponse) Descriptor
deprecated
func (*DeleteInboxResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteInboxResponse.ProtoReflect.Descriptor instead.
func (*DeleteInboxResponse) GetCode ¶
func (x *DeleteInboxResponse) GetCode() string
func (*DeleteInboxResponse) GetStatus ¶
func (x *DeleteInboxResponse) GetStatus() string
func (*DeleteInboxResponse) ProtoMessage ¶
func (*DeleteInboxResponse) ProtoMessage()
func (*DeleteInboxResponse) ProtoReflect ¶
func (x *DeleteInboxResponse) ProtoReflect() protoreflect.Message
func (*DeleteInboxResponse) Reset ¶
func (x *DeleteInboxResponse) Reset()
func (*DeleteInboxResponse) String ¶
func (x *DeleteInboxResponse) String() string
type FriendshipClient ¶
type FriendshipClient interface { // GetFollower Use this API to get a list of followers and return information about them when the user queries them. // This API is also mainly used in Activitypub to get followers' addresses and push them when users post content. GetFollower(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*FriendshipResponse, error) // GetFollowing This API returns the Actor data that is being watched. GetFollowing(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*FriendshipResponse, error) // GetFriend If users are following each other, they are friends by default, // and the list of mutual followers is obtained through this API, // for example, when doing instant messaging, the list is both address book. GetFriend(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*FriendshipResponse, error) }
FriendshipClient is the client API for Friendship 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 NewFriendshipClient ¶
func NewFriendshipClient(cc grpc.ClientConnInterface) FriendshipClient
type FriendshipResponse ¶
type FriendshipResponse struct { Code string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"` Actors []*actor.ActorData `protobuf:"bytes,2,rep,name=actors,proto3" json:"actors,omitempty"` // contains filtered or unexported fields }
func (*FriendshipResponse) Descriptor
deprecated
func (*FriendshipResponse) Descriptor() ([]byte, []int)
Deprecated: Use FriendshipResponse.ProtoReflect.Descriptor instead.
func (*FriendshipResponse) GetActors ¶
func (x *FriendshipResponse) GetActors() []*actor.ActorData
func (*FriendshipResponse) GetCode ¶
func (x *FriendshipResponse) GetCode() string
func (*FriendshipResponse) ProtoMessage ¶
func (*FriendshipResponse) ProtoMessage()
func (*FriendshipResponse) ProtoReflect ¶
func (x *FriendshipResponse) ProtoReflect() protoreflect.Message
func (*FriendshipResponse) Reset ¶
func (x *FriendshipResponse) Reset()
func (*FriendshipResponse) String ¶
func (x *FriendshipResponse) String() string
type FriendshipServer ¶
type FriendshipServer interface { // GetFollower Use this API to get a list of followers and return information about them when the user queries them. // This API is also mainly used in Activitypub to get followers' addresses and push them when users post content. GetFollower(context.Context, *emptypb.Empty) (*FriendshipResponse, error) // GetFollowing This API returns the Actor data that is being watched. GetFollowing(context.Context, *emptypb.Empty) (*FriendshipResponse, error) // GetFriend If users are following each other, they are friends by default, // and the list of mutual followers is obtained through this API, // for example, when doing instant messaging, the list is both address book. GetFriend(context.Context, *emptypb.Empty) (*FriendshipResponse, error) }
FriendshipServer is the server API for Friendship service. All implementations should embed UnimplementedFriendshipServer for forward compatibility
type GetInboxRequest ¶
type GetInboxRequest struct { InboxId string `protobuf:"bytes,1,opt,name=inboxId,proto3" json:"inboxId,omitempty"` // contains filtered or unexported fields }
func (*GetInboxRequest) Descriptor
deprecated
func (*GetInboxRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetInboxRequest.ProtoReflect.Descriptor instead.
func (*GetInboxRequest) GetInboxId ¶
func (x *GetInboxRequest) GetInboxId() string
func (*GetInboxRequest) ProtoMessage ¶
func (*GetInboxRequest) ProtoMessage()
func (*GetInboxRequest) ProtoReflect ¶
func (x *GetInboxRequest) ProtoReflect() protoreflect.Message
func (*GetInboxRequest) Reset ¶
func (x *GetInboxRequest) Reset()
func (*GetInboxRequest) String ¶
func (x *GetInboxRequest) String() string
type GetInboxResponse ¶
type GetInboxResponse struct { Code string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"` Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` Inbox *Inboxes `protobuf:"bytes,3,opt,name=inbox,proto3" json:"inbox,omitempty"` // contains filtered or unexported fields }
func (*GetInboxResponse) Descriptor
deprecated
func (*GetInboxResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetInboxResponse.ProtoReflect.Descriptor instead.
func (*GetInboxResponse) GetCode ¶
func (x *GetInboxResponse) GetCode() string
func (*GetInboxResponse) GetInbox ¶
func (x *GetInboxResponse) GetInbox() *Inboxes
func (*GetInboxResponse) GetStatus ¶
func (x *GetInboxResponse) GetStatus() string
func (*GetInboxResponse) ProtoMessage ¶
func (*GetInboxResponse) ProtoMessage()
func (*GetInboxResponse) ProtoReflect ¶
func (x *GetInboxResponse) ProtoReflect() protoreflect.Message
func (*GetInboxResponse) Reset ¶
func (x *GetInboxResponse) Reset()
func (*GetInboxResponse) String ¶
func (x *GetInboxResponse) String() string
type GetInboxesResponse ¶
type GetInboxesResponse struct { Code string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"` Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` Inboxes []*Inboxes `protobuf:"bytes,3,rep,name=inboxes,proto3" json:"inboxes,omitempty"` // contains filtered or unexported fields }
func (*GetInboxesResponse) Descriptor
deprecated
func (*GetInboxesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetInboxesResponse.ProtoReflect.Descriptor instead.
func (*GetInboxesResponse) GetCode ¶
func (x *GetInboxesResponse) GetCode() string
func (*GetInboxesResponse) GetInboxes ¶
func (x *GetInboxesResponse) GetInboxes() []*Inboxes
func (*GetInboxesResponse) GetStatus ¶
func (x *GetInboxesResponse) GetStatus() string
func (*GetInboxesResponse) ProtoMessage ¶
func (*GetInboxesResponse) ProtoMessage()
func (*GetInboxesResponse) ProtoReflect ¶
func (x *GetInboxesResponse) ProtoReflect() protoreflect.Message
func (*GetInboxesResponse) Reset ¶
func (x *GetInboxesResponse) Reset()
func (*GetInboxesResponse) String ¶
func (x *GetInboxesResponse) String() string
type GetOutboxRequest ¶
type GetOutboxRequest struct { ActivityId string `protobuf:"bytes,1,opt,name=activityId,proto3" json:"activityId,omitempty"` // contains filtered or unexported fields }
func (*GetOutboxRequest) Descriptor
deprecated
func (*GetOutboxRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetOutboxRequest.ProtoReflect.Descriptor instead.
func (*GetOutboxRequest) GetActivityId ¶
func (x *GetOutboxRequest) GetActivityId() string
func (*GetOutboxRequest) ProtoMessage ¶
func (*GetOutboxRequest) ProtoMessage()
func (*GetOutboxRequest) ProtoReflect ¶
func (x *GetOutboxRequest) ProtoReflect() protoreflect.Message
func (*GetOutboxRequest) Reset ¶
func (x *GetOutboxRequest) Reset()
func (*GetOutboxRequest) String ¶
func (x *GetOutboxRequest) String() string
type GetOutboxResponse ¶
type GetOutboxResponse struct { Context string `protobuf:"bytes,1,opt,name=context,json=@context,proto3" json:"context,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"` TotalItems string `protobuf:"bytes,4,opt,name=totalItems,proto3" json:"totalItems,omitempty"` First string `protobuf:"bytes,5,opt,name=first,proto3" json:"first,omitempty"` Last string `protobuf:"bytes,6,opt,name=last,proto3" json:"last,omitempty"` // contains filtered or unexported fields }
"@context": "https://www.w3.org/ns/activitystreams", "id": "https://mastodon.disism.com/users/hvturingga/outbox", "type": "OrderedCollection", "totalItems": 2, "first": "https://mastodon.disism.com/users/hvturingga/outbox?page=true", "last": "https://mastodon.disism.com/users/hvturingga/outbox?min_id=0&page=true"
func (*GetOutboxResponse) Descriptor
deprecated
func (*GetOutboxResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetOutboxResponse.ProtoReflect.Descriptor instead.
func (*GetOutboxResponse) GetContext ¶
func (x *GetOutboxResponse) GetContext() string
func (*GetOutboxResponse) GetFirst ¶
func (x *GetOutboxResponse) GetFirst() string
func (*GetOutboxResponse) GetId ¶
func (x *GetOutboxResponse) GetId() string
func (*GetOutboxResponse) GetLast ¶
func (x *GetOutboxResponse) GetLast() string
func (*GetOutboxResponse) GetTotalItems ¶
func (x *GetOutboxResponse) GetTotalItems() string
func (*GetOutboxResponse) GetType ¶
func (x *GetOutboxResponse) GetType() string
func (*GetOutboxResponse) ProtoMessage ¶
func (*GetOutboxResponse) ProtoMessage()
func (*GetOutboxResponse) ProtoReflect ¶
func (x *GetOutboxResponse) ProtoReflect() protoreflect.Message
func (*GetOutboxResponse) Reset ¶
func (x *GetOutboxResponse) Reset()
func (*GetOutboxResponse) String ¶
func (x *GetOutboxResponse) String() string
type GetOutboxesPublicRequest ¶
type GetOutboxesPublicRequest struct { Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` // contains filtered or unexported fields }
func (*GetOutboxesPublicRequest) Descriptor
deprecated
func (*GetOutboxesPublicRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetOutboxesPublicRequest.ProtoReflect.Descriptor instead.
func (*GetOutboxesPublicRequest) GetUsername ¶
func (x *GetOutboxesPublicRequest) GetUsername() string
func (*GetOutboxesPublicRequest) ProtoMessage ¶
func (*GetOutboxesPublicRequest) ProtoMessage()
func (*GetOutboxesPublicRequest) ProtoReflect ¶
func (x *GetOutboxesPublicRequest) ProtoReflect() protoreflect.Message
func (*GetOutboxesPublicRequest) Reset ¶
func (x *GetOutboxesPublicRequest) Reset()
func (*GetOutboxesPublicRequest) String ¶
func (x *GetOutboxesPublicRequest) String() string
type GetOutboxesPublicResponse ¶
type GetOutboxesPublicResponse struct { Outboxes []*OutboxData `protobuf:"bytes,1,rep,name=outboxes,proto3" json:"outboxes,omitempty"` // contains filtered or unexported fields }
func (*GetOutboxesPublicResponse) Descriptor
deprecated
func (*GetOutboxesPublicResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetOutboxesPublicResponse.ProtoReflect.Descriptor instead.
func (*GetOutboxesPublicResponse) GetOutboxes ¶
func (x *GetOutboxesPublicResponse) GetOutboxes() []*OutboxData
func (*GetOutboxesPublicResponse) ProtoMessage ¶
func (*GetOutboxesPublicResponse) ProtoMessage()
func (*GetOutboxesPublicResponse) ProtoReflect ¶
func (x *GetOutboxesPublicResponse) ProtoReflect() protoreflect.Message
func (*GetOutboxesPublicResponse) Reset ¶
func (x *GetOutboxesPublicResponse) Reset()
func (*GetOutboxesPublicResponse) String ¶
func (x *GetOutboxesPublicResponse) String() string
type GetOutboxesResponse ¶
type GetOutboxesResponse struct { Code string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"` Outboxes []*OutboxData `protobuf:"bytes,2,rep,name=outboxes,proto3" json:"outboxes,omitempty"` // contains filtered or unexported fields }
func (*GetOutboxesResponse) Descriptor
deprecated
func (*GetOutboxesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetOutboxesResponse.ProtoReflect.Descriptor instead.
func (*GetOutboxesResponse) GetCode ¶
func (x *GetOutboxesResponse) GetCode() string
func (*GetOutboxesResponse) GetOutboxes ¶
func (x *GetOutboxesResponse) GetOutboxes() []*OutboxData
func (*GetOutboxesResponse) ProtoMessage ¶
func (*GetOutboxesResponse) ProtoMessage()
func (*GetOutboxesResponse) ProtoReflect ¶
func (x *GetOutboxesResponse) ProtoReflect() protoreflect.Message
func (*GetOutboxesResponse) Reset ¶
func (x *GetOutboxesResponse) Reset()
func (*GetOutboxesResponse) String ¶
func (x *GetOutboxesResponse) String() string
type InboxClient ¶
type InboxClient interface { Inbox(ctx context.Context, in *InboxRequest, opts ...grpc.CallOption) (*InboxResponse, error) GetInbox(ctx context.Context, in *GetInboxRequest, opts ...grpc.CallOption) (*GetInboxResponse, error) GetInboxes(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetInboxesResponse, error) DeleteInbox(ctx context.Context, in *DeleteInboxRequest, opts ...grpc.CallOption) (*DeleteInboxResponse, error) ViewedInbox(ctx context.Context, in *ViewedInboxRequest, opts ...grpc.CallOption) (*ViewedInboxResponse, error) }
InboxClient is the client API for Inbox 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 NewInboxClient ¶
func NewInboxClient(cc grpc.ClientConnInterface) InboxClient
type InboxRequest ¶
type InboxRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*InboxRequest) Descriptor
deprecated
func (*InboxRequest) Descriptor() ([]byte, []int)
Deprecated: Use InboxRequest.ProtoReflect.Descriptor instead.
func (*InboxRequest) GetData ¶
func (x *InboxRequest) GetData() []byte
func (*InboxRequest) GetName ¶
func (x *InboxRequest) GetName() string
func (*InboxRequest) ProtoMessage ¶
func (*InboxRequest) ProtoMessage()
func (*InboxRequest) ProtoReflect ¶
func (x *InboxRequest) ProtoReflect() protoreflect.Message
func (*InboxRequest) Reset ¶
func (x *InboxRequest) Reset()
func (*InboxRequest) String ¶
func (x *InboxRequest) String() string
type InboxResponse ¶
type InboxResponse struct { Code string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"` Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
func (*InboxResponse) Descriptor
deprecated
func (*InboxResponse) Descriptor() ([]byte, []int)
Deprecated: Use InboxResponse.ProtoReflect.Descriptor instead.
func (*InboxResponse) GetCode ¶
func (x *InboxResponse) GetCode() string
func (*InboxResponse) GetStatus ¶
func (x *InboxResponse) GetStatus() string
func (*InboxResponse) ProtoMessage ¶
func (*InboxResponse) ProtoMessage()
func (*InboxResponse) ProtoReflect ¶
func (x *InboxResponse) ProtoReflect() protoreflect.Message
func (*InboxResponse) Reset ¶
func (x *InboxResponse) Reset()
func (*InboxResponse) String ¶
func (x *InboxResponse) String() string
type InboxServer ¶
type InboxServer interface { Inbox(context.Context, *InboxRequest) (*InboxResponse, error) GetInbox(context.Context, *GetInboxRequest) (*GetInboxResponse, error) GetInboxes(context.Context, *emptypb.Empty) (*GetInboxesResponse, error) DeleteInbox(context.Context, *DeleteInboxRequest) (*DeleteInboxResponse, error) ViewedInbox(context.Context, *ViewedInboxRequest) (*ViewedInboxResponse, error) }
InboxServer is the server API for Inbox service. All implementations should embed UnimplementedInboxServer for forward compatibility
type Inboxes ¶
type Inboxes struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` ActorId string `protobuf:"bytes,2,opt,name=actorId,proto3" json:"actorId,omitempty"` From string `protobuf:"bytes,3,opt,name=from,proto3" json:"from,omitempty"` ActivityId string `protobuf:"bytes,4,opt,name=activityId,proto3" json:"activityId,omitempty"` Type string `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"` Body string `protobuf:"bytes,6,opt,name=body,proto3" json:"body,omitempty"` Viewed bool `protobuf:"varint,7,opt,name=viewed,proto3" json:"viewed,omitempty"` // contains filtered or unexported fields }
func (*Inboxes) Descriptor
deprecated
func (*Inboxes) GetActivityId ¶
func (*Inboxes) GetActorId ¶
func (*Inboxes) ProtoMessage ¶
func (*Inboxes) ProtoMessage()
func (*Inboxes) ProtoReflect ¶
func (x *Inboxes) ProtoReflect() protoreflect.Message
type OutboxClient ¶
type OutboxClient interface { GetOutboxesPublic(ctx context.Context, in *GetOutboxesPublicRequest, opts ...grpc.CallOption) (*GetOutboxesPublicResponse, error) GetOutbox(ctx context.Context, in *GetOutboxRequest, opts ...grpc.CallOption) (*GetOutboxResponse, error) GetOutboxes(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetOutboxesResponse, error) }
OutboxClient is the client API for Outbox 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 NewOutboxClient ¶
func NewOutboxClient(cc grpc.ClientConnInterface) OutboxClient
type OutboxData ¶
type OutboxData struct { Id int64 `protobuf:"varint,1,opt,name=Id,proto3" json:"Id,omitempty"` ActorId int64 `protobuf:"varint,2,opt,name=ActorId,proto3" json:"ActorId,omitempty"` ActivityId string `protobuf:"bytes,3,opt,name=ActivityId,proto3" json:"ActivityId,omitempty"` To string `protobuf:"bytes,4,opt,name=To,proto3" json:"To,omitempty"` Cc string `protobuf:"bytes,5,opt,name=Cc,proto3" json:"Cc,omitempty"` Bcc string `protobuf:"bytes,6,opt,name=Bcc,proto3" json:"Bcc,omitempty"` Bto string `protobuf:"bytes,7,opt,name=Bto,proto3" json:"Bto,omitempty"` Audience string `protobuf:"bytes,8,opt,name=Audience,proto3" json:"Audience,omitempty"` Types string `protobuf:"bytes,9,opt,name=Types,proto3" json:"Types,omitempty"` Body string `protobuf:"bytes,10,opt,name=Body,proto3" json:"Body,omitempty"` // contains filtered or unexported fields }
func (*OutboxData) Descriptor
deprecated
func (*OutboxData) Descriptor() ([]byte, []int)
Deprecated: Use OutboxData.ProtoReflect.Descriptor instead.
func (*OutboxData) GetActivityId ¶
func (x *OutboxData) GetActivityId() string
func (*OutboxData) GetActorId ¶
func (x *OutboxData) GetActorId() int64
func (*OutboxData) GetAudience ¶
func (x *OutboxData) GetAudience() string
func (*OutboxData) GetBcc ¶
func (x *OutboxData) GetBcc() string
func (*OutboxData) GetBody ¶
func (x *OutboxData) GetBody() string
func (*OutboxData) GetBto ¶
func (x *OutboxData) GetBto() string
func (*OutboxData) GetCc ¶
func (x *OutboxData) GetCc() string
func (*OutboxData) GetId ¶
func (x *OutboxData) GetId() int64
func (*OutboxData) GetTo ¶
func (x *OutboxData) GetTo() string
func (*OutboxData) GetTypes ¶
func (x *OutboxData) GetTypes() string
func (*OutboxData) ProtoMessage ¶
func (*OutboxData) ProtoMessage()
func (*OutboxData) ProtoReflect ¶
func (x *OutboxData) ProtoReflect() protoreflect.Message
func (*OutboxData) Reset ¶
func (x *OutboxData) Reset()
func (*OutboxData) String ¶
func (x *OutboxData) String() string
type OutboxServer ¶
type OutboxServer interface { GetOutboxesPublic(context.Context, *GetOutboxesPublicRequest) (*GetOutboxesPublicResponse, error) GetOutbox(context.Context, *GetOutboxRequest) (*GetOutboxResponse, error) GetOutboxes(context.Context, *emptypb.Empty) (*GetOutboxesResponse, error) }
OutboxServer is the server API for Outbox service. All implementations should embed UnimplementedOutboxServer for forward compatibility
type UnimplementedActivityServer ¶
type UnimplementedActivityServer struct { }
UnimplementedActivityServer should be embedded to have forward compatible implementations.
func (UnimplementedActivityServer) Activity ¶
func (UnimplementedActivityServer) Activity(context.Context, *ActivityRequest) (*ActivityResponse, error)
func (UnimplementedActivityServer) ArticleCreateActivity ¶
func (UnimplementedActivityServer) ArticleCreateActivity(context.Context, *ArticleCreateActivityRequest) (*ActivityResponse, error)
type UnimplementedFriendshipServer ¶
type UnimplementedFriendshipServer struct { }
UnimplementedFriendshipServer should be embedded to have forward compatible implementations.
func (UnimplementedFriendshipServer) GetFollower ¶
func (UnimplementedFriendshipServer) GetFollower(context.Context, *emptypb.Empty) (*FriendshipResponse, error)
func (UnimplementedFriendshipServer) GetFollowing ¶
func (UnimplementedFriendshipServer) GetFollowing(context.Context, *emptypb.Empty) (*FriendshipResponse, error)
func (UnimplementedFriendshipServer) GetFriend ¶
func (UnimplementedFriendshipServer) GetFriend(context.Context, *emptypb.Empty) (*FriendshipResponse, error)
type UnimplementedInboxServer ¶
type UnimplementedInboxServer struct { }
UnimplementedInboxServer should be embedded to have forward compatible implementations.
func (UnimplementedInboxServer) DeleteInbox ¶
func (UnimplementedInboxServer) DeleteInbox(context.Context, *DeleteInboxRequest) (*DeleteInboxResponse, error)
func (UnimplementedInboxServer) GetInbox ¶
func (UnimplementedInboxServer) GetInbox(context.Context, *GetInboxRequest) (*GetInboxResponse, error)
func (UnimplementedInboxServer) GetInboxes ¶
func (UnimplementedInboxServer) GetInboxes(context.Context, *emptypb.Empty) (*GetInboxesResponse, error)
func (UnimplementedInboxServer) Inbox ¶
func (UnimplementedInboxServer) Inbox(context.Context, *InboxRequest) (*InboxResponse, error)
func (UnimplementedInboxServer) ViewedInbox ¶
func (UnimplementedInboxServer) ViewedInbox(context.Context, *ViewedInboxRequest) (*ViewedInboxResponse, error)
type UnimplementedOutboxServer ¶
type UnimplementedOutboxServer struct { }
UnimplementedOutboxServer should be embedded to have forward compatible implementations.
func (UnimplementedOutboxServer) GetOutbox ¶
func (UnimplementedOutboxServer) GetOutbox(context.Context, *GetOutboxRequest) (*GetOutboxResponse, error)
func (UnimplementedOutboxServer) GetOutboxes ¶
func (UnimplementedOutboxServer) GetOutboxes(context.Context, *emptypb.Empty) (*GetOutboxesResponse, error)
func (UnimplementedOutboxServer) GetOutboxesPublic ¶
func (UnimplementedOutboxServer) GetOutboxesPublic(context.Context, *GetOutboxesPublicRequest) (*GetOutboxesPublicResponse, error)
type UnsafeActivityServer ¶
type UnsafeActivityServer interface {
// contains filtered or unexported methods
}
UnsafeActivityServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ActivityServer will result in compilation errors.
type UnsafeFriendshipServer ¶
type UnsafeFriendshipServer interface {
// contains filtered or unexported methods
}
UnsafeFriendshipServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FriendshipServer will result in compilation errors.
type UnsafeInboxServer ¶
type UnsafeInboxServer interface {
// contains filtered or unexported methods
}
UnsafeInboxServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to InboxServer will result in compilation errors.
type UnsafeOutboxServer ¶
type UnsafeOutboxServer interface {
// contains filtered or unexported methods
}
UnsafeOutboxServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OutboxServer will result in compilation errors.
type ViewedInboxRequest ¶
type ViewedInboxRequest struct { InboxId int64 `protobuf:"varint,1,opt,name=inboxId,proto3" json:"inboxId,omitempty"` // contains filtered or unexported fields }
func (*ViewedInboxRequest) Descriptor
deprecated
func (*ViewedInboxRequest) Descriptor() ([]byte, []int)
Deprecated: Use ViewedInboxRequest.ProtoReflect.Descriptor instead.
func (*ViewedInboxRequest) GetInboxId ¶
func (x *ViewedInboxRequest) GetInboxId() int64
func (*ViewedInboxRequest) ProtoMessage ¶
func (*ViewedInboxRequest) ProtoMessage()
func (*ViewedInboxRequest) ProtoReflect ¶
func (x *ViewedInboxRequest) ProtoReflect() protoreflect.Message
func (*ViewedInboxRequest) Reset ¶
func (x *ViewedInboxRequest) Reset()
func (*ViewedInboxRequest) String ¶
func (x *ViewedInboxRequest) String() string
type ViewedInboxResponse ¶
type ViewedInboxResponse struct { Code string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"` Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
func (*ViewedInboxResponse) Descriptor
deprecated
func (*ViewedInboxResponse) Descriptor() ([]byte, []int)
Deprecated: Use ViewedInboxResponse.ProtoReflect.Descriptor instead.
func (*ViewedInboxResponse) GetCode ¶
func (x *ViewedInboxResponse) GetCode() string
func (*ViewedInboxResponse) GetStatus ¶
func (x *ViewedInboxResponse) GetStatus() string
func (*ViewedInboxResponse) ProtoMessage ¶
func (*ViewedInboxResponse) ProtoMessage()
func (*ViewedInboxResponse) ProtoReflect ¶
func (x *ViewedInboxResponse) ProtoReflect() protoreflect.Message
func (*ViewedInboxResponse) Reset ¶
func (x *ViewedInboxResponse) Reset()
func (*ViewedInboxResponse) String ¶
func (x *ViewedInboxResponse) String() string