Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

messages

package

Go to main page

Versions in this module

v0

v0.4.1

Nov 1, 2019

v0.4.0

Mar 16, 2019

v0.3.0

Sep 21, 2018

v0.2.0

Jun 11, 2018

v0.1.0

Mar 26, 2018

Changes in this version

+ var CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult_name = map[int32]string

+ var CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult_value = map[string]int32

+ var DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult_name = map[int32]string

+ var DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult_value = map[string]int32

+ var NotHandled_NotHandledReason_name = map[int32]string

+ var NotHandled_NotHandledReason_value = map[string]int32

+ var OperationResult_name = map[int32]string

+ var OperationResult_value = map[string]int32

+ var PersistentSubscriptionNakEvents_NakAction_name = map[int32]string

+ var PersistentSubscriptionNakEvents_NakAction_value = map[string]int32

+ var ReadAllEventsCompleted_ReadAllResult_name = map[int32]string

+ var ReadAllEventsCompleted_ReadAllResult_value = map[string]int32

+ var ReadEventCompleted_ReadEventResult_name = map[int32]string

+ var ReadEventCompleted_ReadEventResult_value = map[string]int32

+ var ReadStreamEventsCompleted_ReadStreamResult_name = map[int32]string

+ var ReadStreamEventsCompleted_ReadStreamResult_value = map[string]int32

+ var ScavengeDatabaseCompleted_ScavengeResult_name = map[int32]string

+ var ScavengeDatabaseCompleted_ScavengeResult_value = map[string]int32

+ var SubscriptionDropped_SubscriptionDropReason_name = map[int32]string

+ var SubscriptionDropped_SubscriptionDropReason_value = map[string]int32

+ var UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult_name = map[int32]string

+ var UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult_value = map[string]int32

+ var VNodeState_name = map[int]string

+ type ClusterInfoDto struct

+ Members []*MemberInfoDto

+ type ConnectToPersistentSubscription struct

+ AllowedInFlightMessages *int32

+ EventStreamId *string

+ SubscriptionId *string

+ XXX_unrecognized []byte

+ func (*ConnectToPersistentSubscription) Descriptor() ([]byte, []int)

+ func (*ConnectToPersistentSubscription) ProtoMessage()

+ func (m *ConnectToPersistentSubscription) GetAllowedInFlightMessages() int32

+ func (m *ConnectToPersistentSubscription) GetEventStreamId() string

+ func (m *ConnectToPersistentSubscription) GetSubscriptionId() string

+ func (m *ConnectToPersistentSubscription) Reset()

+ func (m *ConnectToPersistentSubscription) String() string

+ type CreatePersistentSubscription struct

+ BufferSize *int32

+ CheckpointAfterTime *int32

+ CheckpointMaxCount *int32

+ CheckpointMinCount *int32

+ EventStreamId *string

+ LiveBufferSize *int32

+ MaxRetryCount *int32

+ MessageTimeoutMilliseconds *int32

+ NamedConsumerStrategy *string

+ PreferRoundRobin *bool

+ ReadBatchSize *int32

+ RecordStatistics *bool

+ ResolveLinkTos *bool

+ StartFrom *int32

+ SubscriberMaxCount *int32

+ SubscriptionGroupName *string

+ XXX_unrecognized []byte

+ func (*CreatePersistentSubscription) Descriptor() ([]byte, []int)

+ func (*CreatePersistentSubscription) ProtoMessage()

+ func (m *CreatePersistentSubscription) GetBufferSize() int32

+ func (m *CreatePersistentSubscription) GetCheckpointAfterTime() int32

+ func (m *CreatePersistentSubscription) GetCheckpointMaxCount() int32

+ func (m *CreatePersistentSubscription) GetCheckpointMinCount() int32

+ func (m *CreatePersistentSubscription) GetEventStreamId() string

+ func (m *CreatePersistentSubscription) GetLiveBufferSize() int32

+ func (m *CreatePersistentSubscription) GetMaxRetryCount() int32

+ func (m *CreatePersistentSubscription) GetMessageTimeoutMilliseconds() int32

+ func (m *CreatePersistentSubscription) GetNamedConsumerStrategy() string

+ func (m *CreatePersistentSubscription) GetPreferRoundRobin() bool

+ func (m *CreatePersistentSubscription) GetReadBatchSize() int32

+ func (m *CreatePersistentSubscription) GetRecordStatistics() bool

+ func (m *CreatePersistentSubscription) GetResolveLinkTos() bool

+ func (m *CreatePersistentSubscription) GetStartFrom() int32

+ func (m *CreatePersistentSubscription) GetSubscriberMaxCount() int32

+ func (m *CreatePersistentSubscription) GetSubscriptionGroupName() string

+ func (m *CreatePersistentSubscription) Reset()

+ func (m *CreatePersistentSubscription) String() string

+ type CreatePersistentSubscriptionCompleted struct

+ Reason *string

+ Result *CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult

+ XXX_unrecognized []byte

+ func (*CreatePersistentSubscriptionCompleted) Descriptor() ([]byte, []int)

+ func (*CreatePersistentSubscriptionCompleted) ProtoMessage()

+ func (m *CreatePersistentSubscriptionCompleted) GetReason() string

