channel

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: 18 Imported by: 0

Documentation

Overview

Package channel is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package channel is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package channel is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package channel is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source
var Administrative_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "hvx.api.v1alpha1.channel.proto.Administrative",
	HandlerType: (*AdministrativeServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "IsAdministrator",
			Handler:    _Administrative_IsAdministrator_Handler,
		},
		{
			MethodName: "IsOwner",
			Handler:    _Administrative_IsOwner_Handler,
		},
		{
			MethodName: "AddAdministrator",
			Handler:    _Administrative_AddAdministrator_Handler,
		},
		{
			MethodName: "RemoveAdministrator",
			Handler:    _Administrative_RemoveAdministrator_Handler,
		},
		{
			MethodName: "GetAdministrators",
			Handler:    _Administrative_GetAdministrators_Handler,
		},
		{
			MethodName: "ExitAdministrator",
			Handler:    _Administrative_ExitAdministrator_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/v1alpha1/channel/administrative.proto",
}

Administrative_ServiceDesc is the grpc.ServiceDesc for Administrative 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 Broadcast_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "hvx.api.v1alpha1.channel.proto.Broadcast",
	HandlerType: (*BroadcastServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateBroadcast",
			Handler:    _Broadcast_CreateBroadcast_Handler,
		},
		{
			MethodName: "GetBroadcasts",
			Handler:    _Broadcast_GetBroadcasts_Handler,
		},
		{
			MethodName: "DeleteBroadcast",
			Handler:    _Broadcast_DeleteBroadcast_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/v1alpha1/channel/broadcast.proto",
}

Broadcast_ServiceDesc is the grpc.ServiceDesc for Broadcast 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 Channel_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "hvx.api.v1alpha1.channel.proto.Channel",
	HandlerType: (*ChannelServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateChannel",
			Handler:    _Channel_CreateChannel_Handler,
		},
		{
			MethodName: "GetChannels",
			Handler:    _Channel_GetChannels_Handler,
		},
		{
			MethodName: "DeleteChannel",
			Handler:    _Channel_DeleteChannel_Handler,
		},
		{
			MethodName: "DeleteChannels",
			Handler:    _Channel_DeleteChannels_Handler,
		},
		{
			MethodName: "GetPrivateKeyByActorId",
			Handler:    _Channel_GetPrivateKeyByActorId_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/v1alpha1/channel/channel.proto",
}

Channel_ServiceDesc is the grpc.ServiceDesc for Channel 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_channel_administrative_proto protoreflect.FileDescriptor
View Source
var File_proto_v1alpha1_channel_broadcast_proto protoreflect.FileDescriptor
View Source
var File_proto_v1alpha1_channel_channel_proto protoreflect.FileDescriptor
View Source
var File_proto_v1alpha1_channel_subscriber_proto protoreflect.FileDescriptor
View Source
var Subscriber_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "hvx.api.v1alpha1.channel.proto.Subscriber",
	HandlerType: (*SubscriberServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AddSubscriber",
			Handler:    _Subscriber_AddSubscriber_Handler,
		},
		{
			MethodName: "RemoveSubscriber",
			Handler:    _Subscriber_RemoveSubscriber_Handler,
		},
		{
			MethodName: "GetSubscribers",
			Handler:    _Subscriber_GetSubscribers_Handler,
		},
		{
			MethodName: "Subscription",
			Handler:    _Subscriber_Subscription_Handler,
		},
		{
			MethodName: "Unsubscribe",
			Handler:    _Subscriber_Unsubscribe_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/v1alpha1/channel/subscriber.proto",
}

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

Functions

func RegisterAdministrativeHandler

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

RegisterAdministrativeHandler registers the http handlers for service Administrative to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterAdministrativeHandlerClient

func RegisterAdministrativeHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AdministrativeClient) error

RegisterAdministrativeHandlerClient registers the http handlers for service Administrative to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "AdministrativeClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "AdministrativeClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "AdministrativeClient" to call the correct interceptors.

func RegisterAdministrativeHandlerFromEndpoint

func RegisterAdministrativeHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterAdministrativeHandlerFromEndpoint is same as RegisterAdministrativeHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterAdministrativeHandlerServer

func RegisterAdministrativeHandlerServer(ctx context.Context, mux *runtime.ServeMux, server AdministrativeServer) error

RegisterAdministrativeHandlerServer registers the http handlers for service Administrative to "mux". UnaryRPC :call AdministrativeServer 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 RegisterAdministrativeHandlerFromEndpoint instead.

func RegisterAdministrativeServer

func RegisterAdministrativeServer(s grpc.ServiceRegistrar, srv AdministrativeServer)

func RegisterBroadcastHandler

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

RegisterBroadcastHandler registers the http handlers for service Broadcast to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterBroadcastHandlerClient

func RegisterBroadcastHandlerClient(ctx context.Context, mux *runtime.ServeMux, client BroadcastClient) error

RegisterBroadcastHandlerClient registers the http handlers for service Broadcast to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "BroadcastClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "BroadcastClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "BroadcastClient" to call the correct interceptors.

func RegisterBroadcastHandlerFromEndpoint

func RegisterBroadcastHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterBroadcastHandlerFromEndpoint is same as RegisterBroadcastHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterBroadcastHandlerServer

func RegisterBroadcastHandlerServer(ctx context.Context, mux *runtime.ServeMux, server BroadcastServer) error

RegisterBroadcastHandlerServer registers the http handlers for service Broadcast to "mux". UnaryRPC :call BroadcastServer 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 RegisterBroadcastHandlerFromEndpoint instead.

func RegisterBroadcastServer

func RegisterBroadcastServer(s grpc.ServiceRegistrar, srv BroadcastServer)

func RegisterChannelHandler

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

RegisterChannelHandler registers the http handlers for service Channel to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterChannelHandlerClient

func RegisterChannelHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ChannelClient) error

RegisterChannelHandlerClient registers the http handlers for service Channel to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ChannelClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ChannelClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ChannelClient" to call the correct interceptors.

func RegisterChannelHandlerFromEndpoint

func RegisterChannelHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterChannelHandlerFromEndpoint is same as RegisterChannelHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterChannelHandlerServer

func RegisterChannelHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ChannelServer) error

RegisterChannelHandlerServer registers the http handlers for service Channel to "mux". UnaryRPC :call ChannelServer 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 RegisterChannelHandlerFromEndpoint instead.

func RegisterChannelServer

func RegisterChannelServer(s grpc.ServiceRegistrar, srv ChannelServer)

func RegisterSubscriberHandler

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

RegisterSubscriberHandler registers the http handlers for service Subscriber to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterSubscriberHandlerClient

func RegisterSubscriberHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SubscriberClient) error

RegisterSubscriberHandlerClient registers the http handlers for service Subscriber to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "SubscriberClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "SubscriberClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "SubscriberClient" to call the correct interceptors.

func RegisterSubscriberHandlerFromEndpoint

func RegisterSubscriberHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterSubscriberHandlerFromEndpoint is same as RegisterSubscriberHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterSubscriberHandlerServer

func RegisterSubscriberHandlerServer(ctx context.Context, mux *runtime.ServeMux, server SubscriberServer) error

RegisterSubscriberHandlerServer registers the http handlers for service Subscriber to "mux". UnaryRPC :call SubscriberServer 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 RegisterSubscriberHandlerFromEndpoint instead.

func RegisterSubscriberServer

func RegisterSubscriberServer(s grpc.ServiceRegistrar, srv SubscriberServer)

Types

type AddAdministratorRequest

type AddAdministratorRequest struct {
	ChannelId int64 `protobuf:"varint,1,opt,name=channelId,proto3" json:"channelId,omitempty"`
	AddedId   int64 `protobuf:"varint,3,opt,name=addedId,proto3" json:"addedId,omitempty"`
	// contains filtered or unexported fields
}

func (*AddAdministratorRequest) Descriptor deprecated

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

Deprecated: Use AddAdministratorRequest.ProtoReflect.Descriptor instead.

func (*AddAdministratorRequest) GetAddedId

func (x *AddAdministratorRequest) GetAddedId() int64

func (*AddAdministratorRequest) GetChannelId

func (x *AddAdministratorRequest) GetChannelId() int64

func (*AddAdministratorRequest) ProtoMessage

func (*AddAdministratorRequest) ProtoMessage()

func (*AddAdministratorRequest) ProtoReflect

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

func (*AddAdministratorRequest) Reset

func (x *AddAdministratorRequest) Reset()

func (*AddAdministratorRequest) String

func (x *AddAdministratorRequest) String() string

type AddAdministratorResponse

type AddAdministratorResponse 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 (*AddAdministratorResponse) Descriptor deprecated

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

Deprecated: Use AddAdministratorResponse.ProtoReflect.Descriptor instead.

func (*AddAdministratorResponse) GetCode

func (x *AddAdministratorResponse) GetCode() string

func (*AddAdministratorResponse) GetStatus

func (x *AddAdministratorResponse) GetStatus() string

func (*AddAdministratorResponse) ProtoMessage

func (*AddAdministratorResponse) ProtoMessage()

func (*AddAdministratorResponse) ProtoReflect

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

func (*AddAdministratorResponse) Reset

func (x *AddAdministratorResponse) Reset()

func (*AddAdministratorResponse) String

func (x *AddAdministratorResponse) String() string

type AddSubscriberRequest

type AddSubscriberRequest struct {
	ChannelId    int64 `protobuf:"varint,1,opt,name=channelId,proto3" json:"channelId,omitempty"`
	SubscriberId int64 `protobuf:"varint,2,opt,name=subscriberId,proto3" json:"subscriberId,omitempty"`
	// contains filtered or unexported fields
}

func (*AddSubscriberRequest) Descriptor deprecated

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

Deprecated: Use AddSubscriberRequest.ProtoReflect.Descriptor instead.

func (*AddSubscriberRequest) GetChannelId

func (x *AddSubscriberRequest) GetChannelId() int64

func (*AddSubscriberRequest) GetSubscriberId

func (x *AddSubscriberRequest) GetSubscriberId() int64

func (*AddSubscriberRequest) ProtoMessage

func (*AddSubscriberRequest) ProtoMessage()

func (*AddSubscriberRequest) ProtoReflect

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

func (*AddSubscriberRequest) Reset

func (x *AddSubscriberRequest) Reset()

func (*AddSubscriberRequest) String

func (x *AddSubscriberRequest) String() string

type AddSubscriberResponse

type AddSubscriberResponse 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 (*AddSubscriberResponse) Descriptor deprecated

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

Deprecated: Use AddSubscriberResponse.ProtoReflect.Descriptor instead.

func (*AddSubscriberResponse) GetCode

func (x *AddSubscriberResponse) GetCode() string

func (*AddSubscriberResponse) GetStatus

func (x *AddSubscriberResponse) GetStatus() string

func (*AddSubscriberResponse) ProtoMessage

func (*AddSubscriberResponse) ProtoMessage()

func (*AddSubscriberResponse) ProtoReflect

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

func (*AddSubscriberResponse) Reset

func (x *AddSubscriberResponse) Reset()

func (*AddSubscriberResponse) String

func (x *AddSubscriberResponse) String() string

type AdministrativeClient

type AdministrativeClient interface {
	// IsAdministrator Used to check the channel administrator's privileges,
	// returning whether the user's ID is an administrator.
	IsAdministrator(ctx context.Context, in *IsAdministratorRequest, opts ...grpc.CallOption) (*IsAdministratorResponse, error)
	// IsOwner Check if it is the owner of the channel.
	IsOwner(ctx context.Context, in *IsOwnerRequest, opts ...grpc.CallOption) (*IsOwnerResponse, error)
	// AddAdministrator A user will be added as an administrator by the channel administrator.
	AddAdministrator(ctx context.Context, in *AddAdministratorRequest, opts ...grpc.CallOption) (*AddAdministratorResponse, error)
	// Removing an administrator will remove the administrative privileges of a channel administrator.
	// This is done by the owner of the channel.
	RemoveAdministrator(ctx context.Context, in *RemoveAdministratorRequest, opts ...grpc.CallOption) (*RemoveAdministratorResponse, error)
	// GetAdministrators Gets the list of administrators for the channel.
	GetAdministrators(ctx context.Context, in *GetAdministratorsRequest, opts ...grpc.CallOption) (*GetAdministratorsResponse, error)
	// ExitAdministrator The administrator who exits the channel will have the administrator
	// itself to access the API and choose to revoke the administrator privileges for their channel.
	// Do not become the administrator of the channel.
	ExitAdministrator(ctx context.Context, in *ExitAdministratorRequest, opts ...grpc.CallOption) (*ExitAdministratorResponse, error)
}

AdministrativeClient is the client API for Administrative 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.

type AdministrativeServer

type AdministrativeServer interface {
	// IsAdministrator Used to check the channel administrator's privileges,
	// returning whether the user's ID is an administrator.
	IsAdministrator(context.Context, *IsAdministratorRequest) (*IsAdministratorResponse, error)
	// IsOwner Check if it is the owner of the channel.
	IsOwner(context.Context, *IsOwnerRequest) (*IsOwnerResponse, error)
	// AddAdministrator A user will be added as an administrator by the channel administrator.
	AddAdministrator(context.Context, *AddAdministratorRequest) (*AddAdministratorResponse, error)
	// Removing an administrator will remove the administrative privileges of a channel administrator.
	// This is done by the owner of the channel.
	RemoveAdministrator(context.Context, *RemoveAdministratorRequest) (*RemoveAdministratorResponse, error)
	// GetAdministrators Gets the list of administrators for the channel.
	GetAdministrators(context.Context, *GetAdministratorsRequest) (*GetAdministratorsResponse, error)
	// ExitAdministrator The administrator who exits the channel will have the administrator
	// itself to access the API and choose to revoke the administrator privileges for their channel.
	// Do not become the administrator of the channel.
	ExitAdministrator(context.Context, *ExitAdministratorRequest) (*ExitAdministratorResponse, error)
}

