pb

Documentation

Index

• Variables
• type AggregateMetaData
  • func (*AggregateMetaData) Descriptor() ([]byte, []int)
  • func (x *AggregateMetaData) GetBarrierEventId() string
  • func (x *AggregateMetaData) GetInstanceExists() bool
  • func (x *AggregateMetaData) GetLastEventId() string
  • func (x *AggregateMetaData) GetRevision() uint64
  • func (*AggregateMetaData) ProtoMessage()
  • func (x *AggregateMetaData) ProtoReflect() protoreflect.Message
  • func (x *AggregateMetaData) Reset()
  • func (x *AggregateMetaData) String() string
• type ProcessInstance
  • func (*ProcessInstance) Descriptor() ([]byte, []int)
  • func (x *ProcessInstance) GetData() []byte
  • func (x *ProcessInstance) GetMediaType() string
  • func (x *ProcessInstance) GetRevision() uint64
  • func (*ProcessInstance) ProtoMessage()
  • func (x *ProcessInstance) ProtoReflect() protoreflect.Message
  • func (x *ProcessInstance) Reset()
  • func (x *ProcessInstance) String() string
• type QueueMessage
  • func (*QueueMessage) Descriptor() ([]byte, []int)
  • func (x *QueueMessage) GetEnvelope() *envelopespec.Envelope
  • func (x *QueueMessage) GetFailureCount() uint64
  • func (x *QueueMessage) GetNextAttemptAt() string
  • func (x *QueueMessage) GetRevision() uint64
  • func (*QueueMessage) ProtoMessage()
  • func (x *QueueMessage) ProtoReflect() protoreflect.Message
  • func (x *QueueMessage) Reset()
  • func (x *QueueMessage) String() string

Variables

var File_github_com_dogmatiq_verity_persistence_boltpersistence_internal_pb_aggregate_proto protoreflect.FileDescriptor

var File_github_com_dogmatiq_verity_persistence_boltpersistence_internal_pb_process_proto protoreflect.FileDescriptor

var File_github_com_dogmatiq_verity_persistence_boltpersistence_internal_pb_queue_proto protoreflect.FileDescriptor

Types

type AggregateMetaData

type AggregateMetaData struct {
	Revision       uint64 `protobuf:"varint,1,opt,name=revision,proto3" json:"revision,omitempty"`
	InstanceExists bool   `protobuf:"varint,2,opt,name=instance_exists,json=instanceExists,proto3" json:"instance_exists,omitempty"`
	LastEventId    string `protobuf:"bytes,3,opt,name=last_event_id,json=lastEventId,proto3" json:"last_event_id,omitempty"`
	BarrierEventId string `protobuf:"bytes,4,opt,name=barrier_event_id,json=barrierEventId,proto3" json:"barrier_event_id,omitempty"`
	// contains filtered or unexported fields
}

AggregateMetaData is a protocol buffers representation of persistence.AggregateMetaData.

func (*AggregateMetaData) Descriptor

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

Deprecated: Use AggregateMetaData.ProtoReflect.Descriptor instead.

func (*AggregateMetaData) GetBarrierEventId

func (x *AggregateMetaData) GetBarrierEventId() string

func (*AggregateMetaData) GetInstanceExists

func (x *AggregateMetaData) GetInstanceExists() bool

func (*AggregateMetaData) GetLastEventId

func (x *AggregateMetaData) GetLastEventId() string

func (*AggregateMetaData) GetRevision

func (x *AggregateMetaData) GetRevision() uint64

func (*AggregateMetaData) ProtoMessage

func (*AggregateMetaData) ProtoMessage()

func (*AggregateMetaData) ProtoReflect

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

func (*AggregateMetaData) Reset

func (x *AggregateMetaData) Reset()

func (*AggregateMetaData) String

func (x *AggregateMetaData) String() string

type ProcessInstance

type ProcessInstance struct {
	Revision  uint64 `protobuf:"varint,1,opt,name=revision,proto3" json:"revision,omitempty"`
	MediaType string `protobuf:"bytes,2,opt,name=media_type,json=mediaType,proto3" json:"media_type,omitempty"`
	Data      []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

ProcessInstance is a protocol buffers representation of persistence.ProcessInstance.

func (*ProcessInstance) Descriptor

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

Deprecated: Use ProcessInstance.ProtoReflect.Descriptor instead.

func (*ProcessInstance) GetData

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

func (*ProcessInstance) GetMediaType

func (x *ProcessInstance) GetMediaType() string

func (*ProcessInstance) GetRevision

func (x *ProcessInstance) GetRevision() uint64

func (*ProcessInstance) ProtoMessage

func (*ProcessInstance) ProtoMessage()

func (*ProcessInstance) ProtoReflect

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

func (*ProcessInstance) Reset

func (x *ProcessInstance) Reset()

func (*ProcessInstance) String

func (x *ProcessInstance) String() string

type QueueMessage

type QueueMessage struct {
	Revision      uint64                 `protobuf:"varint,1,opt,name=revision,proto3" json:"revision,omitempty"`
	FailureCount  uint64                 `protobuf:"varint,2,opt,name=failure_count,json=failureCount,proto3" json:"failure_count,omitempty"`
	NextAttemptAt string                 `protobuf:"bytes,3,opt,name=next_attempt_at,json=nextAttemptAt,proto3" json:"next_attempt_at,omitempty"`
	Envelope      *envelopespec.Envelope `protobuf:"bytes,15,opt,name=Envelope,proto3" json:"Envelope,omitempty"`
	// contains filtered or unexported fields
}

QueueMessage is a protocol buffers representation of a persistence.QueueMessage.

func (*QueueMessage) Descriptor

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

Deprecated: Use QueueMessage.ProtoReflect.Descriptor instead.

func (*QueueMessage) GetEnvelope

func (x *QueueMessage) GetEnvelope() *envelopespec.Envelope

func (*QueueMessage) GetFailureCount

func (x *QueueMessage) GetFailureCount() uint64

func (*QueueMessage) GetNextAttemptAt

func (x *QueueMessage) GetNextAttemptAt() string

func (*QueueMessage) GetRevision

func (x *QueueMessage) GetRevision() uint64

func (*QueueMessage) ProtoMessage

func (*QueueMessage) ProtoMessage()

func (*QueueMessage) ProtoReflect

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

func (*QueueMessage) Reset

func (x *QueueMessage) Reset()

func (*QueueMessage) String

func (x *QueueMessage) String() string