+ func (m *CreatePersistentSubscriptionCompleted) GetResult() CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult

+ func (m *CreatePersistentSubscriptionCompleted) Reset()

+ func (m *CreatePersistentSubscriptionCompleted) String() string

+ type CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult int32

+ const CreatePersistentSubscriptionCompleted_AccessDenied

+ const CreatePersistentSubscriptionCompleted_AlreadyExists

+ const CreatePersistentSubscriptionCompleted_Fail

+ const CreatePersistentSubscriptionCompleted_Success

+ const Default_CreatePersistentSubscriptionCompleted_Result

+ func (CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult) EnumDescriptor() ([]byte, []int)

+ func (x *CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult) UnmarshalJSON(data []byte) error

+ func (x CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult) Enum() *CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult

+ func (x CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult) String() string

+ type DeletePersistentSubscription struct

+ EventStreamId *string

+ SubscriptionGroupName *string

+ XXX_unrecognized []byte

+ func (*DeletePersistentSubscription) Descriptor() ([]byte, []int)

+ func (*DeletePersistentSubscription) ProtoMessage()

+ func (m *DeletePersistentSubscription) GetEventStreamId() string

+ func (m *DeletePersistentSubscription) GetSubscriptionGroupName() string

+ func (m *DeletePersistentSubscription) Reset()

+ func (m *DeletePersistentSubscription) String() string

+ type DeletePersistentSubscriptionCompleted struct

+ Reason *string

+ Result *DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult

+ XXX_unrecognized []byte

+ func (*DeletePersistentSubscriptionCompleted) Descriptor() ([]byte, []int)

+ func (*DeletePersistentSubscriptionCompleted) ProtoMessage()

+ func (m *DeletePersistentSubscriptionCompleted) GetReason() string

+ func (m *DeletePersistentSubscriptionCompleted) GetResult() DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult

+ func (m *DeletePersistentSubscriptionCompleted) Reset()

+ func (m *DeletePersistentSubscriptionCompleted) String() string

+ type DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult int32

+ const Default_DeletePersistentSubscriptionCompleted_Result

+ const DeletePersistentSubscriptionCompleted_AccessDenied

+ const DeletePersistentSubscriptionCompleted_DoesNotExist

+ const DeletePersistentSubscriptionCompleted_Fail

+ const DeletePersistentSubscriptionCompleted_Success

+ func (DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult) EnumDescriptor() ([]byte, []int)

+ func (x *DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult) UnmarshalJSON(data []byte) error

+ func (x DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult) Enum() *DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult

+ func (x DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult) String() string

+ type DeleteStream struct

+ EventStreamId *string

+ ExpectedVersion *int32

+ HardDelete *bool

+ RequireMaster *bool

+ XXX_unrecognized []byte

+ func (*DeleteStream) Descriptor() ([]byte, []int)

+ func (*DeleteStream) ProtoMessage()

+ func (m *DeleteStream) GetEventStreamId() string

+ func (m *DeleteStream) GetExpectedVersion() int32

+ func (m *DeleteStream) GetHardDelete() bool

+ func (m *DeleteStream) GetRequireMaster() bool

+ func (m *DeleteStream) Reset()

+ func (m *DeleteStream) String() string

+ type DeleteStreamCompleted struct

+ CommitPosition *int64

+ Message *string

+ PreparePosition *int64

+ Result *OperationResult

+ XXX_unrecognized []byte

+ func (*DeleteStreamCompleted) Descriptor() ([]byte, []int)

+ func (*DeleteStreamCompleted) ProtoMessage()

+ func (m *DeleteStreamCompleted) GetCommitPosition() int64

+ func (m *DeleteStreamCompleted) GetMessage() string

+ func (m *DeleteStreamCompleted) GetPreparePosition() int64

+ func (m *DeleteStreamCompleted) GetResult() OperationResult

+ func (m *DeleteStreamCompleted) Reset()

+ func (m *DeleteStreamCompleted) String() string

+ type EventRecord struct

+ Created *int64

+ CreatedEpoch *int64

+ Data []byte

+ DataContentType *int32

+ EventId []byte

+ EventNumber *int32

+ EventStreamId *string

+ EventType *string

+ Metadata []byte

+ MetadataContentType *int32

+ XXX_unrecognized []byte

+ func (*EventRecord) Descriptor() ([]byte, []int)

+ func (*EventRecord) ProtoMessage()

+ func (m *EventRecord) GetCreated() int64

+ func (m *EventRecord) GetCreatedEpoch() int64

+ func (m *EventRecord) GetData() []byte

+ func (m *EventRecord) GetDataContentType() int32

+ func (m *EventRecord) GetEventId() []byte

+ func (m *EventRecord) GetEventNumber() int32

+ func (m *EventRecord) GetEventStreamId() string

+ func (m *EventRecord) GetEventType() string

+ func (m *EventRecord) GetMetadata() []byte

+ func (m *EventRecord) GetMetadataContentType() int32

+ func (m *EventRecord) Reset()

+ func (m *EventRecord) String() string

+ type MemberInfoDto struct

+ ChaserCheckpoint int64

+ EpochId uuid.UUID

+ EpochNumber int

+ EpochPosition int64

