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
}

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
}