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 ¶
- Variables
- func RegisterAdministrativeHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterAdministrativeHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AdministrativeClient) error
- func RegisterAdministrativeHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterAdministrativeHandlerServer(ctx context.Context, mux *runtime.ServeMux, server AdministrativeServer) error
- func RegisterAdministrativeServer(s grpc.ServiceRegistrar, srv AdministrativeServer)
- func RegisterBroadcastHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterBroadcastHandlerClient(ctx context.Context, mux *runtime.ServeMux, client BroadcastClient) error
- func RegisterBroadcastHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterBroadcastHandlerServer(ctx context.Context, mux *runtime.ServeMux, server BroadcastServer) error
- func RegisterBroadcastServer(s grpc.ServiceRegistrar, srv BroadcastServer)
- func RegisterChannelHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterChannelHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ChannelClient) error
- func RegisterChannelHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterChannelHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ChannelServer) error
- func RegisterChannelServer(s grpc.ServiceRegistrar, srv ChannelServer)
- func RegisterSubscriberHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterSubscriberHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SubscriberClient) error
- func RegisterSubscriberHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterSubscriberHandlerServer(ctx context.Context, mux *runtime.ServeMux, server SubscriberServer) error
- func RegisterSubscriberServer(s grpc.ServiceRegistrar, srv SubscriberServer)
- type AddAdministratorRequest
- func (*AddAdministratorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AddAdministratorRequest) GetAddedId() int64
- func (x *AddAdministratorRequest) GetChannelId() int64
- func (*AddAdministratorRequest) ProtoMessage()
- func (x *AddAdministratorRequest) ProtoReflect() protoreflect.Message
- func (x *AddAdministratorRequest) Reset()
- func (x *AddAdministratorRequest) String() string
- type AddAdministratorResponse
- func (*AddAdministratorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AddAdministratorResponse) GetCode() string
- func (x *AddAdministratorResponse) GetStatus() string
- func (*AddAdministratorResponse) ProtoMessage()
- func (x *AddAdministratorResponse) ProtoReflect() protoreflect.Message
- func (x *AddAdministratorResponse) Reset()
- func (x *AddAdministratorResponse) String() string
- type AddSubscriberRequest
- func (*AddSubscriberRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AddSubscriberRequest) GetChannelId() int64
- func (x *AddSubscriberRequest) GetSubscriberId() int64
- func (*AddSubscriberRequest) ProtoMessage()
- func (x *AddSubscriberRequest) ProtoReflect() protoreflect.Message
- func (x *AddSubscriberRequest) Reset()
- func (x *AddSubscriberRequest) String() string
- type AddSubscriberResponse
- func (*AddSubscriberResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AddSubscriberResponse) GetCode() string
- func (x *AddSubscriberResponse) GetStatus() string
- func (*AddSubscriberResponse) ProtoMessage()
- func (x *AddSubscriberResponse) ProtoReflect() protoreflect.Message
- func (x *AddSubscriberResponse) Reset()
- func (x *AddSubscriberResponse) String() string
- type AdministrativeClient
- type AdministrativeServer
- type AdminsData
- func (*AdminsData) Descriptor() ([]byte, []int)deprecated
- func (x *AdminsData) GetAdmin() *actor.ActorData
- func (x *AdminsData) GetIsOwner() bool
- func (*AdminsData) ProtoMessage()
- func (x *AdminsData) ProtoReflect() protoreflect.Message
- func (x *AdminsData) Reset()
- func (x *AdminsData) String() string
- type BroadcastClient
- type BroadcastData
- func (*BroadcastData) Descriptor() ([]byte, []int)deprecated
- func (x *BroadcastData) GetAdminId() int64
- func (x *BroadcastData) GetChannelId() int64
- func (x *BroadcastData) GetCid() string
- func (x *BroadcastData) GetId() int64
- func (*BroadcastData) ProtoMessage()
- func (x *BroadcastData) ProtoReflect() protoreflect.Message
- func (x *BroadcastData) Reset()
- func (x *BroadcastData) String() string
- type BroadcastServer
- type ChannelClient
- type ChannelData
- func (*ChannelData) Descriptor() ([]byte, []int)deprecated
- func (x *ChannelData) GetChannel() *actor.ActorData
- func (x *ChannelData) GetChannelId() int64
- func (*ChannelData) ProtoMessage()
- func (x *ChannelData) ProtoReflect() protoreflect.Message
- func (x *ChannelData) Reset()
- func (x *ChannelData) String() string
- type ChannelServer
- type CreateBroadcastRequest
- func (*CreateBroadcastRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateBroadcastRequest) GetChannelId() int64
- func (x *CreateBroadcastRequest) GetCid() string
- func (x *CreateBroadcastRequest) GetType() string
- func (*CreateBroadcastRequest) ProtoMessage()
- func (x *CreateBroadcastRequest) ProtoReflect() protoreflect.Message
- func (x *CreateBroadcastRequest) Reset()
- func (x *CreateBroadcastRequest) String() string
- type CreateBroadcastResponse
- func (*CreateBroadcastResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateBroadcastResponse) GetCode() string
- func (x *CreateBroadcastResponse) GetStatus() string
- func (*CreateBroadcastResponse) ProtoMessage()
- func (x *CreateBroadcastResponse) ProtoReflect() protoreflect.Message
- func (x *CreateBroadcastResponse) Reset()
- func (x *CreateBroadcastResponse) String() string
- type CreateChannelRequest
- func (*CreateChannelRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateChannelRequest) GetPreferredUsername() string
- func (*CreateChannelRequest) ProtoMessage()
- func (x *CreateChannelRequest) ProtoReflect() protoreflect.Message
- func (x *CreateChannelRequest) Reset()
- func (x *CreateChannelRequest) String() string
- type CreateChannelResponse
- func (*CreateChannelResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateChannelResponse) GetCode() string
- func (x *CreateChannelResponse) GetStatus() string
- func (*CreateChannelResponse) ProtoMessage()
- func (x *CreateChannelResponse) ProtoReflect() protoreflect.Message
- func (x *CreateChannelResponse) Reset()
- func (x *CreateChannelResponse) String() string
- type DeleteBroadcastRequest
- func (*DeleteBroadcastRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteBroadcastRequest) GetBroadcastId() int64
- func (x *DeleteBroadcastRequest) GetChannelId() int64
- func (*DeleteBroadcastRequest) ProtoMessage()
- func (x *DeleteBroadcastRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteBroadcastRequest) Reset()
- func (x *DeleteBroadcastRequest) String() string
- type DeleteBroadcastResponse
- func (*DeleteBroadcastResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteBroadcastResponse) GetCode() string
- func (x *DeleteBroadcastResponse) GetStatus() string
- func (*DeleteBroadcastResponse) ProtoMessage()
- func (x *DeleteBroadcastResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteBroadcastResponse) Reset()
- func (x *DeleteBroadcastResponse) String() string
- type DeleteChannelRequest
- func (*DeleteChannelRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteChannelRequest) GetChannelId() int64
- func (*DeleteChannelRequest) ProtoMessage()
- func (x *DeleteChannelRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteChannelRequest) Reset()
- func (x *DeleteChannelRequest) String() string
- type DeleteChannelResponse
- func (*DeleteChannelResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteChannelResponse) GetCode() string
- func (x *DeleteChannelResponse) GetStatus() string
- func (*DeleteChannelResponse) ProtoMessage()
- func (x *DeleteChannelResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteChannelResponse) Reset()
- func (x *DeleteChannelResponse) String() string
- type DeleteChannelsRequest
- func (*DeleteChannelsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteChannelsRequest) GetAccountId() int64
- func (*DeleteChannelsRequest) ProtoMessage()
- func (x *DeleteChannelsRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteChannelsRequest) Reset()
- func (x *DeleteChannelsRequest) String() string
- type DeleteChannelsResponse
- func (*DeleteChannelsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteChannelsResponse) GetCode() string
- func (x *DeleteChannelsResponse) GetStatus() string
- func (*DeleteChannelsResponse) ProtoMessage()
- func (x *DeleteChannelsResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteChannelsResponse) Reset()
- func (x *DeleteChannelsResponse) String() string
- type ExitAdministratorRequest
- func (*ExitAdministratorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExitAdministratorRequest) GetAdminId() int64
- func (x *ExitAdministratorRequest) GetChannelId() int64
- func (*ExitAdministratorRequest) ProtoMessage()
- func (x *ExitAdministratorRequest) ProtoReflect() protoreflect.Message
- func (x *ExitAdministratorRequest) Reset()
- func (x *ExitAdministratorRequest) String() string
- type ExitAdministratorResponse
- func (*ExitAdministratorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ExitAdministratorResponse) GetCode() string
- func (x *ExitAdministratorResponse) GetStatus() string
- func (*ExitAdministratorResponse) ProtoMessage()
- func (x *ExitAdministratorResponse) ProtoReflect() protoreflect.Message
- func (x *ExitAdministratorResponse) Reset()
- func (x *ExitAdministratorResponse) String() string
- type GetAdministratorsRequest
- func (*GetAdministratorsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetAdministratorsRequest) GetChannelId() string
- func (*GetAdministratorsRequest) ProtoMessage()
- func (x *GetAdministratorsRequest) ProtoReflect() protoreflect.Message
- func (x *GetAdministratorsRequest) Reset()
- func (x *GetAdministratorsRequest) String() string
- type GetAdministratorsResponse
- func (*GetAdministratorsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetAdministratorsResponse) GetAdmins() []*AdminsData
- func (x *GetAdministratorsResponse) GetCode() string
- func (*GetAdministratorsResponse) ProtoMessage()
- func (x *GetAdministratorsResponse) ProtoReflect() protoreflect.Message
- func (x *GetAdministratorsResponse) Reset()
- func (x *GetAdministratorsResponse) String() string
- type GetBroadcastsRequest
- func (*GetBroadcastsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetBroadcastsRequest) GetChannelId() string
- func (*GetBroadcastsRequest) ProtoMessage()
- func (x *GetBroadcastsRequest) ProtoReflect() protoreflect.Message
- func (x *GetBroadcastsRequest) Reset()
- func (x *GetBroadcastsRequest) String() string
- type GetBroadcastsResponse
- func (*GetBroadcastsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetBroadcastsResponse) GetBroadcasts() []*BroadcastData
- func (x *GetBroadcastsResponse) GetCode() string
- func (*GetBroadcastsResponse) ProtoMessage()
- func (x *GetBroadcastsResponse) ProtoReflect() protoreflect.Message
- func (x *GetBroadcastsResponse) Reset()
- func (x *GetBroadcastsResponse) String() string
- type GetChannelsResponse
- func (*GetChannelsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetChannelsResponse) GetChannels() []*ChannelData
- func (x *GetChannelsResponse) GetCode() string
- func (x *GetChannelsResponse) GetStatus() string
- func (*GetChannelsResponse) ProtoMessage()
- func (x *GetChannelsResponse) ProtoReflect() protoreflect.Message
- func (x *GetChannelsResponse) Reset()
- func (x *GetChannelsResponse) String() string
- type GetPrivateKeyByActorIdRequest
- func (*GetPrivateKeyByActorIdRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetPrivateKeyByActorIdRequest) GetActorId() int64
- func (*GetPrivateKeyByActorIdRequest) ProtoMessage()
- func (x *GetPrivateKeyByActorIdRequest) ProtoReflect() protoreflect.Message
- func (x *GetPrivateKeyByActorIdRequest) Reset()
- func (x *GetPrivateKeyByActorIdRequest) String() string
- type GetPrivateKeyByActorIdResponse
- func (*GetPrivateKeyByActorIdResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetPrivateKeyByActorIdResponse) GetPrivateKey() string
- func (*GetPrivateKeyByActorIdResponse) ProtoMessage()
- func (x *GetPrivateKeyByActorIdResponse) ProtoReflect() protoreflect.Message
- func (x *GetPrivateKeyByActorIdResponse) Reset()
- func (x *GetPrivateKeyByActorIdResponse) String() string
- type GetSubscribersRequest
- func (*GetSubscribersRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetSubscribersRequest) GetAdminId() int64
- func (x *GetSubscribersRequest) GetChannelId() string
- func (*GetSubscribersRequest) ProtoMessage()
- func (x *GetSubscribersRequest) ProtoReflect() protoreflect.Message
- func (x *GetSubscribersRequest) Reset()
- func (x *GetSubscribersRequest) String() string
- type GetSubscribersResponse
- func (*GetSubscribersResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetSubscribersResponse) GetCode() string
- func (x *GetSubscribersResponse) GetStatus() string
- func (x *GetSubscribersResponse) GetSubscriber() []*actor.ActorData
- func (*GetSubscribersResponse) ProtoMessage()
- func (x *GetSubscribersResponse) ProtoReflect() protoreflect.Message
- func (x *GetSubscribersResponse) Reset()
- func (x *GetSubscribersResponse) String() string
- type IsAdministratorRequest
- func (*IsAdministratorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *IsAdministratorRequest) GetAdminId() int64
- func (x *IsAdministratorRequest) GetChannelId() int64
- func (*IsAdministratorRequest) ProtoMessage()
- func (x *IsAdministratorRequest) ProtoReflect() protoreflect.Message
- func (x *IsAdministratorRequest) Reset()
- func (x *IsAdministratorRequest) String() string
- type IsAdministratorResponse
- func (*IsAdministratorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *IsAdministratorResponse) GetIsAdministrator() bool
- func (*IsAdministratorResponse) ProtoMessage()
- func (x *IsAdministratorResponse) ProtoReflect() protoreflect.Message
- func (x *IsAdministratorResponse) Reset()
- func (x *IsAdministratorResponse) String() string
- type IsOwnerRequest
- func (*IsOwnerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *IsOwnerRequest) GetChannelId() int64
- func (x *IsOwnerRequest) GetOwnerId() int64
- func (*IsOwnerRequest) ProtoMessage()
- func (x *IsOwnerRequest) ProtoReflect() protoreflect.Message
- func (x *IsOwnerRequest) Reset()
- func (x *IsOwnerRequest) String() string
- type IsOwnerResponse
- type RemoveAdministratorRequest
- func (*RemoveAdministratorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveAdministratorRequest) GetChannelId() int64
- func (x *RemoveAdministratorRequest) GetRemovedId() int64
- func (*RemoveAdministratorRequest) ProtoMessage()
- func (x *RemoveAdministratorRequest) ProtoReflect() protoreflect.Message
- func (x *RemoveAdministratorRequest) Reset()
- func (x *RemoveAdministratorRequest) String() string
- type RemoveAdministratorResponse
- func (*RemoveAdministratorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveAdministratorResponse) GetCode() string
- func (x *RemoveAdministratorResponse) GetStatus() string
- func (*RemoveAdministratorResponse) ProtoMessage()
- func (x *RemoveAdministratorResponse) ProtoReflect() protoreflect.Message
- func (x *RemoveAdministratorResponse) Reset()
- func (x *RemoveAdministratorResponse) String() string
- type RemoveSubscriberRequest
- func (*RemoveSubscriberRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveSubscriberRequest) GetChannelId() int64
- func (x *RemoveSubscriberRequest) GetRemovedId() int64
- func (*RemoveSubscriberRequest) ProtoMessage()
- func (x *RemoveSubscriberRequest) ProtoReflect() protoreflect.Message
- func (x *RemoveSubscriberRequest) Reset()
- func (x *RemoveSubscriberRequest) String() string
- type RemoveSubscriberResponse
- func (*RemoveSubscriberResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveSubscriberResponse) GetCode() string
- func (x *RemoveSubscriberResponse) GetStatus() string
- func (*RemoveSubscriberResponse) ProtoMessage()
- func (x *RemoveSubscriberResponse) ProtoReflect() protoreflect.Message
- func (x *RemoveSubscriberResponse) Reset()
- func (x *RemoveSubscriberResponse) String() string
- type SubscriberClient
- type SubscriberServer
- type SubscriptionRequest
- func (*SubscriptionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SubscriptionRequest) GetChannelId() int64
- func (*SubscriptionRequest) ProtoMessage()
- func (x *SubscriptionRequest) ProtoReflect() protoreflect.Message
- func (x *SubscriptionRequest) Reset()
- func (x *SubscriptionRequest) String() string
- type SubscriptionResponse
- func (*SubscriptionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SubscriptionResponse) GetCode() string
- func (x *SubscriptionResponse) GetStatus() string
- func (*SubscriptionResponse) ProtoMessage()
- func (x *SubscriptionResponse) ProtoReflect() protoreflect.Message
- func (x *SubscriptionResponse) Reset()
- func (x *SubscriptionResponse) String() string
- type UnimplementedAdministrativeServer
- func (UnimplementedAdministrativeServer) AddAdministrator(context.Context, *AddAdministratorRequest) (*AddAdministratorResponse, error)
- func (UnimplementedAdministrativeServer) ExitAdministrator(context.Context, *ExitAdministratorRequest) (*ExitAdministratorResponse, error)
- func (UnimplementedAdministrativeServer) GetAdministrators(context.Context, *GetAdministratorsRequest) (*GetAdministratorsResponse, error)
- func (UnimplementedAdministrativeServer) IsAdministrator(context.Context, *IsAdministratorRequest) (*IsAdministratorResponse, error)
- func (UnimplementedAdministrativeServer) IsOwner(context.Context, *IsOwnerRequest) (*IsOwnerResponse, error)
- func (UnimplementedAdministrativeServer) RemoveAdministrator(context.Context, *RemoveAdministratorRequest) (*RemoveAdministratorResponse, error)
- type UnimplementedBroadcastServer
- func (UnimplementedBroadcastServer) CreateBroadcast(context.Context, *CreateBroadcastRequest) (*CreateBroadcastResponse, error)
- func (UnimplementedBroadcastServer) DeleteBroadcast(context.Context, *DeleteBroadcastRequest) (*DeleteBroadcastResponse, error)
- func (UnimplementedBroadcastServer) GetBroadcasts(context.Context, *GetBroadcastsRequest) (*GetBroadcastsResponse, error)
- type UnimplementedChannelServer
- func (UnimplementedChannelServer) CreateChannel(context.Context, *CreateChannelRequest) (*CreateChannelResponse, error)
- func (UnimplementedChannelServer) DeleteChannel(context.Context, *DeleteChannelRequest) (*DeleteChannelResponse, error)
- func (UnimplementedChannelServer) DeleteChannels(context.Context, *DeleteChannelsRequest) (*DeleteChannelsResponse, error)
- func (UnimplementedChannelServer) GetChannels(context.Context, *emptypb.Empty) (*GetChannelsResponse, error)
- func (UnimplementedChannelServer) GetPrivateKeyByActorId(context.Context, *GetPrivateKeyByActorIdRequest) (*GetPrivateKeyByActorIdResponse, error)
- type UnimplementedSubscriberServer
- func (UnimplementedSubscriberServer) AddSubscriber(context.Context, *AddSubscriberRequest) (*AddSubscriberResponse, error)
- func (UnimplementedSubscriberServer) GetSubscribers(context.Context, *GetSubscribersRequest) (*GetSubscribersResponse, error)
- func (UnimplementedSubscriberServer) RemoveSubscriber(context.Context, *RemoveSubscriberRequest) (*RemoveSubscriberResponse, error)
- func (UnimplementedSubscriberServer) Subscription(context.Context, *SubscriptionRequest) (*SubscriptionResponse, error)
- func (UnimplementedSubscriberServer) Unsubscribe(context.Context, *UnsubscribeRequest) (*UnsubscribeResponse, error)
- type UnsafeAdministrativeServer
- type UnsafeBroadcastServer
- type UnsafeChannelServer
- type UnsafeSubscriberServer
- type UnsubscribeRequest
- func (*UnsubscribeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UnsubscribeRequest) GetChannelId() int64
- func (*UnsubscribeRequest) ProtoMessage()
- func (x *UnsubscribeRequest) ProtoReflect() protoreflect.Message
- func (x *UnsubscribeRequest) Reset()
- func (x *UnsubscribeRequest) String() string
- type UnsubscribeResponse
- func (*UnsubscribeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UnsubscribeResponse) GetCode() string
- func (x *UnsubscribeResponse) GetStatus() string
- func (*UnsubscribeResponse) ProtoMessage()
- func (x *UnsubscribeResponse) ProtoReflect() protoreflect.Message
- func (x *UnsubscribeResponse) Reset()
- func (x *UnsubscribeResponse) String() string
Constants ¶
This section is empty.
Variables ¶
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)
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)
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)
var File_proto_v1alpha1_channel_administrative_proto protoreflect.FileDescriptor
var File_proto_v1alpha1_channel_broadcast_proto protoreflect.FileDescriptor
var File_proto_v1alpha1_channel_channel_proto protoreflect.FileDescriptor
var File_proto_v1alpha1_channel_subscriber_proto protoreflect.FileDescriptor
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.
func NewAdministrativeClient ¶
func NewAdministrativeClient(cc grpc.ClientConnInterface) AdministrativeClient
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 ¶
type BroadcastServer interface { CreateBroadcast(context.Context, *CreateBroadcastRequest) (*CreateBroadcastResponse, error) GetBroadcasts(context.Context, *GetBroadcastsRequest) (*GetBroadcastsResponse, error) DeleteBroadcast(context.Context, *DeleteBroadcastRequest) (*DeleteBroadcastResponse, error) }
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 (x *ExitAdministratorResponse) ProtoReflect() protoreflect.Message
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 (x *GetAdministratorsResponse) ProtoReflect() protoreflect.Message
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 (x *GetPrivateKeyByActorIdRequest) ProtoReflect() protoreflect.Message
func (*GetPrivateKeyByActorIdRequest) Reset ¶
func (x *GetPrivateKeyByActorIdRequest) Reset()
func (*GetPrivateKeyByActorIdRequest) String ¶
func (x *GetPrivateKeyByActorIdRequest) String() 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 (x *GetPrivateKeyByActorIdResponse) ProtoReflect() protoreflect.Message
func (*GetPrivateKeyByActorIdResponse) Reset ¶
func (x *GetPrivateKeyByActorIdResponse) Reset()
func (*GetPrivateKeyByActorIdResponse) String ¶
func (x *GetPrivateKeyByActorIdResponse) String() 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 (x *RemoveAdministratorRequest) ProtoReflect() protoreflect.Message
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 (x *RemoveAdministratorResponse) ProtoReflect() protoreflect.Message
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) AddAdministrator(context.Context, *AddAdministratorRequest) (*AddAdministratorResponse, error)
func (UnimplementedAdministrativeServer) ExitAdministrator ¶
func (UnimplementedAdministrativeServer) ExitAdministrator(context.Context, *ExitAdministratorRequest) (*ExitAdministratorResponse, error)
func (UnimplementedAdministrativeServer) GetAdministrators ¶
func (UnimplementedAdministrativeServer) GetAdministrators(context.Context, *GetAdministratorsRequest) (*GetAdministratorsResponse, error)
func (UnimplementedAdministrativeServer) IsAdministrator ¶
func (UnimplementedAdministrativeServer) IsAdministrator(context.Context, *IsAdministratorRequest) (*IsAdministratorResponse, error)
func (UnimplementedAdministrativeServer) IsOwner ¶
func (UnimplementedAdministrativeServer) IsOwner(context.Context, *IsOwnerRequest) (*IsOwnerResponse, error)
func (UnimplementedAdministrativeServer) RemoveAdministrator ¶
func (UnimplementedAdministrativeServer) RemoveAdministrator(context.Context, *RemoveAdministratorRequest) (*RemoveAdministratorResponse, error)
type UnimplementedBroadcastServer ¶
type UnimplementedBroadcastServer struct { }
UnimplementedBroadcastServer should be embedded to have forward compatible implementations.
func (UnimplementedBroadcastServer) CreateBroadcast ¶
func (UnimplementedBroadcastServer) CreateBroadcast(context.Context, *CreateBroadcastRequest) (*CreateBroadcastResponse, error)
func (UnimplementedBroadcastServer) DeleteBroadcast ¶
func (UnimplementedBroadcastServer) DeleteBroadcast(context.Context, *DeleteBroadcastRequest) (*DeleteBroadcastResponse, error)
func (UnimplementedBroadcastServer) GetBroadcasts ¶
func (UnimplementedBroadcastServer) GetBroadcasts(context.Context, *GetBroadcastsRequest) (*GetBroadcastsResponse, error)
type UnimplementedChannelServer ¶
type UnimplementedChannelServer struct { }
UnimplementedChannelServer should be embedded to have forward compatible implementations.
func (UnimplementedChannelServer) CreateChannel ¶
func (UnimplementedChannelServer) CreateChannel(context.Context, *CreateChannelRequest) (*CreateChannelResponse, error)
func (UnimplementedChannelServer) DeleteChannel ¶
func (UnimplementedChannelServer) DeleteChannel(context.Context, *DeleteChannelRequest) (*DeleteChannelResponse, error)
func (UnimplementedChannelServer) DeleteChannels ¶
func (UnimplementedChannelServer) DeleteChannels(context.Context, *DeleteChannelsRequest) (*DeleteChannelsResponse, error)
func (UnimplementedChannelServer) GetChannels ¶
func (UnimplementedChannelServer) GetChannels(context.Context, *emptypb.Empty) (*GetChannelsResponse, error)
func (UnimplementedChannelServer) GetPrivateKeyByActorId ¶
func (UnimplementedChannelServer) GetPrivateKeyByActorId(context.Context, *GetPrivateKeyByActorIdRequest) (*GetPrivateKeyByActorIdResponse, error)
type UnimplementedSubscriberServer ¶
type UnimplementedSubscriberServer struct { }
UnimplementedSubscriberServer should be embedded to have forward compatible implementations.
func (UnimplementedSubscriberServer) AddSubscriber ¶
func (UnimplementedSubscriberServer) AddSubscriber(context.Context, *AddSubscriberRequest) (*AddSubscriberResponse, error)
func (UnimplementedSubscriberServer) GetSubscribers ¶
func (UnimplementedSubscriberServer) GetSubscribers(context.Context, *GetSubscribersRequest) (*GetSubscribersResponse, error)
func (UnimplementedSubscriberServer) RemoveSubscriber ¶
func (UnimplementedSubscriberServer) RemoveSubscriber(context.Context, *RemoveSubscriberRequest) (*RemoveSubscriberResponse, error)
func (UnimplementedSubscriberServer) Subscription ¶
func (UnimplementedSubscriberServer) Subscription(context.Context, *SubscriptionRequest) (*SubscriptionResponse, error)
func (UnimplementedSubscriberServer) Unsubscribe ¶
func (UnimplementedSubscriberServer) Unsubscribe(context.Context, *UnsubscribeRequest) (*UnsubscribeResponse, error)
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