+ ExternalHttpIp string

+ ExternalHttpPort int

+ ExternalSecureTcpPort int

+ ExternalTcpIp string

+ ExternalTcpPort int

+ InstanceId uuid.UUID

+ InternalHttpIp string

+ InternalHttpPort int

+ InternalSecureTcpPort int

+ InternalTcpIp string

+ InternalTcpPort int

+ IsAlive bool

+ LastCommitPosition int64

+ NodePriority int

+ State VNodeState

+ Timestamp time.Time

+ WriterCheckpoint int64

+ func (x MemberInfoDto) String() string

+ type NewEvent struct

+ Data []byte

+ DataContentType *int32

+ EventId []byte

+ EventType *string

+ Metadata []byte

+ MetadataContentType *int32

+ XXX_unrecognized []byte

+ func (*NewEvent) Descriptor() ([]byte, []int)

+ func (*NewEvent) ProtoMessage()

+ func (m *NewEvent) GetData() []byte

+ func (m *NewEvent) GetDataContentType() int32

+ func (m *NewEvent) GetEventId() []byte

+ func (m *NewEvent) GetEventType() string

+ func (m *NewEvent) GetMetadata() []byte

+ func (m *NewEvent) GetMetadataContentType() int32

+ func (m *NewEvent) Reset()

+ func (m *NewEvent) String() string

+ type NotHandled struct

+ AdditionalInfo []byte

+ Reason *NotHandled_NotHandledReason

+ XXX_unrecognized []byte

+ func (*NotHandled) Descriptor() ([]byte, []int)

+ func (*NotHandled) ProtoMessage()

+ func (m *NotHandled) GetAdditionalInfo() []byte

+ func (m *NotHandled) GetReason() NotHandled_NotHandledReason

+ func (m *NotHandled) Reset()

+ func (m *NotHandled) String() string

+ type NotHandled_MasterInfo struct

+ ExternalHttpAddress *string

+ ExternalHttpPort *int32

+ ExternalSecureTcpAddress *string

+ ExternalSecureTcpPort *int32

+ ExternalTcpAddress *string

+ ExternalTcpPort *int32

+ XXX_unrecognized []byte

+ func (*NotHandled_MasterInfo) Descriptor() ([]byte, []int)

+ func (*NotHandled_MasterInfo) ProtoMessage()

+ func (m *NotHandled_MasterInfo) GetExternalHttpAddress() string

+ func (m *NotHandled_MasterInfo) GetExternalHttpPort() int32

+ func (m *NotHandled_MasterInfo) GetExternalSecureTcpAddress() string

+ func (m *NotHandled_MasterInfo) GetExternalSecureTcpPort() int32

+ func (m *NotHandled_MasterInfo) GetExternalTcpAddress() string

+ func (m *NotHandled_MasterInfo) GetExternalTcpPort() int32

+ func (m *NotHandled_MasterInfo) Reset()

+ func (m *NotHandled_MasterInfo) String() string

+ type NotHandled_NotHandledReason int32

+ const NotHandled_NotMaster

+ const NotHandled_NotReady

+ const NotHandled_TooBusy

+ func (NotHandled_NotHandledReason) EnumDescriptor() ([]byte, []int)

+ func (x *NotHandled_NotHandledReason) UnmarshalJSON(data []byte) error

+ func (x NotHandled_NotHandledReason) Enum() *NotHandled_NotHandledReason

+ func (x NotHandled_NotHandledReason) String() string

+ type OperationResult int32

+ const OperationResult_AccessDenied

+ const OperationResult_CommitTimeout

+ const OperationResult_ForwardTimeout

+ const OperationResult_InvalidTransaction

+ const OperationResult_PrepareTimeout

+ const OperationResult_StreamDeleted

+ const OperationResult_Success

+ const OperationResult_WrongExpectedVersion

+ func (OperationResult) EnumDescriptor() ([]byte, []int)

+ func (x *OperationResult) UnmarshalJSON(data []byte) error

+ func (x OperationResult) Enum() *OperationResult

+ func (x OperationResult) String() string

+ type PersistentSubscriptionAckEvents struct

+ ProcessedEventIds [][]byte

+ SubscriptionId *string

+ XXX_unrecognized []byte

+ func (*PersistentSubscriptionAckEvents) Descriptor() ([]byte, []int)

+ func (*PersistentSubscriptionAckEvents) ProtoMessage()

+ func (m *PersistentSubscriptionAckEvents) GetProcessedEventIds() [][]byte

+ func (m *PersistentSubscriptionAckEvents) GetSubscriptionId() string

+ func (m *PersistentSubscriptionAckEvents) Reset()

+ func (m *PersistentSubscriptionAckEvents) String() string

+ type PersistentSubscriptionConfirmation struct

+ LastCommitPosition *int64

+ LastEventNumber *int32

+ SubscriptionId *string

+ XXX_unrecognized []byte

+ func (*PersistentSubscriptionConfirmation) Descriptor() ([]byte, []int)

+ func (*PersistentSubscriptionConfirmation) ProtoMessage()

+ func (m *PersistentSubscriptionConfirmation) GetLastCommitPosition() int64

+ func (m *PersistentSubscriptionConfirmation) GetLastEventNumber() int32

