v1

package

Go to main page

Versions in this module

v1

v1.3.1

Aug 16, 2022

v1.3.0

Aug 15, 2022

v1.2.0

Aug 11, 2022

v1.1.1

Aug 10, 2022

Changes in this version

+ var File_message_api_v1_authn_proto protoreflect.FileDescriptor

+ type AuthData struct

+ CreatedNs uint64

+ WalletAddr string

+ func (*AuthData) Descriptor() ([]byte, []int)

+ func (*AuthData) ProtoMessage()

+ func (x *AuthData) GetCreatedNs() uint64

+ func (x *AuthData) GetWalletAddr() string

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

+ func (x *AuthData) Reset()

+ func (x *AuthData) String() string

+ type PublicKey struct

+ Signature *Signature

+ Timestamp uint64

+ Union isPublicKey_Union

+ func (*PublicKey) Descriptor() ([]byte, []int)

+ func (*PublicKey) ProtoMessage()

+ func (m *PublicKey) GetUnion() isPublicKey_Union

+ func (x *PublicKey) GetSecp256K1Uncompressed() *PublicKey_Secp256K1Uncompresed

+ func (x *PublicKey) GetSignature() *Signature

+ func (x *PublicKey) GetTimestamp() uint64

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

+ func (x *PublicKey) Reset()

+ func (x *PublicKey) String() string

+ type PublicKey_Secp256K1Uncompresed struct

+ Bytes []byte

+ func (*PublicKey_Secp256K1Uncompresed) Descriptor() ([]byte, []int)

+ func (*PublicKey_Secp256K1Uncompresed) ProtoMessage()

+ func (x *PublicKey_Secp256K1Uncompresed) GetBytes() []byte

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

+ func (x *PublicKey_Secp256K1Uncompresed) Reset()

+ func (x *PublicKey_Secp256K1Uncompresed) String() string

+ type PublicKey_Secp256K1Uncompressed struct

+ Secp256K1Uncompressed *PublicKey_Secp256K1Uncompresed

+ type Signature struct

+ Union isSignature_Union

+ func (*Signature) Descriptor() ([]byte, []int)

+ func (*Signature) ProtoMessage()

+ func (m *Signature) GetUnion() isSignature_Union

+ func (x *Signature) GetEcdsaCompact() *Signature_ECDSACompact

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

+ func (x *Signature) Reset()

+ func (x *Signature) String() string

+ type Signature_ECDSACompact struct

+ Bytes []byte

+ Recovery uint32

+ func (*Signature_ECDSACompact) Descriptor() ([]byte, []int)

+ func (*Signature_ECDSACompact) ProtoMessage()

+ func (x *Signature_ECDSACompact) GetBytes() []byte

+ func (x *Signature_ECDSACompact) GetRecovery() uint32

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

+ func (x *Signature_ECDSACompact) Reset()

+ func (x *Signature_ECDSACompact) String() string

+ type Signature_EcdsaCompact struct

+ EcdsaCompact *Signature_ECDSACompact

+ type Token struct

+ AuthDataBytes []byte

+ AuthDataSignature *Signature

+ IdentityKey *PublicKey

+ func (*Token) Descriptor() ([]byte, []int)

+ func (*Token) ProtoMessage()

+ func (x *Token) GetAuthDataBytes() []byte

+ func (x *Token) GetAuthDataSignature() *Signature

+ func (x *Token) GetIdentityKey() *PublicKey

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

+ func (x *Token) Reset()

+ func (x *Token) String() string

v1.1.0

Aug 8, 2022

v1.0.1

Aug 4, 2022

Changes in this version

type PublishRequest

+ Envelopes []*Envelope

+ func (x *PublishRequest) GetEnvelopes() []*Envelope

v1.0.0

Jul 28, 2022

Changes in this version

+ var File_message_api_v1_message_api_proto protoreflect.FileDescriptor

+ var MessageApi_ServiceDesc = grpc.ServiceDesc

+ var SortDirection_name = map[int32]string

+ var SortDirection_value = map[string]int32

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

+ func RegisterMessageApiHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MessageApiClient) error

+ func RegisterMessageApiHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ func RegisterMessageApiHandlerServer(ctx context.Context, mux *runtime.ServeMux, server MessageApiServer) error

+ func RegisterMessageApiServer(s grpc.ServiceRegistrar, srv MessageApiServer)

+ type Cursor struct

+ Cursor isCursor_Cursor

+ func (*Cursor) Descriptor() ([]byte, []int)

+ func (*Cursor) ProtoMessage()

+ func (m *Cursor) GetCursor() isCursor_Cursor

+ func (x *Cursor) GetIndex() *IndexCursor

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

+ func (x *Cursor) Reset()

+ func (x *Cursor) String() string

+ type Cursor_Index struct

+ Index *IndexCursor

+ type Envelope struct

+ ContentTopic string

+ Id string

+ Message []byte

+ TimestampNs uint64

+ func (*Envelope) Descriptor() ([]byte, []int)

+ func (*Envelope) ProtoMessage()

+ func (x *Envelope) GetContentTopic() string

+ func (x *Envelope) GetId() string

