activity

package
v0.0.0-...-a0d1ad3 Latest Latest
Warning

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

Go to latest
Published: Nov 25, 2022 License: MIT Imports: 20 Imported by: 0

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

Constants

This section is empty.

Variables

View Source
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)

View Source
var File_proto_v1alpha1_activity_activity_proto protoreflect.FileDescriptor
View Source
var File_proto_v1alpha1_activity_friendship_proto protoreflect.FileDescriptor
View Source
var File_proto_v1alpha1_activity_inbox_proto protoreflect.FileDescriptor
View Source
var File_proto_v1alpha1_activity_outbox_proto protoreflect.FileDescriptor
View Source
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)

View Source
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)

View Source
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

func RegisterInboxHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

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

func RegisterOutboxHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

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 (*ArticleCreateActivityRequest) GetArticleId

func (x *ArticleCreateActivityRequest) GetArticleId() int64

func (*ArticleCreateActivityRequest) ProtoMessage

func (*ArticleCreateActivityRequest) ProtoMessage()

func (*ArticleCreateActivityRequest) ProtoReflect

func (*ArticleCreateActivityRequest) Reset

func (x *ArticleCreateActivityRequest) Reset()

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

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) Descriptor() ([]byte, []int)

Deprecated: Use Inboxes.ProtoReflect.Descriptor instead.

func (*Inboxes) GetActivityId

func (x *Inboxes) GetActivityId() string

func (*Inboxes) GetActorId

func (x *Inboxes) GetActorId() string

func (*Inboxes) GetBody

func (x *Inboxes) GetBody() string

func (*Inboxes) GetFrom

func (x *Inboxes) GetFrom() string

func (*Inboxes) GetId

func (x *Inboxes) GetId() string

func (*Inboxes) GetType

func (x *Inboxes) GetType() string

func (*Inboxes) GetViewed

func (x *Inboxes) GetViewed() bool

func (*Inboxes) ProtoMessage

func (*Inboxes) ProtoMessage()

func (*Inboxes) ProtoReflect

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

func (*Inboxes) Reset

func (x *Inboxes) Reset()

func (*Inboxes) String

func (x *Inboxes) String() string

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

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) ArticleCreateActivity

type UnimplementedFriendshipServer

type UnimplementedFriendshipServer struct {
}

UnimplementedFriendshipServer should be embedded to have forward compatible implementations.

func (UnimplementedFriendshipServer) GetFollower

func (UnimplementedFriendshipServer) GetFollowing

func (UnimplementedFriendshipServer) GetFriend

type UnimplementedInboxServer

type UnimplementedInboxServer struct {
}

UnimplementedInboxServer should be embedded to have forward compatible implementations.

func (UnimplementedInboxServer) DeleteInbox

func (UnimplementedInboxServer) GetInbox

func (UnimplementedInboxServer) GetInboxes

func (UnimplementedInboxServer) Inbox

func (UnimplementedInboxServer) ViewedInbox

type UnimplementedOutboxServer

type UnimplementedOutboxServer struct {
}

UnimplementedOutboxServer should be embedded to have forward compatible implementations.

func (UnimplementedOutboxServer) GetOutbox

func (UnimplementedOutboxServer) GetOutboxes

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

Jump to

Keyboard shortcuts

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