pushapi

package
v0.0.0-...-b0c4583 Latest Latest
Warning

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

 Go to latest Published: Aug 7, 2025 License: MIT Imports: 14 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrUnexpected            = errGroup.Register(errors.New("unexpected error"), uint64(ErrCodes_Unexpected))
	ErrInvalidSignature      = errGroup.Register(errors.New("invalid signature"), uint64(ErrCodes_InvalidSignature))
	ErrInvalidTopicSignature = errGroup.Register(errors.New("invalid topic signature"), uint64(ErrCodes_InvalidTopicSignature))
	ErrSpaceExists           = errGroup.Register(errors.New("space already exists"), uint64(ErrCodes_SpaceExists))
	ErrNoValidTopics         = errGroup.Register(errors.New("no valid topics"), uint64(ErrCodes_NoValidTopics))
)
View Source 
var (
	ErrCodes_name = map[int32]string{
		0:    "Unexpected",
		1:    "InvalidSignature",
		2:    "InvalidTopicSignature",
		3:    "SpaceExists",
		4:    "NoValidTopics",
		1200: "ErrorOffset",
	}
	ErrCodes_value = map[string]int32{
		"Unexpected":            0,
		"InvalidSignature":      1,
		"InvalidTopicSignature": 2,
		"SpaceExists":           3,
		"NoValidTopics":         4,
		"ErrorOffset":           1200,
	}
)

Enum value maps for ErrCodes.

View Source 
var (
	Platform_name = map[int32]string{
		0: "IOS",
		1: "Android",
	}
	Platform_value = map[string]int32{
		"IOS":     0,
		"Android": 1,
	}
)

Enum value maps for Platform.

View Source 
var File_pushclient_pushapi_protos_push_proto protoreflect.FileDescriptor

Functions

func DRPCRegisterPush 

func DRPCRegisterPush(mux drpc.Mux, impl DRPCPushServer) error

Types

type CreateSpaceRequest 