+ func (m *PersistentSubscriptionConfirmation) GetSubscriptionId() string

+ func (m *PersistentSubscriptionConfirmation) Reset()

+ func (m *PersistentSubscriptionConfirmation) String() string

+ type PersistentSubscriptionNakEvents struct

+ Action *PersistentSubscriptionNakEvents_NakAction

+ Message *string

+ ProcessedEventIds [][]byte

+ SubscriptionId *string

+ XXX_unrecognized []byte

+ func (*PersistentSubscriptionNakEvents) Descriptor() ([]byte, []int)

+ func (*PersistentSubscriptionNakEvents) ProtoMessage()

+ func (m *PersistentSubscriptionNakEvents) GetAction() PersistentSubscriptionNakEvents_NakAction

+ func (m *PersistentSubscriptionNakEvents) GetMessage() string

+ func (m *PersistentSubscriptionNakEvents) GetProcessedEventIds() [][]byte

+ func (m *PersistentSubscriptionNakEvents) GetSubscriptionId() string

+ func (m *PersistentSubscriptionNakEvents) Reset()

+ func (m *PersistentSubscriptionNakEvents) String() string

+ type PersistentSubscriptionNakEvents_NakAction int32

+ const Default_PersistentSubscriptionNakEvents_Action

+ const PersistentSubscriptionNakEvents_Park

+ const PersistentSubscriptionNakEvents_Retry

+ const PersistentSubscriptionNakEvents_Skip

+ const PersistentSubscriptionNakEvents_Stop

+ const PersistentSubscriptionNakEvents_Unknown

+ func (PersistentSubscriptionNakEvents_NakAction) EnumDescriptor() ([]byte, []int)

+ func (x *PersistentSubscriptionNakEvents_NakAction) UnmarshalJSON(data []byte) error

+ func (x PersistentSubscriptionNakEvents_NakAction) Enum() *PersistentSubscriptionNakEvents_NakAction

+ func (x PersistentSubscriptionNakEvents_NakAction) String() string

+ type PersistentSubscriptionStreamEventAppeared struct

+ Event *ResolvedIndexedEvent

+ XXX_unrecognized []byte

+ func (*PersistentSubscriptionStreamEventAppeared) Descriptor() ([]byte, []int)

+ func (*PersistentSubscriptionStreamEventAppeared) ProtoMessage()

+ func (m *PersistentSubscriptionStreamEventAppeared) GetEvent() *ResolvedIndexedEvent

+ func (m *PersistentSubscriptionStreamEventAppeared) Reset()

+ func (m *PersistentSubscriptionStreamEventAppeared) String() string

+ type ReadAllEvents struct

+ CommitPosition *int64

+ MaxCount *int32

+ PreparePosition *int64

+ RequireMaster *bool

+ ResolveLinkTos *bool

+ XXX_unrecognized []byte

+ func (*ReadAllEvents) Descriptor() ([]byte, []int)

+ func (*ReadAllEvents) ProtoMessage()

+ func (m *ReadAllEvents) GetCommitPosition() int64

+ func (m *ReadAllEvents) GetMaxCount() int32

+ func (m *ReadAllEvents) GetPreparePosition() int64

+ func (m *ReadAllEvents) GetRequireMaster() bool

+ func (m *ReadAllEvents) GetResolveLinkTos() bool

+ func (m *ReadAllEvents) Reset()

+ func (m *ReadAllEvents) String() string

+ type ReadAllEventsCompleted struct

+ CommitPosition *int64

+ Error *string

+ Events []*ResolvedEvent

+ NextCommitPosition *int64

+ NextPreparePosition *int64

+ PreparePosition *int64

+ Result *ReadAllEventsCompleted_ReadAllResult

+ XXX_unrecognized []byte

+ func (*ReadAllEventsCompleted) Descriptor() ([]byte, []int)

+ func (*ReadAllEventsCompleted) ProtoMessage()

+ func (m *ReadAllEventsCompleted) GetCommitPosition() int64

+ func (m *ReadAllEventsCompleted) GetError() string

+ func (m *ReadAllEventsCompleted) GetEvents() []*ResolvedEvent

+ func (m *ReadAllEventsCompleted) GetNextCommitPosition() int64

+ func (m *ReadAllEventsCompleted) GetNextPreparePosition() int64

+ func (m *ReadAllEventsCompleted) GetPreparePosition() int64

+ func (m *ReadAllEventsCompleted) GetResult() ReadAllEventsCompleted_ReadAllResult

+ func (m *ReadAllEventsCompleted) Reset()

+ func (m *ReadAllEventsCompleted) String() string

+ type ReadAllEventsCompleted_ReadAllResult int32

+ const Default_ReadAllEventsCompleted_Result

+ const ReadAllEventsCompleted_AccessDenied

+ const ReadAllEventsCompleted_Error

+ const ReadAllEventsCompleted_NotModified

+ const ReadAllEventsCompleted_Success

+ func (ReadAllEventsCompleted_ReadAllResult) EnumDescriptor() ([]byte, []int)

+ func (x *ReadAllEventsCompleted_ReadAllResult) UnmarshalJSON(data []byte) error

+ func (x ReadAllEventsCompleted_ReadAllResult) Enum() *ReadAllEventsCompleted_ReadAllResult