AdministrativeServer is the server API for Administrative service. All implementations should embed UnimplementedAdministrativeServer for forward compatibility

type AdminsData

type AdminsData struct {
	IsOwner bool `protobuf:"varint,1,opt,name=isOwner,proto3" json:"isOwner,omitempty"`
	// manaadminger is actually also an activitypub actor,
	// and this field will return all the data for the actor.
	Admin *actor.ActorData `protobuf:"bytes,2,opt,name=admin,proto3" json:"admin,omitempty"`
	// contains filtered or unexported fields
}

func (*AdminsData) Descriptor deprecated

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

Deprecated: Use AdminsData.ProtoReflect.Descriptor instead.

func (*AdminsData) GetAdmin

func (x *AdminsData) GetAdmin() *actor.ActorData

func (*AdminsData) GetIsOwner

func (x *AdminsData) GetIsOwner() bool

func (*AdminsData) ProtoMessage

func (*AdminsData) ProtoMessage()

func (*AdminsData) ProtoReflect

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

func (*AdminsData) Reset

func (x *AdminsData) Reset()

func (*AdminsData) String

func (x *AdminsData) String() string

type BroadcastClient

type BroadcastClient interface {
	CreateBroadcast(ctx context.Context, in *CreateBroadcastRequest, opts ...grpc.CallOption) (*CreateBroadcastResponse, error)
	GetBroadcasts(ctx context.Context, in *GetBroadcastsRequest, opts ...grpc.CallOption) (*GetBroadcastsResponse, error)
	DeleteBroadcast(ctx context.Context, in *DeleteBroadcastRequest, opts ...grpc.CallOption) (*DeleteBroadcastResponse, error)
}

BroadcastClient is the client API for Broadcast 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 NewBroadcastClient

func NewBroadcastClient(cc grpc.ClientConnInterface) BroadcastClient

type BroadcastData

type BroadcastData struct {
	Id        int64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	ChannelId int64  `protobuf:"varint,2,opt,name=channelId,proto3" json:"channelId,omitempty"`
	AdminId   int64  `protobuf:"varint,3,opt,name=adminId,proto3" json:"adminId,omitempty"`
	Cid       string `protobuf:"bytes,4,opt,name=cid,proto3" json:"cid,omitempty"`
	// contains filtered or unexported fields
}

func (*BroadcastData) Descriptor deprecated

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

Deprecated: Use BroadcastData.ProtoReflect.Descriptor instead.

func (*BroadcastData) GetAdminId

func (x *BroadcastData) GetAdminId() int64

func (*BroadcastData) GetChannelId

func (x *BroadcastData) GetChannelId() int64

func (*BroadcastData) GetCid

func (x *BroadcastData) GetCid() string

func (*BroadcastData) GetId

func (x *BroadcastData) GetId() int64

func (*BroadcastData) ProtoMessage

func (*BroadcastData) ProtoMessage()

func (*BroadcastData) ProtoReflect

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

func (*BroadcastData) Reset

func (x *BroadcastData) Reset()

func (*BroadcastData) String

func (x *BroadcastData) String() string

type BroadcastServer

BroadcastServer is the server API for Broadcast service. All implementations should embed UnimplementedBroadcastServer for forward compatibility

type ChannelClient

type ChannelClient interface {
	// CreateChannel Creating a channel is essentially creating an Actor of type services.
	// https://www.w3.org/TR/activitystreams-vocabulary/#dfn-service
	CreateChannel(ctx context.Context, in *CreateChannelRequest, opts ...grpc.CallOption) (*CreateChannelResponse, error)
	// GetChannels Gets all channels created by the account.
	// The interface will be accessed via the HTTP protocol and the user data will be retrieved via the TOKEN context.
	GetChannels(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetChannelsResponse, error)
	// DeleteChannel The API to delete this channel removes the ID of the receiving channel and the ID of the owner.
	DeleteChannel(ctx context.Context, in *DeleteChannelRequest, opts ...grpc.CallOption) (*DeleteChannelResponse, error)
	// DeleteChannels Delete all channels,
	// for example, if you need to delete all data of the account when you logout,
	// you need to use this API to delete all channels created by the account.
	DeleteChannels(ctx context.Context, in *DeleteChannelsRequest, opts ...grpc.CallOption) (*DeleteChannelsResponse, error)
	// GetPrivateKeyByActorId When doing activitypub interaction,
	// for example, publishing a broadcast then you need to send the message to all channel subscribers,
	// and then you need to sign it, you can get the signed private key through this API.
	GetPrivateKeyByActorId(ctx context.Context, in *GetPrivateKeyByActorIdRequest, opts ...grpc.CallOption) (*GetPrivateKeyByActorIdResponse, error)
}

ChannelClient is the client API for Channel 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 NewChannelClient

func NewChannelClient(cc grpc.ClientConnInterface) ChannelClient

type ChannelData

type ChannelData struct {
	ChannelId int64 `protobuf:"varint,1,opt,name=channelId,proto3" json:"channelId,omitempty"`
	// channel will return the channel's data, the same as the actor.
	Channel *actor.ActorData `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel,omitempty"`
	// contains filtered or unexported fields
}

func (*ChannelData) Descriptor deprecated

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

Deprecated: Use ChannelData.ProtoReflect.Descriptor instead.

func (*ChannelData) GetChannel

func (x *ChannelData) GetChannel() *actor.ActorData

func (*ChannelData) GetChannelId

func (x *ChannelData) GetChannelId() int64

func (*ChannelData) ProtoMessage

func (*ChannelData) ProtoMessage()

func (*ChannelData) ProtoReflect

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

func (*ChannelData) Reset

func (x *ChannelData) Reset()

func (*ChannelData) String

func (x *ChannelData) String() string

type ChannelServer

type ChannelServer interface {
	// CreateChannel Creating a channel is essentially creating an Actor of type services.
	// https://www.w3.org/TR/activitystreams-vocabulary/#dfn-service
	CreateChannel(context.Context, *CreateChannelRequest) (*CreateChannelResponse, error)
	// GetChannels Gets all channels created by the account.
	// The interface will be accessed via the HTTP protocol and the user data will be retrieved via the TOKEN context.
	GetChannels(context.Context, *emptypb.Empty) (*GetChannelsResponse, error)
	// DeleteChannel The API to delete this channel removes the ID of the receiving channel and the ID of the owner.
	DeleteChannel(context.Context, *DeleteChannelRequest) (*DeleteChannelResponse, error)
	// DeleteChannels Delete all channels,
	// for example, if you need to delete all data of the account when you logout,
	// you need to use this API to delete all channels created by the account.
	DeleteChannels(context.Context, *DeleteChannelsRequest) (*DeleteChannelsResponse, error)
	// GetPrivateKeyByActorId When doing activitypub interaction,
	// for example, publishing a broadcast then you need to send the message to all channel subscribers,
	// and then you need to sign it, you can get the signed private key through this API.
	GetPrivateKeyByActorId(context.Context, *GetPrivateKeyByActorIdRequest) (*GetPrivateKeyByActorIdResponse, error)
}