type CreateSpaceRequest struct {
	SpaceKey []byte `protobuf:"bytes,1,opt,name=spaceKey,proto3" json:"spaceKey,omitempty"`
	// spacePrivateKey.Sign(identity)
	AccountSignature []byte `protobuf:"bytes,2,opt,name=accountSignature,proto3" json:"accountSignature,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSpaceRequest) Descriptor deprecated 

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

Deprecated: Use CreateSpaceRequest.ProtoReflect.Descriptor instead.

func (*CreateSpaceRequest) GetAccountSignature 

func (x *CreateSpaceRequest) GetAccountSignature() []byte

func (*CreateSpaceRequest) GetSpaceKey 

func (x *CreateSpaceRequest) GetSpaceKey() []byte

func (*CreateSpaceRequest) MarshalToSizedBufferVT 

func (m *CreateSpaceRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CreateSpaceRequest) MarshalToVT 

func (m *CreateSpaceRequest) MarshalToVT(dAtA []byte) (int, error)

func (*CreateSpaceRequest) MarshalVT 

func (m *CreateSpaceRequest) MarshalVT() (dAtA []byte, err error)

func (*CreateSpaceRequest) ProtoMessage 

func (*CreateSpaceRequest) ProtoMessage()

func (*CreateSpaceRequest) ProtoReflect 

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

func (*CreateSpaceRequest) Reset 

func (x *CreateSpaceRequest) Reset()

func (*CreateSpaceRequest) SizeVT 

func (m *CreateSpaceRequest) SizeVT() (n int)

func (*CreateSpaceRequest) String 

func (x *CreateSpaceRequest) String() string

func (*CreateSpaceRequest) UnmarshalVT 

func (m *CreateSpaceRequest) UnmarshalVT(dAtA []byte) error

type DRPCPushClient 

type DRPCPushClient interface {
	DRPCConn() drpc.Conn

	SetToken(ctx context.Context, in *SetTokenRequest) (*Ok, error)
	RevokeToken(ctx context.Context, in *Ok) (*Ok, error)
	CreateSpace(ctx context.Context, in *CreateSpaceRequest) (*Ok, error)
	RemoveSpace(ctx context.Context, in *RemoveSpaceRequest) (*Ok, error)
	Subscriptions(ctx context.Context, in *SubscriptionsRequest) (*SubscriptionsResponse, error)
	Subscribe(ctx context.Context, in *SubscribeRequest) (*Ok, error)
	Unsubscribe(ctx context.Context, in *UnsubscribeRequest) (*Ok, error)
	SubscribeAll(ctx context.Context, in *SubscribeAllRequest) (*Ok, error)
	Notify(ctx context.Context, in *NotifyRequest) (*Ok, error)
	NotifySilent(ctx context.Context, in *NotifyRequest) (*Ok, error)
}

func NewDRPCPushClient 

func NewDRPCPushClient(cc drpc.Conn) DRPCPushClient

type DRPCPushDescription 

type DRPCPushDescription struct{}

func (DRPCPushDescription) Method 

func (DRPCPushDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool)

func (DRPCPushDescription) NumMethods 

func (DRPCPushDescription) NumMethods() int

type DRPCPushServer 

type DRPCPushServer interface {
	SetToken(context.Context, *SetTokenRequest) (*Ok, error)
	RevokeToken(context.Context, *Ok) (*Ok, error)
	CreateSpace(context.Context, *CreateSpaceRequest) (*Ok, error)
	RemoveSpace(context.Context, *RemoveSpaceRequest) (*Ok, error)
	Subscriptions(context.Context, *SubscriptionsRequest) (*SubscriptionsResponse, error)
	Subscribe(context.Context, *SubscribeRequest) (*Ok, error)
	Unsubscribe(context.Context, *UnsubscribeRequest) (*Ok, error)
	SubscribeAll(context.Context, *SubscribeAllRequest) (*Ok, error)
	Notify(context.Context, *NotifyRequest) (*Ok, error)
	NotifySilent(context.Context, *NotifyRequest) (*Ok, error)
}

type DRPCPushUnimplementedServer 

type DRPCPushUnimplementedServer struct{}

func (*DRPCPushUnimplementedServer) CreateSpace 

func (s *DRPCPushUnimplementedServer) CreateSpace(context.Context, *CreateSpaceRequest) (*Ok, error)

func (*DRPCPushUnimplementedServer) Notify 

func (s *DRPCPushUnimplementedServer) Notify(context.Context, *NotifyRequest) (*Ok, error)

func (*DRPCPushUnimplementedServer) NotifySilent 

func (s *DRPCPushUnimplementedServer) NotifySilent(context.Context, *NotifyRequest) (*Ok, error)

func (*DRPCPushUnimplementedServer) RemoveSpace 

func (s *DRPCPushUnimplementedServer) RemoveSpace(context.Context, *RemoveSpaceRequest) (*Ok, error)

func (*DRPCPushUnimplementedServer) RevokeToken 

func (s *DRPCPushUnimplementedServer) RevokeToken(context.Context, *Ok) (*Ok, error)

func (*DRPCPushUnimplementedServer) SetToken 

func (s *DRPCPushUnimplementedServer) SetToken(context.Context, *SetTokenRequest) (*Ok, error)

func (*DRPCPushUnimplementedServer) Subscribe 

func (s *DRPCPushUnimplementedServer) Subscribe(context.Context, *SubscribeRequest) (*Ok, error)

func (*DRPCPushUnimplementedServer) SubscribeAll 

func (s *DRPCPushUnimplementedServer) SubscribeAll(context.Context, *SubscribeAllRequest) (*Ok, error)

func (*DRPCPushUnimplementedServer) Subscriptions 

func (s *DRPCPushUnimplementedServer) Subscriptions(context.Context, *SubscriptionsRequest) (*SubscriptionsResponse, error)

func (*DRPCPushUnimplementedServer) Unsubscribe 

func (s *DRPCPushUnimplementedServer) Unsubscribe(context.Context, *UnsubscribeRequest) (*Ok, error)

type DRPCPush_CreateSpaceStream 

type DRPCPush_CreateSpaceStream interface {
	drpc.Stream
	SendAndClose(*Ok) error
}

type DRPCPush_NotifySilentStream 

type DRPCPush_NotifySilentStream interface {
	drpc.Stream
	SendAndClose(*Ok) error
}

type DRPCPush_NotifyStream 

type DRPCPush_NotifyStream interface {
	drpc.Stream
	SendAndClose(*Ok) error
}

type DRPCPush_RemoveSpaceStream 

type DRPCPush_RemoveSpaceStream interface {
	drpc.Stream
	SendAndClose(*Ok) error
}

type DRPCPush_RevokeTokenStream 

type DRPCPush_RevokeTokenStream interface {
	drpc.Stream
	SendAndClose(*Ok) error
}

type DRPCPush_SetTokenStream 

type DRPCPush_SetTokenStream interface {
	drpc.Stream
	SendAndClose(*Ok) error
}

type DRPCPush_SubscribeAllStream 

type DRPCPush_SubscribeAllStream interface {
	drpc.Stream
	SendAndClose(*Ok) error
}

type DRPCPush_SubscribeStream 

type DRPCPush_SubscribeStream interface {
	drpc.Stream
	SendAndClose(*Ok) error
}

type DRPCPush_SubscriptionsStream 

type DRPCPush_SubscriptionsStream interface {
	drpc.Stream
	SendAndClose(*SubscriptionsResponse) error
}

type DRPCPush_UnsubscribeStream 

type DRPCPush_UnsubscribeStream interface {
	drpc.Stream
	SendAndClose(*Ok) error
}

type ErrCodes 

type ErrCodes int32
const (
	ErrCodes_Unexpected            ErrCodes = 0
	ErrCodes_InvalidSignature      ErrCodes = 1
	ErrCodes_InvalidTopicSignature ErrCodes = 2
	ErrCodes_SpaceExists           ErrCodes = 3
	ErrCodes_NoValidTopics         ErrCodes = 4
	ErrCodes_ErrorOffset           ErrCodes = 1200
)

func (ErrCodes) Descriptor 

func (ErrCodes) Descriptor() protoreflect.EnumDescriptor

func (ErrCodes) Enum 

func (x ErrCodes) Enum() *ErrCodes

func (ErrCodes) EnumDescriptor deprecated 

func (ErrCodes) EnumDescriptor() ([]byte, []int)

Deprecated: Use ErrCodes.Descriptor instead.

func (ErrCodes) Number 

func (x ErrCodes) Number() protoreflect.EnumNumber

func (ErrCodes) String 

func (x ErrCodes) String() string

func (ErrCodes) Type 

func (ErrCodes) Type() protoreflect.EnumType

type Message 

type Message struct {
	KeyId     string `protobuf:"bytes,1,opt,name=keyId,proto3" json:"keyId,omitempty"`
	Payload   []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	Signature []byte `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetKeyId 

func (x *Message) GetKeyId() string

func (*Message) GetPayload 

func (x *Message) GetPayload() []byte

func (*Message) GetSignature 

func (x *Message) GetSignature() []byte

func (*Message) MarshalToSizedBufferVT 

func (m *Message) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Message) MarshalToVT 