+ func (x ReadAllEventsCompleted_ReadAllResult) String() string

+ type ReadEvent struct

+ EventNumber *int32

+ EventStreamId *string

+ RequireMaster *bool

+ ResolveLinkTos *bool

+ XXX_unrecognized []byte

+ func (*ReadEvent) Descriptor() ([]byte, []int)

+ func (*ReadEvent) ProtoMessage()

+ func (m *ReadEvent) GetEventNumber() int32

+ func (m *ReadEvent) GetEventStreamId() string

+ func (m *ReadEvent) GetRequireMaster() bool

+ func (m *ReadEvent) GetResolveLinkTos() bool

+ func (m *ReadEvent) Reset()

+ func (m *ReadEvent) String() string

+ type ReadEventCompleted struct

+ Error *string

+ Event *ResolvedIndexedEvent

+ Result *ReadEventCompleted_ReadEventResult

+ XXX_unrecognized []byte

+ func (*ReadEventCompleted) Descriptor() ([]byte, []int)

+ func (*ReadEventCompleted) ProtoMessage()

+ func (m *ReadEventCompleted) GetError() string

+ func (m *ReadEventCompleted) GetEvent() *ResolvedIndexedEvent

+ func (m *ReadEventCompleted) GetResult() ReadEventCompleted_ReadEventResult

+ func (m *ReadEventCompleted) Reset()

+ func (m *ReadEventCompleted) String() string

+ type ReadEventCompleted_ReadEventResult int32

+ const ReadEventCompleted_AccessDenied

+ const ReadEventCompleted_Error

+ const ReadEventCompleted_NoStream

+ const ReadEventCompleted_NotFound

+ const ReadEventCompleted_StreamDeleted

+ const ReadEventCompleted_Success

+ func (ReadEventCompleted_ReadEventResult) EnumDescriptor() ([]byte, []int)

+ func (x *ReadEventCompleted_ReadEventResult) UnmarshalJSON(data []byte) error

+ func (x ReadEventCompleted_ReadEventResult) Enum() *ReadEventCompleted_ReadEventResult

+ func (x ReadEventCompleted_ReadEventResult) String() string

+ type ReadStreamEvents struct

+ EventStreamId *string

+ FromEventNumber *int32

+ MaxCount *int32

+ RequireMaster *bool

+ ResolveLinkTos *bool

+ XXX_unrecognized []byte

+ func (*ReadStreamEvents) Descriptor() ([]byte, []int)

+ func (*ReadStreamEvents) ProtoMessage()

+ func (m *ReadStreamEvents) GetEventStreamId() string

+ func (m *ReadStreamEvents) GetFromEventNumber() int32

+ func (m *ReadStreamEvents) GetMaxCount() int32

+ func (m *ReadStreamEvents) GetRequireMaster() bool

+ func (m *ReadStreamEvents) GetResolveLinkTos() bool

+ func (m *ReadStreamEvents) Reset()

+ func (m *ReadStreamEvents) String() string

+ type ReadStreamEventsCompleted struct

+ Error *string

+ Events []*ResolvedIndexedEvent

+ IsEndOfStream *bool

+ LastCommitPosition *int64

+ LastEventNumber *int32

+ NextEventNumber *int32

+ Result *ReadStreamEventsCompleted_ReadStreamResult

+ XXX_unrecognized []byte

+ func (*ReadStreamEventsCompleted) Descriptor() ([]byte, []int)

+ func (*ReadStreamEventsCompleted) ProtoMessage()

+ func (m *ReadStreamEventsCompleted) GetError() string

+ func (m *ReadStreamEventsCompleted) GetEvents() []*ResolvedIndexedEvent

+ func (m *ReadStreamEventsCompleted) GetIsEndOfStream() bool

+ func (m *ReadStreamEventsCompleted) GetLastCommitPosition() int64

+ func (m *ReadStreamEventsCompleted) GetLastEventNumber() int32

+ func (m *ReadStreamEventsCompleted) GetNextEventNumber() int32

+ func (m *ReadStreamEventsCompleted) GetResult() ReadStreamEventsCompleted_ReadStreamResult

+ func (m *ReadStreamEventsCompleted) Reset()

+ func (m *ReadStreamEventsCompleted) String() string

+ type ReadStreamEventsCompleted_ReadStreamResult int32

+ const ReadStreamEventsCompleted_AccessDenied

+ const ReadStreamEventsCompleted_Error

+ const ReadStreamEventsCompleted_NoStream

+ const ReadStreamEventsCompleted_NotModified

+ const ReadStreamEventsCompleted_StreamDeleted

+ const ReadStreamEventsCompleted_Success

+ func (ReadStreamEventsCompleted_ReadStreamResult) EnumDescriptor() ([]byte, []int)

+ func (x *ReadStreamEventsCompleted_ReadStreamResult) UnmarshalJSON(data []byte) error

+ func (x ReadStreamEventsCompleted_ReadStreamResult) Enum() *ReadStreamEventsCompleted_ReadStreamResult

+ func (x ReadStreamEventsCompleted_ReadStreamResult) String() string

+ type ResolvedEvent struct

+ CommitPosition *int64

+ Event *EventRecord

+ Link *EventRecord