+ func (x *Envelope) GetMessage() []byte

+ func (x *Envelope) GetTimestampNs() uint64

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

+ func (x *Envelope) Reset()

+ func (x *Envelope) String() string

+ type IndexCursor struct

+ Digest []byte

+ SenderTimeNs uint64

+ func (*IndexCursor) Descriptor() ([]byte, []int)

+ func (*IndexCursor) ProtoMessage()

+ func (x *IndexCursor) GetDigest() []byte

+ func (x *IndexCursor) GetSenderTimeNs() uint64

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

+ func (x *IndexCursor) Reset()

+ func (x *IndexCursor) String() string

+ type MessageApiClient interface

+ Publish func(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)

+ Query func(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)

+ Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (MessageApi_SubscribeClient, error)

+ func NewMessageApiClient(cc grpc.ClientConnInterface) MessageApiClient

+ type MessageApiServer interface

+ Publish func(context.Context, *PublishRequest) (*PublishResponse, error)

+ Query func(context.Context, *QueryRequest) (*QueryResponse, error)

+ Subscribe func(*SubscribeRequest, MessageApi_SubscribeServer) error

+ type MessageApi_SubscribeClient interface

+ Recv func() (*Envelope, error)

+ type MessageApi_SubscribeServer interface

+ Send func(*Envelope) error

+ type PagingInfo struct

+ Cursor *Cursor

+ Direction SortDirection

+ Limit uint32

+ func (*PagingInfo) Descriptor() ([]byte, []int)

+ func (*PagingInfo) ProtoMessage()

+ func (x *PagingInfo) GetCursor() *Cursor

+ func (x *PagingInfo) GetDirection() SortDirection

+ func (x *PagingInfo) GetLimit() uint32

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

+ func (x *PagingInfo) Reset()

+ func (x *PagingInfo) String() string

+ type PublishRequest struct

+ ContentTopic string

+ Message []byte

+ TimestampNs uint64

+ func (*PublishRequest) Descriptor() ([]byte, []int)

+ func (*PublishRequest) ProtoMessage()

+ func (x *PublishRequest) GetContentTopic() string

+ func (x *PublishRequest) GetMessage() []byte

+ func (x *PublishRequest) GetTimestampNs() uint64

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

+ func (x *PublishRequest) Reset()

+ func (x *PublishRequest) String() string

+ type PublishResponse struct

+ func (*PublishResponse) Descriptor() ([]byte, []int)

+ func (*PublishResponse) ProtoMessage()

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

+ func (x *PublishResponse) Reset()

+ func (x *PublishResponse) String() string

+ type QueryRequest struct

+ ContentTopics []string

+ EndTimeNs uint64

+ PagingInfo *PagingInfo

+ StartTimeNs uint64

+ func (*QueryRequest) Descriptor() ([]byte, []int)

+ func (*QueryRequest) ProtoMessage()

+ func (x *QueryRequest) GetContentTopics() []string

+ func (x *QueryRequest) GetEndTimeNs() uint64

+ func (x *QueryRequest) GetPagingInfo() *PagingInfo

+ func (x *QueryRequest) GetStartTimeNs() uint64

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

+ func (x *QueryRequest) Reset()

+ func (x *QueryRequest) String() string

+ type QueryResponse struct

+ Envelopes []*Envelope

+ PagingInfo *PagingInfo

+ func (*QueryResponse) Descriptor() ([]byte, []int)

+ func (*QueryResponse) ProtoMessage()

+ func (x *QueryResponse) GetEnvelopes() []*Envelope

+ func (x *QueryResponse) GetPagingInfo() *PagingInfo

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

+ func (x *QueryResponse) Reset()

+ func (x *QueryResponse) String() string

+ type SortDirection int32

+ const SortDirection_SORT_DIRECTION_ASCENDING

+ const SortDirection_SORT_DIRECTION_DESCENDING

+ const SortDirection_SORT_DIRECTION_UNSPECIFIED

+ func (SortDirection) Descriptor() protoreflect.EnumDescriptor

+ func (SortDirection) EnumDescriptor() ([]byte, []int)

+ func (SortDirection) Type() protoreflect.EnumType

+ func (x SortDirection) Enum() *SortDirection

+ func (x SortDirection) Number() protoreflect.EnumNumber

+ func (x SortDirection) String() string

+ type SubscribeRequest struct

+ ContentTopics []string

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

+ func (*SubscribeRequest) ProtoMessage()

+ func (x *SubscribeRequest) GetContentTopics() []string

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

+ func (x *SubscribeRequest) Reset()

+ func (x *SubscribeRequest) String() string

+ type UnimplementedMessageApiServer struct

+ func (UnimplementedMessageApiServer) Publish(context.Context, *PublishRequest) (*PublishResponse, error)

+ func (UnimplementedMessageApiServer) Query(context.Context, *QueryRequest) (*QueryResponse, error)

+ func (UnimplementedMessageApiServer) Subscribe(*SubscribeRequest, MessageApi_SubscribeServer) error

+ type UnsafeMessageApiServer interface

Other modules containing this package

github.com/xmtp/proto/v3

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