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.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