+ PreparePosition *int64

+ XXX_unrecognized []byte

+ func (*ResolvedEvent) Descriptor() ([]byte, []int)

+ func (*ResolvedEvent) ProtoMessage()

+ func (m *ResolvedEvent) GetCommitPosition() int64

+ func (m *ResolvedEvent) GetEvent() *EventRecord

+ func (m *ResolvedEvent) GetLink() *EventRecord

+ func (m *ResolvedEvent) GetPreparePosition() int64

+ func (m *ResolvedEvent) Reset()

+ func (m *ResolvedEvent) String() string

+ type ResolvedIndexedEvent struct

+ Event *EventRecord

+ Link *EventRecord

+ XXX_unrecognized []byte

+ func (*ResolvedIndexedEvent) Descriptor() ([]byte, []int)

+ func (*ResolvedIndexedEvent) ProtoMessage()

+ func (m *ResolvedIndexedEvent) GetEvent() *EventRecord

+ func (m *ResolvedIndexedEvent) GetLink() *EventRecord

+ func (m *ResolvedIndexedEvent) Reset()

+ func (m *ResolvedIndexedEvent) String() string

+ type ScavengeDatabase struct

+ XXX_unrecognized []byte

+ func (*ScavengeDatabase) Descriptor() ([]byte, []int)

+ func (*ScavengeDatabase) ProtoMessage()

+ func (m *ScavengeDatabase) Reset()

+ func (m *ScavengeDatabase) String() string

+ type ScavengeDatabaseCompleted struct

+ Error *string

+ Result *ScavengeDatabaseCompleted_ScavengeResult

+ TotalSpaceSaved *int64

+ TotalTimeMs *int32

+ XXX_unrecognized []byte

+ func (*ScavengeDatabaseCompleted) Descriptor() ([]byte, []int)

+ func (*ScavengeDatabaseCompleted) ProtoMessage()

+ func (m *ScavengeDatabaseCompleted) GetError() string

+ func (m *ScavengeDatabaseCompleted) GetResult() ScavengeDatabaseCompleted_ScavengeResult

+ func (m *ScavengeDatabaseCompleted) GetTotalSpaceSaved() int64

+ func (m *ScavengeDatabaseCompleted) GetTotalTimeMs() int32

+ func (m *ScavengeDatabaseCompleted) Reset()

+ func (m *ScavengeDatabaseCompleted) String() string

+ type ScavengeDatabaseCompleted_ScavengeResult int32

+ const ScavengeDatabaseCompleted_Failed

+ const ScavengeDatabaseCompleted_InProgress

+ const ScavengeDatabaseCompleted_Success

+ func (ScavengeDatabaseCompleted_ScavengeResult) EnumDescriptor() ([]byte, []int)

+ func (x *ScavengeDatabaseCompleted_ScavengeResult) UnmarshalJSON(data []byte) error

+ func (x ScavengeDatabaseCompleted_ScavengeResult) Enum() *ScavengeDatabaseCompleted_ScavengeResult

+ func (x ScavengeDatabaseCompleted_ScavengeResult) String() string

+ type StreamEventAppeared struct

+ Event *ResolvedEvent

+ XXX_unrecognized []byte

+ func (*StreamEventAppeared) Descriptor() ([]byte, []int)

+ func (*StreamEventAppeared) ProtoMessage()

+ func (m *StreamEventAppeared) GetEvent() *ResolvedEvent

+ func (m *StreamEventAppeared) Reset()

+ func (m *StreamEventAppeared) String() string

+ type SubscribeToStream struct

+ EventStreamId *string

+ ResolveLinkTos *bool

+ XXX_unrecognized []byte

+ func (*SubscribeToStream) Descriptor() ([]byte, []int)

+ func (*SubscribeToStream) ProtoMessage()

+ func (m *SubscribeToStream) GetEventStreamId() string

+ func (m *SubscribeToStream) GetResolveLinkTos() bool

+ func (m *SubscribeToStream) Reset()

+ func (m *SubscribeToStream) String() string

+ type SubscriptionConfirmation struct

+ LastCommitPosition *int64

+ LastEventNumber *int32

+ XXX_unrecognized []byte

+ func (*SubscriptionConfirmation) Descriptor() ([]byte, []int)

+ func (*SubscriptionConfirmation) ProtoMessage()

+ func (m *SubscriptionConfirmation) GetLastCommitPosition() int64

+ func (m *SubscriptionConfirmation) GetLastEventNumber() int32

+ func (m *SubscriptionConfirmation) Reset()

+ func (m *SubscriptionConfirmation) String() string

+ type SubscriptionDropped struct

+ Reason *SubscriptionDropped_SubscriptionDropReason

+ XXX_unrecognized []byte

+ func (*SubscriptionDropped) Descriptor() ([]byte, []int)

+ func (*SubscriptionDropped) ProtoMessage()

+ func (m *SubscriptionDropped) GetReason() SubscriptionDropped_SubscriptionDropReason

+ func (m *SubscriptionDropped) Reset()

+ func (m *SubscriptionDropped) String() string

+ type SubscriptionDropped_SubscriptionDropReason int32

+ const Default_SubscriptionDropped_Reason

+ const SubscriptionDropped_AccessDenied

