message

Documentation

Index

• Variables
• type Message
  • func (*Message) Descriptor() ([]byte, []int)
  • func (x *Message) GetIndex() uint64
  • func (x *Message) GetKey() *anypb.Any
  • func (x *Message) GetSender() *Sender
  • func (x *Message) GetTimestamp() *timestamppb.Timestamp
  • func (x *Message) GetTopic() string
  • func (x *Message) GetValue() *anypb.Any
  • func (*Message) ProtoMessage()
  • func (x *Message) ProtoReflect() protoreflect.Message
  • func (x *Message) Reset()
  • func (x *Message) String() string
• type Sender
  • func (*Sender) Descriptor() ([]byte, []int)
  • func (x *Sender) GetId() string
  • func (x *Sender) GetKeySignature() []byte
  • func (x *Sender) GetVerified() bool
  • func (*Sender) ProtoMessage()
  • func (x *Sender) ProtoReflect() protoreflect.Message
  • func (x *Sender) Reset()
  • func (x *Sender) String() string

Variables

var File_arrebato_message_v1_message_proto protoreflect.FileDescriptor

Types

type Message

type Message struct {

	// The topic the message belongs to.
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// The location of the message within the topic. This is managed by the cluster and should not be provided when
	// producing messages.
	Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	// The client-provided message key contents.
	Key *anypb.Any `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// The client-provided message contents.
	Value *anypb.Any `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	// The time at which the message was produced. This is managed by the cluster and should not be provided when
	// producing messages.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Information about the client that produced the message.
	Sender *Sender `protobuf:"bytes,6,opt,name=sender,proto3" json:"sender,omitempty"`
	// contains filtered or unexported fields
}

The Message message describes a single message stored within a topic.

func (*Message) Descriptor

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetIndex

func (x *Message) GetIndex() uint64

func (*Message) GetKey

func (x *Message) GetKey() *anypb.Any

func (*Message) GetSender

func (x *Message) GetSender() *Sender

func (*Message) GetTimestamp

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

func (*Message) GetTopic

func (x *Message) GetTopic() string

func (*Message) GetValue

func (x *Message) GetValue() *anypb.Any

func (*Message) ProtoMessage

func (*Message) ProtoMessage()

func (*Message) ProtoReflect

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

func (*Message) Reset

func (x *Message) Reset()

func (*Message) String

func (x *Message) String() string

type Sender

type Sender struct {

	// The client identifier.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Whether or not the client provided the signed message key which has been verified by the server. This is used
	// to confirm the sender is indeed who they claim to be.
	Verified bool `protobuf:"varint,2,opt,name=verified,proto3" json:"verified,omitempty"`
	// The client-generated signature of the message key.
	KeySignature []byte `protobuf:"bytes,3,opt,name=key_signature,json=keySignature,proto3" json:"key_signature,omitempty"`
	// contains filtered or unexported fields
}

The Sender message describes a client that produced a Message.

func (*Sender) Descriptor

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

Deprecated: Use Sender.ProtoReflect.Descriptor instead.

func (*Sender) GetId

func (x *Sender) GetId() string

func (*Sender) GetKeySignature

func (x *Sender) GetKeySignature() []byte

func (*Sender) GetVerified

func (x *Sender) GetVerified() bool

func (*Sender) ProtoMessage

func (*Sender) ProtoMessage()

func (*Sender) ProtoReflect

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

func (*Sender) Reset

func (x *Sender) Reset()

func (*Sender) String

func (x *Sender) String() string