messages

Documentation

Overview

Package messages contains protobuf messages.

Index

• Variables
• type DuplicateTest
  • func (*DuplicateTest) Descriptor() ([]byte, []int)
  • func (x *DuplicateTest) GetCreated() *timestamppb.Timestamp
  • func (x *DuplicateTest) GetGoroutineId() string
  • func (x *DuplicateTest) GetSequence() int64
  • func (*DuplicateTest) ProtoMessage()
  • func (x *DuplicateTest) ProtoReflect() protoreflect.Message
  • func (x *DuplicateTest) Reset()
  • func (x *DuplicateTest) String() string

Variables

var File_messages_messages_proto protoreflect.FileDescriptor

Types

type DuplicateTest

type DuplicateTest struct {

	// Unique random ID for the goroutine that published this message.
	GoroutineId string `protobuf:"bytes,1,opt,name=goroutine_id,json=goroutineId,proto3" json:"goroutine_id,omitempty"`
	// An increasing sequence number for the goroutine that published this message.
	Sequence int64 `protobuf:"varint,2,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// The time this message was created, immediately before it is published.
	Created *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created,proto3" json:"created,omitempty"`
	// contains filtered or unexported fields
}

func (*DuplicateTest) Descriptor

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

Deprecated: Use DuplicateTest.ProtoReflect.Descriptor instead.

func (*DuplicateTest) GetCreated

func (x *DuplicateTest) GetCreated() *timestamppb.Timestamp

func (*DuplicateTest) GetGoroutineId

func (x *DuplicateTest) GetGoroutineId() string

func (*DuplicateTest) GetSequence

func (x *DuplicateTest) GetSequence() int64

func (*DuplicateTest) ProtoMessage

func (*DuplicateTest) ProtoMessage()

func (*DuplicateTest) ProtoReflect

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

func (*DuplicateTest) Reset

func (x *DuplicateTest) Reset()

func (*DuplicateTest) String

func (x *DuplicateTest) String() string