idl

Documentation

Index

• Variables
• type PrototubeMessageHeader
  • func (*PrototubeMessageHeader) Descriptor() ([]byte, []int)
  • func (x *PrototubeMessageHeader) GetSchemaVersion() int32
  • func (x *PrototubeMessageHeader) GetTs() int64
  • func (x *PrototubeMessageHeader) GetUuid() []byte
  • func (x *PrototubeMessageHeader) GetVersion() int32
  • func (*PrototubeMessageHeader) ProtoMessage()
  • func (x *PrototubeMessageHeader) ProtoReflect() protoreflect.Message
  • func (x *PrototubeMessageHeader) Reset()
  • func (x *PrototubeMessageHeader) String() string

Variables

var File_prototube_proto protoreflect.FileDescriptor

Types

type PrototubeMessageHeader

type PrototubeMessageHeader struct {

	// Wire version of the Prototube message
	Version int32 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	// Schema version of the message
	SchemaVersion int32 `protobuf:"varint,2,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"`
	// Time when the message is produced since UNIX epoch
	Ts int64 `protobuf:"varint,3,opt,name=ts,proto3" json:"ts,omitempty"`
	// 16 bytes UUID
	Uuid []byte `protobuf:"bytes,4,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// contains filtered or unexported fields
}

Server side message decoration

func (*PrototubeMessageHeader) Descriptor

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

Deprecated: Use PrototubeMessageHeader.ProtoReflect.Descriptor instead.

func (*PrototubeMessageHeader) GetSchemaVersion

func (x *PrototubeMessageHeader) GetSchemaVersion() int32

func (*PrototubeMessageHeader) GetTs

func (x *PrototubeMessageHeader) GetTs() int64

func (*PrototubeMessageHeader) GetUuid

func (x *PrototubeMessageHeader) GetUuid() []byte

func (*PrototubeMessageHeader) GetVersion

func (x *PrototubeMessageHeader) GetVersion() int32

func (*PrototubeMessageHeader) ProtoMessage

func (*PrototubeMessageHeader) ProtoMessage()

func (*PrototubeMessageHeader) ProtoReflect

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

func (*PrototubeMessageHeader) Reset

func (x *PrototubeMessageHeader) Reset()

func (*PrototubeMessageHeader) String

func (x *PrototubeMessageHeader) String() string