+ const SubscriptionDropped_NotFound

+ const SubscriptionDropped_PersistentSubscriptionDeleted

+ const SubscriptionDropped_SubscriberMaxCountReached

+ const SubscriptionDropped_Unsubscribed

+ func (SubscriptionDropped_SubscriptionDropReason) EnumDescriptor() ([]byte, []int)

+ func (x *SubscriptionDropped_SubscriptionDropReason) UnmarshalJSON(data []byte) error

+ func (x SubscriptionDropped_SubscriptionDropReason) Enum() *SubscriptionDropped_SubscriptionDropReason

+ func (x SubscriptionDropped_SubscriptionDropReason) String() string

+ type TransactionCommit struct

+ RequireMaster *bool

+ TransactionId *int64

+ XXX_unrecognized []byte

+ func (*TransactionCommit) Descriptor() ([]byte, []int)

+ func (*TransactionCommit) ProtoMessage()

+ func (m *TransactionCommit) GetRequireMaster() bool

+ func (m *TransactionCommit) GetTransactionId() int64

+ func (m *TransactionCommit) Reset()

+ func (m *TransactionCommit) String() string

+ type TransactionCommitCompleted struct

+ CommitPosition *int64

+ FirstEventNumber *int32

+ LastEventNumber *int32

+ Message *string

+ PreparePosition *int64

+ Result *OperationResult

+ TransactionId *int64

+ XXX_unrecognized []byte

+ func (*TransactionCommitCompleted) Descriptor() ([]byte, []int)

+ func (*TransactionCommitCompleted) ProtoMessage()

+ func (m *TransactionCommitCompleted) GetCommitPosition() int64

+ func (m *TransactionCommitCompleted) GetFirstEventNumber() int32

+ func (m *TransactionCommitCompleted) GetLastEventNumber() int32

+ func (m *TransactionCommitCompleted) GetMessage() string

+ func (m *TransactionCommitCompleted) GetPreparePosition() int64

+ func (m *TransactionCommitCompleted) GetResult() OperationResult

+ func (m *TransactionCommitCompleted) GetTransactionId() int64

+ func (m *TransactionCommitCompleted) Reset()

+ func (m *TransactionCommitCompleted) String() string

+ type TransactionStart struct

+ EventStreamId *string

+ ExpectedVersion *int32

+ RequireMaster *bool

+ XXX_unrecognized []byte

+ func (*TransactionStart) Descriptor() ([]byte, []int)

+ func (*TransactionStart) ProtoMessage()

+ func (m *TransactionStart) GetEventStreamId() string

+ func (m *TransactionStart) GetExpectedVersion() int32

+ func (m *TransactionStart) GetRequireMaster() bool

+ func (m *TransactionStart) Reset()

+ func (m *TransactionStart) String() string

+ type TransactionStartCompleted struct

+ Message *string

+ Result *OperationResult

+ TransactionId *int64

+ XXX_unrecognized []byte

+ func (*TransactionStartCompleted) Descriptor() ([]byte, []int)

+ func (*TransactionStartCompleted) ProtoMessage()

+ func (m *TransactionStartCompleted) GetMessage() string

+ func (m *TransactionStartCompleted) GetResult() OperationResult

+ func (m *TransactionStartCompleted) GetTransactionId() int64

+ func (m *TransactionStartCompleted) Reset()

+ func (m *TransactionStartCompleted) String() string

+ type TransactionWrite struct

+ Events []*NewEvent

+ RequireMaster *bool

+ TransactionId *int64

+ XXX_unrecognized []byte

+ func (*TransactionWrite) Descriptor() ([]byte, []int)

+ func (*TransactionWrite) ProtoMessage()

+ func (m *TransactionWrite) GetEvents() []*NewEvent

+ func (m *TransactionWrite) GetRequireMaster() bool

+ func (m *TransactionWrite) GetTransactionId() int64

+ func (m *TransactionWrite) Reset()

+ func (m *TransactionWrite) String() string

+ type TransactionWriteCompleted struct

+ Message *string

+ Result *OperationResult

+ TransactionId *int64

+ XXX_unrecognized []byte

+ func (*TransactionWriteCompleted) Descriptor() ([]byte, []int)

+ func (*TransactionWriteCompleted) ProtoMessage()

+ func (m *TransactionWriteCompleted) GetMessage() string

+ func (m *TransactionWriteCompleted) GetResult() OperationResult

+ func (m *TransactionWriteCompleted) GetTransactionId() int64

+ func (m *TransactionWriteCompleted) Reset()

+ func (m *TransactionWriteCompleted) String() string

+ type UnsubscribeFromStream struct

+ XXX_unrecognized []byte

+ func (*UnsubscribeFromStream) Descriptor() ([]byte, []int)

+ func (*UnsubscribeFromStream) ProtoMessage()

+ func (m *UnsubscribeFromStream) Reset()

+ func (m *UnsubscribeFromStream) String() string

+ type UpdatePersistentSubscription struct

+ BufferSize *int32

+ CheckpointAfterTime *int32

+ CheckpointMaxCount *int32

+ CheckpointMinCount *int32

+ EventStreamId *string

+ LiveBufferSize *int32

+ MaxRetryCount *int32

+ MessageTimeoutMilliseconds *int32