ChannelServer is the server API for Channel service. All implementations should embed UnimplementedChannelServer for forward compatibility

type CreateBroadcastRequest

type CreateBroadcastRequest struct {
	ChannelId int64  `protobuf:"varint,1,opt,name=channelId,proto3" json:"channelId,omitempty"`
	Type      string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Cid       string `protobuf:"bytes,3,opt,name=cid,proto3" json:"cid,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateBroadcastRequest) Descriptor deprecated

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

Deprecated: Use CreateBroadcastRequest.ProtoReflect.Descriptor instead.

func (*CreateBroadcastRequest) GetChannelId

func (x *CreateBroadcastRequest) GetChannelId() int64

func (*CreateBroadcastRequest) GetCid

func (x *CreateBroadcastRequest) GetCid() string

func (*CreateBroadcastRequest) GetType

func (x *CreateBroadcastRequest) GetType() string

func (*CreateBroadcastRequest) ProtoMessage

func (*CreateBroadcastRequest) ProtoMessage()

func (*CreateBroadcastRequest) ProtoReflect

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

func (*CreateBroadcastRequest) Reset

func (x *CreateBroadcastRequest) Reset()

func (*CreateBroadcastRequest) String

func (x *CreateBroadcastRequest) String() string

type CreateBroadcastResponse

type CreateBroadcastResponse 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 (*CreateBroadcastResponse) Descriptor deprecated

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

Deprecated: Use CreateBroadcastResponse.ProtoReflect.Descriptor instead.

func (*CreateBroadcastResponse) GetCode

func (x *CreateBroadcastResponse) GetCode() string

func (*CreateBroadcastResponse) GetStatus

func (x *CreateBroadcastResponse) GetStatus() string

func (*CreateBroadcastResponse) ProtoMessage

func (*CreateBroadcastResponse) ProtoMessage()

func (*CreateBroadcastResponse) ProtoReflect

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

func (*CreateBroadcastResponse) Reset

func (x *CreateBroadcastResponse) Reset()

func (*CreateBroadcastResponse) String

func (x *CreateBroadcastResponse) String() string

type CreateChannelRequest

type CreateChannelRequest struct {

	// preferredUsername Because a channel is essentially an actor of an activitypub,
	// this field is used to identify the name of the channel.
	PreferredUsername string `protobuf:"bytes,1,opt,name=preferredUsername,proto3" json:"preferredUsername,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateChannelRequest) Descriptor deprecated

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

Deprecated: Use CreateChannelRequest.ProtoReflect.Descriptor instead.

func (*CreateChannelRequest) GetPreferredUsername

func (x *CreateChannelRequest) GetPreferredUsername() string

func (*CreateChannelRequest) ProtoMessage

func (*CreateChannelRequest) ProtoMessage()

func (*CreateChannelRequest) ProtoReflect

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

func (*CreateChannelRequest) Reset

func (x *CreateChannelRequest) Reset()

func (*CreateChannelRequest) String

func (x *CreateChannelRequest) String() string

type CreateChannelResponse

type CreateChannelResponse 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 (*CreateChannelResponse) Descriptor deprecated

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

Deprecated: Use CreateChannelResponse.ProtoReflect.Descriptor instead.

func (*CreateChannelResponse) GetCode

func (x *CreateChannelResponse) GetCode() string

func (*CreateChannelResponse) GetStatus

func (x *CreateChannelResponse) GetStatus() string

func (*CreateChannelResponse) ProtoMessage

func (*CreateChannelResponse) ProtoMessage()

func (*CreateChannelResponse) ProtoReflect

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

func (*CreateChannelResponse) Reset

func (x *CreateChannelResponse) Reset()

func (*CreateChannelResponse) String

func (x *CreateChannelResponse) String() string

type DeleteBroadcastRequest

type DeleteBroadcastRequest struct {
	ChannelId   int64 `protobuf:"varint,1,opt,name=channelId,proto3" json:"channelId,omitempty"`
	BroadcastId int64 `protobuf:"varint,2,opt,name=broadcastId,proto3" json:"broadcastId,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteBroadcastRequest) Descriptor deprecated

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

Deprecated: Use DeleteBroadcastRequest.ProtoReflect.Descriptor instead.

func (*DeleteBroadcastRequest) GetBroadcastId

func (x *DeleteBroadcastRequest) GetBroadcastId() int64

func (*DeleteBroadcastRequest) GetChannelId

func (x *DeleteBroadcastRequest) GetChannelId() int64

func (*DeleteBroadcastRequest) ProtoMessage

func (*DeleteBroadcastRequest) ProtoMessage()

func (*DeleteBroadcastRequest) ProtoReflect

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

func (*DeleteBroadcastRequest) Reset

func (x *DeleteBroadcastRequest) Reset()

func (*DeleteBroadcastRequest) String

func (x *DeleteBroadcastRequest) String() string

type DeleteBroadcastResponse

type DeleteBroadcastResponse 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 (*DeleteBroadcastResponse) Descriptor deprecated

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

Deprecated: Use DeleteBroadcastResponse.ProtoReflect.Descriptor instead.

func (*DeleteBroadcastResponse) GetCode

func (x *DeleteBroadcastResponse) GetCode() string

func (*DeleteBroadcastResponse) GetStatus

func (x *DeleteBroadcastResponse) GetStatus() string

func (*DeleteBroadcastResponse) ProtoMessage

func (*DeleteBroadcastResponse) ProtoMessage()

func (*DeleteBroadcastResponse) ProtoReflect

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

func (*DeleteBroadcastResponse) Reset

func (x *DeleteBroadcastResponse) Reset()

func (*DeleteBroadcastResponse) String

func (x *DeleteBroadcastResponse) String() string

type DeleteChannelRequest

type DeleteChannelRequest struct {
	ChannelId int64 `protobuf:"varint,1,opt,name=channelId,proto3" json:"channelId,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteChannelRequest) Descriptor deprecated

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

Deprecated: Use DeleteChannelRequest.ProtoReflect.Descriptor instead.

func (*DeleteChannelRequest) GetChannelId

func (x *DeleteChannelRequest) GetChannelId() int64

func (*DeleteChannelRequest) ProtoMessage

func (*DeleteChannelRequest) ProtoMessage()

func (*DeleteChannelRequest) ProtoReflect

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

func (*DeleteChannelRequest) Reset

func (x *DeleteChannelRequest) Reset()

func (*DeleteChannelRequest) String

func (x *DeleteChannelRequest) String() string

type DeleteChannelResponse

type DeleteChannelResponse 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 (*DeleteChannelResponse) Descriptor deprecated

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

Deprecated: Use DeleteChannelResponse.ProtoReflect.Descriptor instead.

func (*DeleteChannelResponse) GetCode

func (x *DeleteChannelResponse) GetCode() string

func (*DeleteChannelResponse) GetStatus

func (x *DeleteChannelResponse) GetStatus() string

func (*DeleteChannelResponse) ProtoMessage

func (*DeleteChannelResponse) ProtoMessage()

func (*DeleteChannelResponse) ProtoReflect

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

func (*DeleteChannelResponse) Reset

func (x *DeleteChannelResponse) Reset()

func (*DeleteChannelResponse) String

func (x *DeleteChannelResponse) String() string

type DeleteChannelsRequest

type DeleteChannelsRequest struct {
	AccountId int64 `protobuf:"varint,1,opt,name=accountId,proto3" json:"accountId,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteChannelsRequest) Descriptor deprecated

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

Deprecated: Use DeleteChannelsRequest.ProtoReflect.Descriptor instead.

func (*DeleteChannelsRequest) GetAccountId

func (x *DeleteChannelsRequest) GetAccountId() int64

func (*DeleteChannelsRequest) ProtoMessage

func (*DeleteChannelsRequest) ProtoMessage()

func (*DeleteChannelsRequest) ProtoReflect

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

func (*DeleteChannelsRequest) Reset

func (x *DeleteChannelsRequest) Reset()

func (*DeleteChannelsRequest) String

func (x *DeleteChannelsRequest) String() string

type DeleteChannelsResponse

type DeleteChannelsResponse 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 (*DeleteChannelsResponse) Descriptor deprecated

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

Deprecated: Use DeleteChannelsResponse.ProtoReflect.Descriptor instead.

func (*DeleteChannelsResponse) GetCode

func (x *DeleteChannelsResponse) GetCode() string

func (*DeleteChannelsResponse) GetStatus

func (x *DeleteChannelsResponse) GetStatus() string

func (*DeleteChannelsResponse) ProtoMessage

func (*DeleteChannelsResponse) ProtoMessage()

func (*DeleteChannelsResponse) ProtoReflect

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

func (*DeleteChannelsResponse) Reset

func (x *DeleteChannelsResponse) Reset()

func (*DeleteChannelsResponse) String

func (x *DeleteChannelsResponse) String() string

type ExitAdministratorRequest

type ExitAdministratorRequest struct {
	ChannelId int64 `protobuf:"varint,1,opt,name=channelId,proto3" json:"channelId,omitempty"`
	AdminId   int64 `protobuf:"varint,2,opt,name=adminId,proto3" json:"adminId,omitempty"`
	// contains filtered or unexported fields
}

func (*ExitAdministratorRequest) Descriptor deprecated

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

Deprecated: Use ExitAdministratorRequest.ProtoReflect.Descriptor instead.

func (*ExitAdministratorRequest) GetAdminId

func (x *ExitAdministratorRequest) GetAdminId() int64

func (*ExitAdministratorRequest) GetChannelId

func (x *ExitAdministratorRequest) GetChannelId() int64

func (*ExitAdministratorRequest) ProtoMessage

func (*ExitAdministratorRequest) ProtoMessage()

func (*ExitAdministratorRequest) ProtoReflect

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

func (*ExitAdministratorRequest) Reset

func (x *ExitAdministratorRequest) Reset()

func (*ExitAdministratorRequest) String

func (x *ExitAdministratorRequest) String() string

type ExitAdministratorResponse

type ExitAdministratorResponse 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 (*ExitAdministratorResponse) Descriptor deprecated

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

Deprecated: Use ExitAdministratorResponse.ProtoReflect.Descriptor instead.

func (*ExitAdministratorResponse) GetCode

func (x *ExitAdministratorResponse) GetCode() string

func (*ExitAdministratorResponse) GetStatus

func (x *ExitAdministratorResponse) GetStatus() string

func (*ExitAdministratorResponse) ProtoMessage

func (*ExitAdministratorResponse) ProtoMessage()

func (*ExitAdministratorResponse) ProtoReflect

func (*ExitAdministratorResponse) Reset

func (x *ExitAdministratorResponse) Reset()

func (*ExitAdministratorResponse) String

func (x *ExitAdministratorResponse) String() string

type GetAdministratorsRequest

type GetAdministratorsRequest struct {
	ChannelId string `protobuf:"bytes,1,opt,name=channelId,proto3" json:"channelId,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAdministratorsRequest) Descriptor deprecated

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

Deprecated: Use GetAdministratorsRequest.ProtoReflect.Descriptor instead.

func (*GetAdministratorsRequest) GetChannelId

func (x *GetAdministratorsRequest) GetChannelId() string

func (*GetAdministratorsRequest) ProtoMessage

func (*GetAdministratorsRequest) ProtoMessage()

func (*GetAdministratorsRequest) ProtoReflect

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

func (*GetAdministratorsRequest) Reset

func (x *GetAdministratorsRequest) Reset()

func (*GetAdministratorsRequest) String

func (x *GetAdministratorsRequest) String() string

type GetAdministratorsResponse

type GetAdministratorsResponse struct {
	Code   string        `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	Admins []*AdminsData `protobuf:"bytes,2,rep,name=admins,proto3" json:"admins,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAdministratorsResponse) Descriptor deprecated

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

Deprecated: Use GetAdministratorsResponse.ProtoReflect.Descriptor instead.

func (*GetAdministratorsResponse) GetAdmins

func (x *GetAdministratorsResponse) GetAdmins() []*AdminsData

func (*GetAdministratorsResponse) GetCode

func (x *GetAdministratorsResponse) GetCode() string

func (*GetAdministratorsResponse) ProtoMessage

func (*GetAdministratorsResponse) ProtoMessage()

func (*GetAdministratorsResponse) ProtoReflect

func (*GetAdministratorsResponse) Reset

func (x *GetAdministratorsResponse) Reset()

func (*GetAdministratorsResponse) String

func (x *GetAdministratorsResponse) String() string

type GetBroadcastsRequest

type GetBroadcastsRequest struct {
	ChannelId string `protobuf:"bytes,1,opt,name=channelId,proto3" json:"channelId,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBroadcastsRequest) Descriptor deprecated

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

Deprecated: Use GetBroadcastsRequest.ProtoReflect.Descriptor instead.

func (*GetBroadcastsRequest) GetChannelId

func (x *GetBroadcastsRequest) GetChannelId() string

func (*GetBroadcastsRequest) ProtoMessage

func (*GetBroadcastsRequest) ProtoMessage()

func (*GetBroadcastsRequest) ProtoReflect

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

func (*GetBroadcastsRequest) Reset

func (x *GetBroadcastsRequest) Reset()

func (*GetBroadcastsRequest) String

func (x *GetBroadcastsRequest) String() string

type GetBroadcastsResponse

type GetBroadcastsResponse struct {
	Code       string           `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	Broadcasts []*BroadcastData `protobuf:"bytes,2,rep,name=broadcasts,proto3" json:"broadcasts,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBroadcastsResponse) Descriptor deprecated

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

Deprecated: Use GetBroadcastsResponse.ProtoReflect.Descriptor instead.

func (*GetBroadcastsResponse) GetBroadcasts

func (x *GetBroadcastsResponse) GetBroadcasts() []*BroadcastData

func (*GetBroadcastsResponse) GetCode

func (x *GetBroadcastsResponse) GetCode() string

func (*GetBroadcastsResponse) ProtoMessage

func (*GetBroadcastsResponse) ProtoMessage()

func (*GetBroadcastsResponse) ProtoReflect

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

func (*GetBroadcastsResponse) Reset

func (x *GetBroadcastsResponse) Reset()

func (*GetBroadcastsResponse) String

func (x *GetBroadcastsResponse) String() string

type GetChannelsResponse

type GetChannelsResponse 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"`
	// is a repeated type of data, loaded with ChannelData.
	Channels []*ChannelData `protobuf:"bytes,3,rep,name=channels,proto3" json:"channels,omitempty"`
	// contains filtered or unexported fields
}

func (*GetChannelsResponse) Descriptor deprecated

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

Deprecated: Use GetChannelsResponse.ProtoReflect.Descriptor instead.

func (*GetChannelsResponse) GetChannels

func (x *GetChannelsResponse) GetChannels() []*ChannelData

func (*GetChannelsResponse) GetCode

func (x *GetChannelsResponse) GetCode() string

func (*GetChannelsResponse) GetStatus

func (x *GetChannelsResponse) GetStatus() string

func (*GetChannelsResponse) ProtoMessage

func (*GetChannelsResponse) ProtoMessage()

func (*GetChannelsResponse) ProtoReflect

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

func (*GetChannelsResponse) Reset

func (x *GetChannelsResponse) Reset()

func (*GetChannelsResponse) String

func (x *GetChannelsResponse) String() string

type GetPrivateKeyByActorIdRequest

type GetPrivateKeyByActorIdRequest struct {
	ActorId int64 `protobuf:"varint,1,opt,name=actorId,proto3" json:"actorId,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPrivateKeyByActorIdRequest) Descriptor deprecated

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

Deprecated: Use GetPrivateKeyByActorIdRequest.ProtoReflect.Descriptor instead.

func (*GetPrivateKeyByActorIdRequest) GetActorId

func (x *GetPrivateKeyByActorIdRequest) GetActorId() int64

func (*GetPrivateKeyByActorIdRequest) ProtoMessage

func (*GetPrivateKeyByActorIdRequest) ProtoMessage()

func (*GetPrivateKeyByActorIdRequest) ProtoReflect

func (*GetPrivateKeyByActorIdRequest) Reset

func (x *GetPrivateKeyByActorIdRequest) Reset()

func (*GetPrivateKeyByActorIdRequest) String

type GetPrivateKeyByActorIdResponse

type GetPrivateKeyByActorIdResponse struct {
	PrivateKey string `protobuf:"bytes,1,opt,name=privateKey,proto3" json:"privateKey,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPrivateKeyByActorIdResponse) Descriptor deprecated

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

Deprecated: Use GetPrivateKeyByActorIdResponse.ProtoReflect.Descriptor instead.

func (*GetPrivateKeyByActorIdResponse) GetPrivateKey

func (x *GetPrivateKeyByActorIdResponse) GetPrivateKey() string

func (*GetPrivateKeyByActorIdResponse) ProtoMessage

func (*GetPrivateKeyByActorIdResponse) ProtoMessage()

func (*GetPrivateKeyByActorIdResponse) ProtoReflect

func (*GetPrivateKeyByActorIdResponse) Reset

func (x *GetPrivateKeyByActorIdResponse) Reset()

func (*GetPrivateKeyByActorIdResponse) String

type GetSubscribersRequest

type GetSubscribersRequest struct {
	ChannelId string `protobuf:"bytes,1,opt,name=channelId,proto3" json:"channelId,omitempty"`
	AdminId   int64  `protobuf:"varint,2,opt,name=adminId,proto3" json:"adminId,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSubscribersRequest) Descriptor deprecated

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

Deprecated: Use GetSubscribersRequest.ProtoReflect.Descriptor instead.

func (*GetSubscribersRequest) GetAdminId

func (x *GetSubscribersRequest) GetAdminId() int64

func (*GetSubscribersRequest) GetChannelId

func (x *GetSubscribersRequest) GetChannelId() string

func (*GetSubscribersRequest) ProtoMessage

func (*GetSubscribersRequest) ProtoMessage()

func (*GetSubscribersRequest) ProtoReflect

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

func (*GetSubscribersRequest) Reset

func (x *GetSubscribersRequest) Reset()

func (*GetSubscribersRequest) String

func (x *GetSubscribersRequest) String() string

type GetSubscribersResponse

type GetSubscribersResponse 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"`
	// The subscriber is an actor type of activitypub, so it will return actor data of type REPEATED.
	Subscriber []*actor.ActorData `protobuf:"bytes,3,rep,name=subscriber,proto3" json:"subscriber,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSubscribersResponse) Descriptor deprecated

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

Deprecated: Use GetSubscribersResponse.ProtoReflect.Descriptor instead.

func (*GetSubscribersResponse) GetCode

func (x *GetSubscribersResponse) GetCode() string

func (*GetSubscribersResponse) GetStatus

func (x *GetSubscribersResponse) GetStatus() string

func (*GetSubscribersResponse) GetSubscriber

func (x *GetSubscribersResponse) GetSubscriber() []*actor.ActorData

func (*GetSubscribersResponse) ProtoMessage

func (*GetSubscribersResponse) ProtoMessage()

func (*GetSubscribersResponse) ProtoReflect

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

func (*GetSubscribersResponse) Reset

func (x *GetSubscribersResponse) Reset()

func (*GetSubscribersResponse) String

func (x *GetSubscribersResponse) String() string

type IsAdministratorRequest

type IsAdministratorRequest struct {
	ChannelId int64 `protobuf:"varint,1,opt,name=channelId,proto3" json:"channelId,omitempty"`
	AdminId   int64 `protobuf:"varint,2,opt,name=adminId,proto3" json:"adminId,omitempty"`
	// contains filtered or unexported fields
}

func (*IsAdministratorRequest) Descriptor deprecated

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

Deprecated: Use IsAdministratorRequest.ProtoReflect.Descriptor instead.

func (*IsAdministratorRequest) GetAdminId

func (x *IsAdministratorRequest) GetAdminId() int64

func (*IsAdministratorRequest) GetChannelId

func (x *IsAdministratorRequest) GetChannelId() int64

func (*IsAdministratorRequest) ProtoMessage

func (*IsAdministratorRequest) ProtoMessage()

func (*IsAdministratorRequest) ProtoReflect

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

func (*IsAdministratorRequest) Reset

func (x *IsAdministratorRequest) Reset()

func (*IsAdministratorRequest) String

func (x *IsAdministratorRequest) String() string

type IsAdministratorResponse

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

func (*IsAdministratorResponse) Descriptor deprecated

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

Deprecated: Use IsAdministratorResponse.ProtoReflect.Descriptor instead.

func (*IsAdministratorResponse) GetIsAdministrator

func (x *IsAdministratorResponse) GetIsAdministrator() bool

func (*IsAdministratorResponse) ProtoMessage

func (*IsAdministratorResponse) ProtoMessage()

func (*IsAdministratorResponse) ProtoReflect

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

func (*IsAdministratorResponse) Reset

func (x *IsAdministratorResponse) Reset()

func (*IsAdministratorResponse) String

func (x *IsAdministratorResponse) String() string

type IsOwnerRequest

type IsOwnerRequest struct {
	ChannelId int64 `protobuf:"varint,1,opt,name=channelId,proto3" json:"channelId,omitempty"`
	OwnerId   int64 `protobuf:"varint,2,opt,name=ownerId,proto3" json:"ownerId,omitempty"`
	// contains filtered or unexported fields
}

func (*IsOwnerRequest) Descriptor deprecated

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

Deprecated: Use IsOwnerRequest.ProtoReflect.Descriptor instead.

func (*IsOwnerRequest) GetChannelId

func (x *IsOwnerRequest) GetChannelId() int64

func (*IsOwnerRequest) GetOwnerId

func (x *IsOwnerRequest) GetOwnerId() int64

func (*IsOwnerRequest) ProtoMessage

func (*IsOwnerRequest) ProtoMessage()

func (*IsOwnerRequest) ProtoReflect

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

func (*IsOwnerRequest) Reset

func (x *IsOwnerRequest) Reset()

func (*IsOwnerRequest) String

func (x *IsOwnerRequest) String() string

type IsOwnerResponse

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

func (*IsOwnerResponse) Descriptor deprecated

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

Deprecated: Use IsOwnerResponse.ProtoReflect.Descriptor instead.

func (*IsOwnerResponse) GetIsOwner

func (x *IsOwnerResponse) GetIsOwner() bool

func (*IsOwnerResponse) ProtoMessage

func (*IsOwnerResponse) ProtoMessage()

func (*IsOwnerResponse) ProtoReflect

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

func (*IsOwnerResponse) Reset

func (x *IsOwnerResponse) Reset()

func (*IsOwnerResponse) String

func (x *IsOwnerResponse) String() string

type RemoveAdministratorRequest

type RemoveAdministratorRequest struct {
	ChannelId int64 `protobuf:"varint,1,opt,name=channelId,proto3" json:"channelId,omitempty"`
	RemovedId int64 `protobuf:"varint,2,opt,name=removedId,proto3" json:"removedId,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveAdministratorRequest) Descriptor deprecated

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

Deprecated: Use RemoveAdministratorRequest.ProtoReflect.Descriptor instead.

func (*RemoveAdministratorRequest) GetChannelId

func (x *RemoveAdministratorRequest) GetChannelId() int64

func (*RemoveAdministratorRequest) GetRemovedId

func (x *RemoveAdministratorRequest) GetRemovedId() int64

func (*RemoveAdministratorRequest) ProtoMessage

func (*RemoveAdministratorRequest) ProtoMessage()

func (*RemoveAdministratorRequest) ProtoReflect

func (*RemoveAdministratorRequest) Reset

func (x *RemoveAdministratorRequest) Reset()

func (*RemoveAdministratorRequest) String

func (x *RemoveAdministratorRequest) String() string

type RemoveAdministratorResponse

type RemoveAdministratorResponse 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 (*RemoveAdministratorResponse) Descriptor deprecated

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

Deprecated: Use RemoveAdministratorResponse.ProtoReflect.Descriptor instead.

func (*RemoveAdministratorResponse) GetCode

func (x *RemoveAdministratorResponse) GetCode() string

func (*RemoveAdministratorResponse) GetStatus

func (x *RemoveAdministratorResponse) GetStatus() string

func (*RemoveAdministratorResponse) ProtoMessage

func (*RemoveAdministratorResponse) ProtoMessage()

func (*RemoveAdministratorResponse) ProtoReflect

func (*RemoveAdministratorResponse) Reset

func (x *RemoveAdministratorResponse) Reset()

func (*RemoveAdministratorResponse) String

func (x *RemoveAdministratorResponse) String() string

type RemoveSubscriberRequest

type RemoveSubscriberRequest struct {
	ChannelId int64 `protobuf:"varint,1,opt,name=channelId,proto3" json:"channelId,omitempty"`
	RemovedId int64 `protobuf:"varint,2,opt,name=removedId,proto3" json:"removedId,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveSubscriberRequest) Descriptor deprecated

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

Deprecated: Use RemoveSubscriberRequest.ProtoReflect.Descriptor instead.

func (*RemoveSubscriberRequest) GetChannelId

func (x *RemoveSubscriberRequest) GetChannelId() int64

func (*RemoveSubscriberRequest) GetRemovedId

func (x *RemoveSubscriberRequest) GetRemovedId() int64

func (*RemoveSubscriberRequest) ProtoMessage

func (*RemoveSubscriberRequest) ProtoMessage()

func (*RemoveSubscriberRequest) ProtoReflect

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

func (*RemoveSubscriberRequest) Reset

func (x *RemoveSubscriberRequest) Reset()

func (*RemoveSubscriberRequest) String

func (x *RemoveSubscriberRequest) String() string

type RemoveSubscriberResponse

type RemoveSubscriberResponse 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 (*RemoveSubscriberResponse) Descriptor deprecated

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

Deprecated: Use RemoveSubscriberResponse.ProtoReflect.Descriptor instead.

func (*RemoveSubscriberResponse) GetCode

func (x *RemoveSubscriberResponse) GetCode() string

func (*RemoveSubscriberResponse) GetStatus

func (x *RemoveSubscriberResponse) GetStatus() string

func (*RemoveSubscriberResponse) ProtoMessage

func (*RemoveSubscriberResponse) ProtoMessage()

func (*RemoveSubscriberResponse) ProtoReflect

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

func (*RemoveSubscriberResponse) Reset

func (x *RemoveSubscriberResponse) Reset()

func (*RemoveSubscriberResponse) String

func (x *RemoveSubscriberResponse) String() string

type SubscriberClient

type SubscriberClient interface {
	// AddSubscriber Add a subscriber, operated by channel owner or administrator only.
	AddSubscriber(ctx context.Context, in *AddSubscriberRequest, opts ...grpc.CallOption) (*AddSubscriberResponse, error)
	// RemoveSubscriber Remove a subscriber, operated by channel owner or administrator only.
	RemoveSubscriber(ctx context.Context, in *RemoveSubscriberRequest, opts ...grpc.CallOption) (*RemoveSubscriberResponse, error)
	// GetSubscribers Get a list of subscribers to channel,
	// operated by channel owner and administrator only.
	GetSubscribers(ctx context.Context, in *GetSubscribersRequest, opts ...grpc.CallOption) (*GetSubscribersResponse, error)
	// Subscription is the API through which the user initiates a subscription to the channel.
	Subscription(ctx context.Context, in *SubscriptionRequest, opts ...grpc.CallOption) (*SubscriptionResponse, error)
	// Unsubscribe The API for user-initiated unsubscriptions.
	Unsubscribe(ctx context.Context, in *UnsubscribeRequest, opts ...grpc.CallOption) (*UnsubscribeResponse, error)
}

SubscriberClient is the client API for Subscriber 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 NewSubscriberClient

func NewSubscriberClient(cc grpc.ClientConnInterface) SubscriberClient

type SubscriberServer

type SubscriberServer interface {
	// AddSubscriber Add a subscriber, operated by channel owner or administrator only.
	AddSubscriber(context.Context, *AddSubscriberRequest) (*AddSubscriberResponse, error)
	// RemoveSubscriber Remove a subscriber, operated by channel owner or administrator only.
	RemoveSubscriber(context.Context, *RemoveSubscriberRequest) (*RemoveSubscriberResponse, error)
	// GetSubscribers Get a list of subscribers to channel,
	// operated by channel owner and administrator only.
	GetSubscribers(context.Context, *GetSubscribersRequest) (*GetSubscribersResponse, error)
	// Subscription is the API through which the user initiates a subscription to the channel.
	Subscription(context.Context, *SubscriptionRequest) (*SubscriptionResponse, error)
	// Unsubscribe The API for user-initiated unsubscriptions.
	Unsubscribe(context.Context, *UnsubscribeRequest) (*UnsubscribeResponse, error)
}

SubscriberServer is the server API for Subscriber service. All implementations should embed UnimplementedSubscriberServer for forward compatibility

type SubscriptionRequest

type SubscriptionRequest struct {
	ChannelId int64 `protobuf:"varint,1,opt,name=channelId,proto3" json:"channelId,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriptionRequest) Descriptor deprecated

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

Deprecated: Use SubscriptionRequest.ProtoReflect.Descriptor instead.

func (*SubscriptionRequest) GetChannelId

func (x *SubscriptionRequest) GetChannelId() int64

func (*SubscriptionRequest) ProtoMessage

func (*SubscriptionRequest) ProtoMessage()

func (*SubscriptionRequest) ProtoReflect

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

func (*SubscriptionRequest) Reset

func (x *SubscriptionRequest) Reset()

func (*SubscriptionRequest) String

func (x *SubscriptionRequest) String() string

type SubscriptionResponse

type SubscriptionResponse 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 (*SubscriptionResponse) Descriptor deprecated

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

Deprecated: Use SubscriptionResponse.ProtoReflect.Descriptor instead.

func (*SubscriptionResponse) GetCode

func (x *SubscriptionResponse) GetCode() string

func (*SubscriptionResponse) GetStatus

func (x *SubscriptionResponse) GetStatus() string

func (*SubscriptionResponse) ProtoMessage

func (*SubscriptionResponse) ProtoMessage()

func (*SubscriptionResponse) ProtoReflect

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

func (*SubscriptionResponse) Reset

func (x *SubscriptionResponse) Reset()

func (*SubscriptionResponse) String

func (x *SubscriptionResponse) String() string

type UnimplementedAdministrativeServer

type UnimplementedAdministrativeServer struct {
}

UnimplementedAdministrativeServer should be embedded to have forward compatible implementations.

func (UnimplementedAdministrativeServer) AddAdministrator

func (UnimplementedAdministrativeServer) ExitAdministrator

func (UnimplementedAdministrativeServer) GetAdministrators

func (UnimplementedAdministrativeServer) IsAdministrator

func (UnimplementedAdministrativeServer) IsOwner

func (UnimplementedAdministrativeServer) RemoveAdministrator

type UnimplementedBroadcastServer

type UnimplementedBroadcastServer struct {
}

UnimplementedBroadcastServer should be embedded to have forward compatible implementations.

func (UnimplementedBroadcastServer) CreateBroadcast

func (UnimplementedBroadcastServer) DeleteBroadcast

func (UnimplementedBroadcastServer) GetBroadcasts

type UnimplementedChannelServer

type UnimplementedChannelServer struct {
}

UnimplementedChannelServer should be embedded to have forward compatible implementations.

func (UnimplementedChannelServer) CreateChannel

func (UnimplementedChannelServer) DeleteChannel

func (UnimplementedChannelServer) DeleteChannels

func (UnimplementedChannelServer) GetChannels

type UnimplementedSubscriberServer

type UnimplementedSubscriberServer struct {
}

UnimplementedSubscriberServer should be embedded to have forward compatible implementations.

func (UnimplementedSubscriberServer) AddSubscriber

func (UnimplementedSubscriberServer) GetSubscribers

func (UnimplementedSubscriberServer) RemoveSubscriber

func (UnimplementedSubscriberServer) Subscription

func (UnimplementedSubscriberServer) Unsubscribe

type UnsafeAdministrativeServer

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

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

type UnsafeBroadcastServer

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

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

type UnsafeChannelServer

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

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

type UnsafeSubscriberServer

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

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

type UnsubscribeRequest

type UnsubscribeRequest struct {
	ChannelId int64 `protobuf:"varint,1,opt,name=channelId,proto3" json:"channelId,omitempty"`
	// contains filtered or unexported fields
}

func (*UnsubscribeRequest) Descriptor deprecated

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

Deprecated: Use UnsubscribeRequest.ProtoReflect.Descriptor instead.

func (*UnsubscribeRequest) GetChannelId

func (x *UnsubscribeRequest) GetChannelId() int64

func (*UnsubscribeRequest) ProtoMessage

func (*UnsubscribeRequest) ProtoMessage()

func (*UnsubscribeRequest) ProtoReflect

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

func (*UnsubscribeRequest) Reset

func (x *UnsubscribeRequest) Reset()

func (*UnsubscribeRequest) String

func (x *UnsubscribeRequest) String() string

type UnsubscribeResponse

type UnsubscribeResponse 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 (*UnsubscribeResponse) Descriptor deprecated

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

Deprecated: Use UnsubscribeResponse.ProtoReflect.Descriptor instead.

func (*UnsubscribeResponse) GetCode

func (x *UnsubscribeResponse) GetCode() string

func (*UnsubscribeResponse) GetStatus

func (x *UnsubscribeResponse) GetStatus() string

func (*UnsubscribeResponse) ProtoMessage

func (*UnsubscribeResponse) ProtoMessage()

func (*UnsubscribeResponse) ProtoReflect

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

func (*UnsubscribeResponse) Reset

func (x *UnsubscribeResponse) Reset()

func (*UnsubscribeResponse) String

func (x *UnsubscribeResponse) String() string

Jump to

Keyboard shortcuts

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