Documentation
¶
Index ¶
- Constants
- Variables
- type WakuMessage
- func (*WakuMessage) Descriptor() ([]byte, []int)deprecated
- func (x *WakuMessage) GetContentTopic() string
- func (x *WakuMessage) GetEphemeral() bool
- func (x *WakuMessage) GetMeta() []byte
- func (x *WakuMessage) GetPayload() []byte
- func (x *WakuMessage) GetRateLimitProof() []byte
- func (x *WakuMessage) GetTimestamp() int64
- func (x *WakuMessage) GetVersion() uint32
- func (msg *WakuMessage) Hash(pubsubTopic string) []byte
- func (m *WakuMessage) MarshalJSON() ([]byte, error)
- func (*WakuMessage) ProtoMessage()
- func (x *WakuMessage) ProtoReflect() protoreflect.Message
- func (x *WakuMessage) Reset()
- func (x *WakuMessage) String() string
- func (m *WakuMessage) UnmarshalJSON(data []byte) error
- func (msg *WakuMessage) Validate() error
Constants ¶
View Source
const MaxMetaAttrLength = 64
Variables ¶
View Source
var File_message_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type WakuMessage ¶
type WakuMessage struct {
Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
ContentTopic string `protobuf:"bytes,2,opt,name=content_topic,json=contentTopic,proto3" json:"content_topic,omitempty"`
Version *uint32 `protobuf:"varint,3,opt,name=version,proto3,oneof" json:"version,omitempty"`
Timestamp *int64 `protobuf:"zigzag64,10,opt,name=timestamp,proto3,oneof" json:"timestamp,omitempty"`
Meta []byte `protobuf:"bytes,11,opt,name=meta,proto3,oneof" json:"meta,omitempty"`
Ephemeral *bool `protobuf:"varint,31,opt,name=ephemeral,proto3,oneof" json:"ephemeral,omitempty"`
RateLimitProof []byte `protobuf:"bytes,21,opt,name=rate_limit_proof,json=rateLimitProof,proto3,oneof" json:"rate_limit_proof,omitempty"`
// contains filtered or unexported fields
}
func Unmarshal ¶ added in v0.9.0
func Unmarshal(data []byte) (*WakuMessage, error)
func (*WakuMessage) Descriptor
deprecated
func (*WakuMessage) Descriptor() ([]byte, []int)
Deprecated: Use WakuMessage.ProtoReflect.Descriptor instead.
func (*WakuMessage) GetContentTopic ¶
func (x *WakuMessage) GetContentTopic() string
func (*WakuMessage) GetEphemeral ¶
func (x *WakuMessage) GetEphemeral() bool
func (*WakuMessage) GetMeta ¶ added in v0.5.2
func (x *WakuMessage) GetMeta() []byte
func (*WakuMessage) GetPayload ¶
func (x *WakuMessage) GetPayload() []byte
func (*WakuMessage) GetRateLimitProof ¶
func (x *WakuMessage) GetRateLimitProof() []byte
func (*WakuMessage) GetTimestamp ¶
func (x *WakuMessage) GetTimestamp() int64
func (*WakuMessage) GetVersion ¶
func (x *WakuMessage) GetVersion() uint32
func (*WakuMessage) Hash ¶
func (msg *WakuMessage) Hash(pubsubTopic string) []byte
Hash calculates the hash of a waku message
func (*WakuMessage) MarshalJSON ¶ added in v0.9.0
func (m *WakuMessage) MarshalJSON() ([]byte, error)
func (*WakuMessage) ProtoMessage ¶
func (*WakuMessage) ProtoMessage()
func (*WakuMessage) ProtoReflect ¶ added in v0.5.0
func (x *WakuMessage) ProtoReflect() protoreflect.Message
func (*WakuMessage) Reset ¶
func (x *WakuMessage) Reset()
func (*WakuMessage) String ¶
func (x *WakuMessage) String() string
func (*WakuMessage) UnmarshalJSON ¶ added in v0.9.0
func (m *WakuMessage) UnmarshalJSON(data []byte) error
func (*WakuMessage) Validate ¶ added in v0.9.0
func (msg *WakuMessage) Validate() error
Source Files
Click to show internal directories.
Click to hide internal directories.