pubmessage

Documentation

Index

• Variables
• type Message
  • func NewMessage(peerID peer.ID, pktInner *PubMessageInner) *Message
  • func (m *Message) GetAuthenticated() bool
  • func (m *Message) GetData() []byte
  • func (m *Message) GetFrom() peer.ID
• type PubMessageInner
  • func ExtractAndVerify(msg *peer.SignedMsg) (*PubMessageInner, crypto.PubKey, peer.ID, error)
  • func NewPubMessage(channelID string, privKey crypto.PrivKey, hashType hash.HashType, data []byte) (*peer.SignedMsg, *PubMessageInner, error)
  • func (m *PubMessageInner) CloneMessageVT() protobuf_go_lite.CloneMessage
  • func (m *PubMessageInner) CloneVT() *PubMessageInner
  • func (this *PubMessageInner) EqualMessageVT(thatMsg any) bool
  • func (this *PubMessageInner) EqualVT(that *PubMessageInner) bool
  • func (x *PubMessageInner) GetChannel() string
  • func (x *PubMessageInner) GetData() []byte
  • func (x *PubMessageInner) GetTimestamp() *timestamppb.Timestamp
  • func (x *PubMessageInner) MarshalJSON() ([]byte, error)
  • func (x *PubMessageInner) MarshalProtoJSON(s *json.MarshalState)
  • func (x *PubMessageInner) MarshalProtoText() string
  • func (m *PubMessageInner) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *PubMessageInner) MarshalToVT(dAtA []byte) (int, error)
  • func (m *PubMessageInner) MarshalVT() (dAtA []byte, err error)
  • func (*PubMessageInner) ProtoMessage()
  • func (x *PubMessageInner) Reset()
  • func (m *PubMessageInner) SizeVT() (n int)
  • func (x *PubMessageInner) String() string
  • func (x *PubMessageInner) UnmarshalJSON(b []byte) error
  • func (x *PubMessageInner) UnmarshalProtoJSON(s *json.UnmarshalState)
  • func (m *PubMessageInner) UnmarshalVT(dAtA []byte) error
  • func (i *PubMessageInner) Validate() error

Variables

var ErrInvalidChannelID = errors.New("invalid or empty channel id on pubmessage")

ErrInvalidChannelID is returned for an invalid inner channel ID.

Types

type Message

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

Message fulfills the Message type with a PubMessageInner.

func NewMessage

func NewMessage(peerID peer.ID, pktInner *PubMessageInner) *Message

NewMessage constructs a new Message object

func (*Message) GetAuthenticated

func (m *Message) GetAuthenticated() bool

GetAuthenticated indicates if the signature is valid.

func (*Message) GetData

func (m *Message) GetData() []byte

GetData returns the Message data.

func (*Message) GetFrom

func (m *Message) GetFrom() peer.ID

GetFrom returns the peer ID of the sender.

type PubMessageInner

type PubMessageInner struct {

	// Data is the message data.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// Channel is the channel.
	Channel string `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel,omitempty"`
	// Timestamp is the message timestamp.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

PubMessageInner is the signed inner portion of the message.

func ExtractAndVerify

func ExtractAndVerify(msg *peer.SignedMsg) (*PubMessageInner, crypto.PubKey, peer.ID, error)

ExtractAndVerify extracts the inner message from a signed message.

func NewPubMessage

func NewPubMessage(
	channelID string,
	privKey crypto.PrivKey,
	hashType hash.HashType,
	data []byte,
) (*peer.SignedMsg, *PubMessageInner, error)

NewPubMessage constructs/signs/encodes a new pub-message and inner message.

Uses time.Now() for the timestamp: not deterministic.

func (*PubMessageInner) CloneMessageVT

func (m *PubMessageInner) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*PubMessageInner) CloneVT

func (m *PubMessageInner) CloneVT() *PubMessageInner

func (*PubMessageInner) EqualMessageVT

func (this *PubMessageInner) EqualMessageVT(thatMsg any) bool

func (*PubMessageInner) EqualVT

func (this *PubMessageInner) EqualVT(that *PubMessageInner) bool

func (*PubMessageInner) GetChannel

func (x *PubMessageInner) GetChannel() string

func (*PubMessageInner) GetData

func (x *PubMessageInner) GetData() []byte

func (*PubMessageInner) GetTimestamp

func (x *PubMessageInner) GetTimestamp() *timestamppb.Timestamp

func (*PubMessageInner) MarshalJSON

func (x *PubMessageInner) MarshalJSON() ([]byte, error)

MarshalJSON marshals the PubMessageInner to JSON.

func (*PubMessageInner) MarshalProtoJSON

func (x *PubMessageInner) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the PubMessageInner message to JSON.

func (*PubMessageInner) MarshalProtoText

func (x *PubMessageInner) MarshalProtoText() string

func (*PubMessageInner) MarshalToSizedBufferVT

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

func (*PubMessageInner) MarshalToVT

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

func (*PubMessageInner) MarshalVT

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

func (*PubMessageInner) ProtoMessage

func (*PubMessageInner) ProtoMessage()

func (*PubMessageInner) Reset

func (x *PubMessageInner) Reset()

func (*PubMessageInner) SizeVT

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

func (*PubMessageInner) String

func (x *PubMessageInner) String() string

func (*PubMessageInner) UnmarshalJSON

func (x *PubMessageInner) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the PubMessageInner from JSON.

func (*PubMessageInner) UnmarshalProtoJSON

func (x *PubMessageInner) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the PubMessageInner message from JSON.

func (*PubMessageInner) UnmarshalVT

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

func (*PubMessageInner) Validate

func (i *PubMessageInner) Validate() error

Validate checks the inner data.