func (m *Message) MarshalToVT(dAtA []byte) (int, error)

func (*Message) MarshalVT 

func (m *Message) MarshalVT() (dAtA []byte, err error)

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

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

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) SizeVT 

func (m *Message) SizeVT() (n int)

func (*Message) String 

func (x *Message) String() string

func (*Message) UnmarshalVT 

func (m *Message) UnmarshalVT(dAtA []byte) error

type NotifyRequest 

type NotifyRequest struct {
	Topics  *Topics  `protobuf:"bytes,1,opt,name=topics,proto3" json:"topics,omitempty"`
	Message *Message `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	GroupId string   `protobuf:"bytes,3,opt,name=groupId,proto3" json:"groupId,omitempty"`
	// contains filtered or unexported fields
}

func (*NotifyRequest) Descriptor deprecated 

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

Deprecated: Use NotifyRequest.ProtoReflect.Descriptor instead.

func (*NotifyRequest) GetGroupId 

func (x *NotifyRequest) GetGroupId() string

func (*NotifyRequest) GetMessage 

func (x *NotifyRequest) GetMessage() *Message

func (*NotifyRequest) GetTopics 

func (x *NotifyRequest) GetTopics() *Topics

func (*NotifyRequest) MarshalToSizedBufferVT 

func (m *NotifyRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*NotifyRequest) MarshalToVT 

func (m *NotifyRequest) MarshalToVT(dAtA []byte) (int, error)

func (*NotifyRequest) MarshalVT 

func (m *NotifyRequest) MarshalVT() (dAtA []byte, err error)

func (*NotifyRequest) ProtoMessage 

func (*NotifyRequest) ProtoMessage()

func (*NotifyRequest) ProtoReflect 

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

func (*NotifyRequest) Reset 

func (x *NotifyRequest) Reset()

func (*NotifyRequest) SizeVT 

func (m *NotifyRequest) SizeVT() (n int)

func (*NotifyRequest) String 

func (x *NotifyRequest) String() string

func (*NotifyRequest) UnmarshalVT 

func (m *NotifyRequest) UnmarshalVT(dAtA []byte) error

type Ok 

type Ok struct {
	// contains filtered or unexported fields
}

func (*Ok) Descriptor deprecated 

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

Deprecated: Use Ok.ProtoReflect.Descriptor instead.

func (*Ok) MarshalToSizedBufferVT 

func (m *Ok) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Ok) MarshalToVT 

func (m *Ok) MarshalToVT(dAtA []byte) (int, error)

func (*Ok) MarshalVT 

func (m *Ok) MarshalVT() (dAtA []byte, err error)

func (*Ok) ProtoMessage 

func (*Ok) ProtoMessage()

func (*Ok) ProtoReflect 

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

func (*Ok) Reset 

func (x *Ok) Reset()

func (*Ok) SizeVT 

func (m *Ok) SizeVT() (n int)

func (*Ok) String 

func (x *Ok) String() string

func (*Ok) UnmarshalVT 

func (m *Ok) UnmarshalVT(dAtA []byte) error

type Platform 

type Platform int32
const (
	Platform_IOS     Platform = 0
	Platform_Android Platform = 1
)

func (Platform) Descriptor 

func (Platform) Descriptor() protoreflect.EnumDescriptor

func (Platform) Enum 

func (x Platform) Enum() *Platform

func (Platform) EnumDescriptor deprecated 

func (Platform) EnumDescriptor() ([]byte, []int)

Deprecated: Use Platform.Descriptor instead.

func (Platform) Number 

func (x Platform) Number() protoreflect.EnumNumber

func (Platform) String 

func (x Platform) String() string

func (Platform) Type 

func (Platform) Type() protoreflect.EnumType

type RemoveSpaceRequest 

type RemoveSpaceRequest struct {
	SpaceKey []byte `protobuf:"bytes,1,opt,name=spaceKey,proto3" json:"spaceKey,omitempty"`
	// spacePrivateKey.Sign(identity)
	AccountSignature []byte `protobuf:"bytes,2,opt,name=accountSignature,proto3" json:"accountSignature,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveSpaceRequest) Descriptor deprecated 

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

Deprecated: Use RemoveSpaceRequest.ProtoReflect.Descriptor instead.

func (*RemoveSpaceRequest) GetAccountSignature 

func (x *RemoveSpaceRequest) GetAccountSignature() []byte

func (*RemoveSpaceRequest) GetSpaceKey 

func (x *RemoveSpaceRequest) GetSpaceKey() []byte

func (*RemoveSpaceRequest) MarshalToSizedBufferVT 

func (m *RemoveSpaceRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RemoveSpaceRequest) MarshalToVT 

func (m *RemoveSpaceRequest) MarshalToVT(dAtA []byte) (int, error)

func (*RemoveSpaceRequest) MarshalVT 

func (m *RemoveSpaceRequest) MarshalVT() (dAtA []byte, err error)

func (*RemoveSpaceRequest) ProtoMessage 

func (*RemoveSpaceRequest) ProtoMessage()

func (*RemoveSpaceRequest) ProtoReflect 

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

func (*RemoveSpaceRequest) Reset 

func (x *RemoveSpaceRequest) Reset()

func (*RemoveSpaceRequest) SizeVT 

func (m *RemoveSpaceRequest) SizeVT() (n int)

func (*RemoveSpaceRequest) String 

func (x *RemoveSpaceRequest) String() string

func (*RemoveSpaceRequest) UnmarshalVT 

func (m *RemoveSpaceRequest) UnmarshalVT(dAtA []byte) error

type SetTokenRequest 

type SetTokenRequest struct {
	Platform Platform `protobuf:"varint,1,opt,name=platform,proto3,enum=pushproto.Platform" json:"platform,omitempty"`
	Token    string   `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*SetTokenRequest) Descriptor deprecated 

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

Deprecated: Use SetTokenRequest.ProtoReflect.Descriptor instead.

func (*SetTokenRequest) GetPlatform 

func (x *SetTokenRequest) GetPlatform() Platform

func (*SetTokenRequest) GetToken 

func (x *SetTokenRequest) GetToken() string

func (*SetTokenRequest) MarshalToSizedBufferVT 

func (m *SetTokenRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SetTokenRequest) MarshalToVT 

func (m *SetTokenRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SetTokenRequest) MarshalVT 

func (m *SetTokenRequest) MarshalVT() (dAtA []byte, err error)

func (*SetTokenRequest) ProtoMessage 

func (*SetTokenRequest) ProtoMessage()

func (*SetTokenRequest) ProtoReflect 

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

func (*SetTokenRequest) Reset 

func (x *SetTokenRequest) Reset()

func (*SetTokenRequest) SizeVT 

func (m *SetTokenRequest) SizeVT() (n int)

func (*SetTokenRequest) String 

func (x *SetTokenRequest) String() string

func (*SetTokenRequest) UnmarshalVT 

func (m *SetTokenRequest) UnmarshalVT(dAtA []byte) error

type SubscribeAllRequest 

type SubscribeAllRequest struct {
	Topics *Topics `protobuf:"bytes,1,opt,name=topics,proto3" json:"topics,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeAllRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeAllRequest.ProtoReflect.Descriptor instead.

func (*SubscribeAllRequest) GetTopics 

func (x *SubscribeAllRequest) GetTopics() *Topics

func (*SubscribeAllRequest) MarshalToSizedBufferVT 

func (m *SubscribeAllRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SubscribeAllRequest) MarshalToVT 

func (m *SubscribeAllRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SubscribeAllRequest) MarshalVT 

func (m *SubscribeAllRequest) MarshalVT() (dAtA []byte, err error)

func (*SubscribeAllRequest) ProtoMessage 

func (*SubscribeAllRequest) ProtoMessage()

func (*SubscribeAllRequest) ProtoReflect 

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

func (*SubscribeAllRequest) Reset 

func (x *SubscribeAllRequest) Reset()

func (*SubscribeAllRequest) SizeVT 

func (m *SubscribeAllRequest) SizeVT() (n int)

func (*SubscribeAllRequest) String 

func (x *SubscribeAllRequest) String() string

func (*SubscribeAllRequest) UnmarshalVT 

func (m *SubscribeAllRequest) UnmarshalVT(dAtA []byte) error

type SubscribeRequest 

type SubscribeRequest struct {
	Topics *Topics `protobuf:"bytes,1,opt,name=topics,proto3" json:"topics,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.

func (*SubscribeRequest) GetTopics 

func (x *SubscribeRequest) GetTopics() *Topics

func (*SubscribeRequest) MarshalToSizedBufferVT 

func (m *SubscribeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SubscribeRequest) MarshalToVT 

func (m *SubscribeRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SubscribeRequest) MarshalVT 

func (m *SubscribeRequest) MarshalVT() (dAtA []byte, err error)

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoReflect 

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

func (*SubscribeRequest) Reset 

func (x *SubscribeRequest) Reset()

func (*SubscribeRequest) SizeVT 

func (m *SubscribeRequest) SizeVT() (n int)

func (*SubscribeRequest) String 

func (x *SubscribeRequest) String() string

func (*SubscribeRequest) UnmarshalVT 

func (m *SubscribeRequest) UnmarshalVT(dAtA []byte) error

type SubscriptionsRequest 

type SubscriptionsRequest struct {
	// contains filtered or unexported fields
}

func (*SubscriptionsRequest) Descriptor deprecated 

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

Deprecated: Use SubscriptionsRequest.ProtoReflect.Descriptor instead.

func (*SubscriptionsRequest) MarshalToSizedBufferVT 

func (m *SubscriptionsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SubscriptionsRequest) MarshalToVT 

func (m *SubscriptionsRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SubscriptionsRequest) MarshalVT 

func (m *SubscriptionsRequest) MarshalVT() (dAtA []byte, err error)

func (*SubscriptionsRequest) ProtoMessage 

func (*SubscriptionsRequest) ProtoMessage()

func (*SubscriptionsRequest) ProtoReflect 

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

func (*SubscriptionsRequest) Reset 

func (x *SubscriptionsRequest) Reset()

func (*SubscriptionsRequest) SizeVT 

func (m *SubscriptionsRequest) SizeVT() (n int)

func (*SubscriptionsRequest) String 

func (x *SubscriptionsRequest) String() string

func (*SubscriptionsRequest) UnmarshalVT 

func (m *SubscriptionsRequest) UnmarshalVT(dAtA []byte) error

type SubscriptionsResponse 

type SubscriptionsResponse struct {
	Topics *Topics `protobuf:"bytes,1,opt,name=topics,proto3" json:"topics,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriptionsResponse) Descriptor deprecated 

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

Deprecated: Use SubscriptionsResponse.ProtoReflect.Descriptor instead.

func (*SubscriptionsResponse) GetTopics 

func (x *SubscriptionsResponse) GetTopics() *Topics

func (*SubscriptionsResponse) MarshalToSizedBufferVT 

func (m *SubscriptionsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SubscriptionsResponse) MarshalToVT 

func (m *SubscriptionsResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SubscriptionsResponse) MarshalVT 

func (m *SubscriptionsResponse) MarshalVT() (dAtA []byte, err error)

func (*SubscriptionsResponse) ProtoMessage 

func (*SubscriptionsResponse) ProtoMessage()

func (*SubscriptionsResponse) ProtoReflect 

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

func (*SubscriptionsResponse) Reset 

func (x *SubscriptionsResponse) Reset()

func (*SubscriptionsResponse) SizeVT 

func (m *SubscriptionsResponse) SizeVT() (n int)

func (*SubscriptionsResponse) String 

func (x *SubscriptionsResponse) String() string

func (*SubscriptionsResponse) UnmarshalVT 

func (m *SubscriptionsResponse) UnmarshalVT(dAtA []byte) error

type Topic 

type Topic struct {
	SpaceKey []byte `protobuf:"bytes,1,opt,name=spaceKey,proto3" json:"spaceKey,omitempty"`
	Topic    string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// space private key
	Signature []byte `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*Topic) Descriptor deprecated 

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

Deprecated: Use Topic.ProtoReflect.Descriptor instead.

func (*Topic) GetSignature 

func (x *Topic) GetSignature() []byte

func (*Topic) GetSpaceKey 

func (x *Topic) GetSpaceKey() []byte

func (*Topic) GetTopic 

func (x *Topic) GetTopic() string

func (*Topic) MarshalToSizedBufferVT 

func (m *Topic) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Topic) MarshalToVT 

func (m *Topic) MarshalToVT(dAtA []byte) (int, error)

func (*Topic) MarshalVT 

func (m *Topic) MarshalVT() (dAtA []byte, err error)

func (*Topic) ProtoMessage 

func (*Topic) ProtoMessage()

func (*Topic) ProtoReflect 

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

func (*Topic) Reset 

func (x *Topic) Reset()

func (*Topic) SizeVT 

func (m *Topic) SizeVT() (n int)

func (*Topic) String 

func (x *Topic) String() string

func (*Topic) UnmarshalVT 

func (m *Topic) UnmarshalVT(dAtA []byte) error

type Topics 

type Topics struct {
	Topics []*Topic `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
	// contains filtered or unexported fields
}

func (*Topics) Descriptor deprecated 

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

Deprecated: Use Topics.ProtoReflect.Descriptor instead.

func (*Topics) GetTopics 

func (x *Topics) GetTopics() []*Topic

func (*Topics) MarshalToSizedBufferVT 

func (m *Topics) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Topics) MarshalToVT 

func (m *Topics) MarshalToVT(dAtA []byte) (int, error)

func (*Topics) MarshalVT 

func (m *Topics) MarshalVT() (dAtA []byte, err error)

func (*Topics) ProtoMessage 

func (*Topics) ProtoMessage()

func (*Topics) ProtoReflect 

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

func (*Topics) Reset 

func (x *Topics) Reset()

func (*Topics) SizeVT 

func (m *Topics) SizeVT() (n int)

func (*Topics) String 

func (x *Topics) String() string

func (*Topics) UnmarshalVT 

func (m *Topics) UnmarshalVT(dAtA []byte) error

type UnsubscribeRequest 

type UnsubscribeRequest struct {
	Topics *Topics `protobuf:"bytes,1,opt,name=topics,proto3" json:"topics,omitempty"`
	// contains filtered or unexported fields
}

func (*UnsubscribeRequest) Descriptor deprecated 

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

Deprecated: Use UnsubscribeRequest.ProtoReflect.Descriptor instead.

func (*UnsubscribeRequest) GetTopics 

func (x *UnsubscribeRequest) GetTopics() *Topics

func (*UnsubscribeRequest) MarshalToSizedBufferVT 

func (m *UnsubscribeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UnsubscribeRequest) MarshalToVT 

func (m *UnsubscribeRequest) MarshalToVT(dAtA []byte) (int, error)

func (*UnsubscribeRequest) MarshalVT 

func (m *UnsubscribeRequest) MarshalVT() (dAtA []byte, err error)

func (*UnsubscribeRequest) ProtoMessage 

func (*UnsubscribeRequest) ProtoMessage()

func (*UnsubscribeRequest) ProtoReflect 

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

func (*UnsubscribeRequest) Reset 

func (x *UnsubscribeRequest) Reset()

func (*UnsubscribeRequest) SizeVT 

func (m *UnsubscribeRequest) SizeVT() (n int)

func (*UnsubscribeRequest) String 

func (x *UnsubscribeRequest) String() string

func (*UnsubscribeRequest) UnmarshalVT 

func (m *UnsubscribeRequest) UnmarshalVT(dAtA []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.