+ NamedConsumerStrategy *string

+ PreferRoundRobin *bool

+ ReadBatchSize *int32

+ RecordStatistics *bool

+ ResolveLinkTos *bool

+ StartFrom *int32

+ SubscriberMaxCount *int32

+ SubscriptionGroupName *string

+ XXX_unrecognized []byte

+ func (*UpdatePersistentSubscription) Descriptor() ([]byte, []int)

+ func (*UpdatePersistentSubscription) ProtoMessage()

+ func (m *UpdatePersistentSubscription) GetBufferSize() int32

+ func (m *UpdatePersistentSubscription) GetCheckpointAfterTime() int32

+ func (m *UpdatePersistentSubscription) GetCheckpointMaxCount() int32

+ func (m *UpdatePersistentSubscription) GetCheckpointMinCount() int32

+ func (m *UpdatePersistentSubscription) GetEventStreamId() string

+ func (m *UpdatePersistentSubscription) GetLiveBufferSize() int32

+ func (m *UpdatePersistentSubscription) GetMaxRetryCount() int32

+ func (m *UpdatePersistentSubscription) GetMessageTimeoutMilliseconds() int32

+ func (m *UpdatePersistentSubscription) GetNamedConsumerStrategy() string

+ func (m *UpdatePersistentSubscription) GetPreferRoundRobin() bool

+ func (m *UpdatePersistentSubscription) GetReadBatchSize() int32

+ func (m *UpdatePersistentSubscription) GetRecordStatistics() bool

+ func (m *UpdatePersistentSubscription) GetResolveLinkTos() bool

+ func (m *UpdatePersistentSubscription) GetStartFrom() int32

+ func (m *UpdatePersistentSubscription) GetSubscriberMaxCount() int32

+ func (m *UpdatePersistentSubscription) GetSubscriptionGroupName() string

+ func (m *UpdatePersistentSubscription) Reset()

+ func (m *UpdatePersistentSubscription) String() string

+ type UpdatePersistentSubscriptionCompleted struct

+ Reason *string

+ Result *UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult

+ XXX_unrecognized []byte

+ func (*UpdatePersistentSubscriptionCompleted) Descriptor() ([]byte, []int)

+ func (*UpdatePersistentSubscriptionCompleted) ProtoMessage()

+ func (m *UpdatePersistentSubscriptionCompleted) GetReason() string

+ func (m *UpdatePersistentSubscriptionCompleted) GetResult() UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult

+ func (m *UpdatePersistentSubscriptionCompleted) Reset()

+ func (m *UpdatePersistentSubscriptionCompleted) String() string

+ type UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult int32

+ const Default_UpdatePersistentSubscriptionCompleted_Result

+ const UpdatePersistentSubscriptionCompleted_AccessDenied

+ const UpdatePersistentSubscriptionCompleted_DoesNotExist

+ const UpdatePersistentSubscriptionCompleted_Fail

+ const UpdatePersistentSubscriptionCompleted_Success

+ func (UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult) EnumDescriptor() ([]byte, []int)

+ func (x *UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult) UnmarshalJSON(data []byte) error

+ func (x UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult) Enum() *UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult

+ func (x UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult) String() string

+ type VNodeState int

+ const VNodeState_CatchingUp

+ const VNodeState_Clone

+ const VNodeState_Initializing

+ const VNodeState_Manager

+ const VNodeState_Master

+ const VNodeState_PreMaster

+ const VNodeState_PreReplica

+ const VNodeState_Shutdown

+ const VNodeState_ShuttingDown

+ const VNodeState_Slave

+ const VNodeState_Unknown

+ func (x VNodeState) String() string

+ type WriteEvents struct

+ EventStreamId *string

+ Events []*NewEvent

+ ExpectedVersion *int32

+ RequireMaster *bool

+ XXX_unrecognized []byte

+ func (*WriteEvents) Descriptor() ([]byte, []int)

+ func (*WriteEvents) ProtoMessage()

+ func (m *WriteEvents) GetEventStreamId() string

+ func (m *WriteEvents) GetEvents() []*NewEvent

+ func (m *WriteEvents) GetExpectedVersion() int32

+ func (m *WriteEvents) GetRequireMaster() bool

+ func (m *WriteEvents) Reset()

+ func (m *WriteEvents) String() string

+ type WriteEventsCompleted struct

+ CommitPosition *int64

+ FirstEventNumber *int32

+ LastEventNumber *int32

+ Message *string

+ PreparePosition *int64

+ Result *OperationResult

+ XXX_unrecognized []byte

+ func (*WriteEventsCompleted) Descriptor() ([]byte, []int)

+ func (*WriteEventsCompleted) ProtoMessage()

+ func (m *WriteEventsCompleted) GetCommitPosition() int64

+ func (m *WriteEventsCompleted) GetFirstEventNumber() int32

+ func (m *WriteEventsCompleted) GetLastEventNumber() int32

+ func (m *WriteEventsCompleted) GetMessage() string

+ func (m *WriteEventsCompleted) GetPreparePosition() int64

+ func (m *WriteEventsCompleted) GetResult() OperationResult

+ func (m *WriteEventsCompleted) Reset()

+ func (m *WriteEventsCompleted) String() string