messages

package
v0.4.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 1, 2019 License: MIT Imports: 5 Imported by: 0

Documentation

Overview

Package messages is a generated protocol buffer package.

It is generated from these files:

github.com/jdextraze/go-gesclient/messages/ClientMessageDtos.proto

It has these top-level messages:

NewEvent
EventRecord
ResolvedIndexedEvent
ResolvedEvent
WriteEvents
WriteEventsCompleted
DeleteStream
DeleteStreamCompleted
TransactionStart
TransactionStartCompleted
TransactionWrite
TransactionWriteCompleted
TransactionCommit
TransactionCommitCompleted
ReadEvent
ReadEventCompleted
ReadStreamEvents
ReadStreamEventsCompleted
ReadAllEvents
ReadAllEventsCompleted
CreatePersistentSubscription
DeletePersistentSubscription
UpdatePersistentSubscription
UpdatePersistentSubscriptionCompleted
CreatePersistentSubscriptionCompleted
DeletePersistentSubscriptionCompleted
ConnectToPersistentSubscription
PersistentSubscriptionAckEvents
PersistentSubscriptionNakEvents
PersistentSubscriptionConfirmation
PersistentSubscriptionStreamEventAppeared
SubscribeToStream
SubscriptionConfirmation
StreamEventAppeared
UnsubscribeFromStream
SubscriptionDropped
NotHandled
ScavengeDatabase
ScavengeDatabaseCompleted

Index

Constants

This section is empty.

Variables

View Source
var CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult_name = map[int32]string{
	0: "Success",
	1: "AlreadyExists",
	2: "Fail",
	3: "AccessDenied",
}
View Source
var CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult_value = map[string]int32{
	"Success":       0,
	"AlreadyExists": 1,
	"Fail":          2,
	"AccessDenied":  3,
}
View Source
var DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult_name = map[int32]string{
	0: "Success",
	1: "DoesNotExist",
	2: "Fail",
	3: "AccessDenied",
}
View Source
var DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult_value = map[string]int32{
	"Success":      0,
	"DoesNotExist": 1,
	"Fail":         2,
	"AccessDenied": 3,
}
View Source
var NotHandled_NotHandledReason_name = map[int32]string{
	0: "NotReady",
	1: "TooBusy",
	2: "NotMaster",
}
View Source
var NotHandled_NotHandledReason_value = map[string]int32{
	"NotReady":  0,
	"TooBusy":   1,
	"NotMaster": 2,
}
View Source
var OperationResult_name = map[int32]string{
	0: "Success",
	1: "PrepareTimeout",
	2: "CommitTimeout",
	3: "ForwardTimeout",
	4: "WrongExpectedVersion",
	5: "StreamDeleted",
	6: "InvalidTransaction",
	7: "AccessDenied",
}
View Source
var OperationResult_value = map[string]int32{
	"Success":              0,
	"PrepareTimeout":       1,
	"CommitTimeout":        2,
	"ForwardTimeout":       3,
	"WrongExpectedVersion": 4,
	"StreamDeleted":        5,
	"InvalidTransaction":   6,
	"AccessDenied":         7,
}
View Source
var PersistentSubscriptionNakEvents_NakAction_name = map[int32]string{
	0: "Unknown",
	1: "Park",
	2: "Retry",
	3: "Skip",
	4: "Stop",
}
View Source
var PersistentSubscriptionNakEvents_NakAction_value = map[string]int32{
	"Unknown": 0,
	"Park":    1,
	"Retry":   2,
	"Skip":    3,
	"Stop":    4,
}
View Source
var ReadAllEventsCompleted_ReadAllResult_name = map[int32]string{
	0: "Success",
	1: "NotModified",
	2: "Error",
	3: "AccessDenied",
}
View Source
var ReadAllEventsCompleted_ReadAllResult_value = map[string]int32{
	"Success":      0,
	"NotModified":  1,
	"Error":        2,
	"AccessDenied": 3,
}
View Source
var ReadEventCompleted_ReadEventResult_name = map[int32]string{
	0: "Success",
	1: "NotFound",
	2: "NoStream",
	3: "StreamDeleted",
	4: "Error",
	5: "AccessDenied",
}
View Source
var ReadEventCompleted_ReadEventResult_value = map[string]int32{
	"Success":       0,
	"NotFound":      1,
	"NoStream":      2,
	"StreamDeleted": 3,
	"Error":         4,
	"AccessDenied":  5,
}
View Source
var ReadStreamEventsCompleted_ReadStreamResult_name = map[int32]string{
	0: "Success",
	1: "NoStream",
	2: "StreamDeleted",
	3: "NotModified",
	4: "Error",
	5: "AccessDenied",
}
View Source
var ReadStreamEventsCompleted_ReadStreamResult_value = map[string]int32{
	"Success":       0,
	"NoStream":      1,
	"StreamDeleted": 2,
	"NotModified":   3,
	"Error":         4,
	"AccessDenied":  5,
}
View Source
var ScavengeDatabaseCompleted_ScavengeResult_name = map[int32]string{
	0: "Success",
	1: "InProgress",
	2: "Failed",
}
View Source
var ScavengeDatabaseCompleted_ScavengeResult_value = map[string]int32{
	"Success":    0,
	"InProgress": 1,
	"Failed":     2,
}
View Source
var SubscriptionDropped_SubscriptionDropReason_name = map[int32]string{
	0: "Unsubscribed",
	1: "AccessDenied",
	2: "NotFound",
	3: "PersistentSubscriptionDeleted",
	4: "SubscriberMaxCountReached",
}
View Source
var SubscriptionDropped_SubscriptionDropReason_value = map[string]int32{
	"Unsubscribed":                  0,
	"AccessDenied":                  1,
	"NotFound":                      2,
	"PersistentSubscriptionDeleted": 3,
	"SubscriberMaxCountReached":     4,
}
View Source
var UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult_name = map[int32]string{
	0: "Success",
	1: "DoesNotExist",
	2: "Fail",
	3: "AccessDenied",
}
View Source
var UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult_value = map[string]int32{
	"Success":      0,
	"DoesNotExist": 1,
	"Fail":         2,
	"AccessDenied": 3,
}
View Source
var VNodeState_name = map[int]string{
	0:  "Initializing",
	1:  "Unknown",
	2:  "PreReplica",
	3:  "CatchingUp",
	4:  "Clone",
	5:  "Slave",
	6:  "PreMaster",
	7:  "Master",
	8:  "Manager",
	9:  "ShuttingDown",
	10: "Shutdown",
}

Functions

This section is empty.

Types

type ClusterInfoDto

type ClusterInfoDto struct {
	Members []*MemberInfoDto
}

type ConnectToPersistentSubscription

type ConnectToPersistentSubscription struct {
	SubscriptionId          *string `protobuf:"bytes,1,req,name=subscription_id" json:"subscription_id,omitempty"`
	EventStreamId           *string `protobuf:"bytes,2,req,name=event_stream_id" json:"event_stream_id,omitempty"`
	AllowedInFlightMessages *int32  `protobuf:"varint,3,req,name=allowed_in_flight_messages" json:"allowed_in_flight_messages,omitempty"`
	XXX_unrecognized        []byte  `json:"-"`
}

func (*ConnectToPersistentSubscription) Descriptor

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

func (*ConnectToPersistentSubscription) GetAllowedInFlightMessages

func (m *ConnectToPersistentSubscription) GetAllowedInFlightMessages() int32

func (*ConnectToPersistentSubscription) GetEventStreamId

func (m *ConnectToPersistentSubscription) GetEventStreamId() string

func (*ConnectToPersistentSubscription) GetSubscriptionId

func (m *ConnectToPersistentSubscription) GetSubscriptionId() string

func (*ConnectToPersistentSubscription) ProtoMessage

func (*ConnectToPersistentSubscription) ProtoMessage()

func (*ConnectToPersistentSubscription) Reset

func (*ConnectToPersistentSubscription) String

type CreatePersistentSubscription

type CreatePersistentSubscription struct {
	SubscriptionGroupName      *string `protobuf:"bytes,1,req,name=subscription_group_name" json:"subscription_group_name,omitempty"`
	EventStreamId              *string `protobuf:"bytes,2,req,name=event_stream_id" json:"event_stream_id,omitempty"`
	ResolveLinkTos             *bool   `protobuf:"varint,3,req,name=resolve_link_tos" json:"resolve_link_tos,omitempty"`
	StartFrom                  *int32  `protobuf:"varint,4,req,name=start_from" json:"start_from,omitempty"`
	MessageTimeoutMilliseconds *int32  `protobuf:"varint,5,req,name=message_timeout_milliseconds" json:"message_timeout_milliseconds,omitempty"`
	RecordStatistics           *bool   `protobuf:"varint,6,req,name=record_statistics" json:"record_statistics,omitempty"`
	LiveBufferSize             *int32  `protobuf:"varint,7,req,name=live_buffer_size" json:"live_buffer_size,omitempty"`
	ReadBatchSize              *int32  `protobuf:"varint,8,req,name=read_batch_size" json:"read_batch_size,omitempty"`
	BufferSize                 *int32  `protobuf:"varint,9,req,name=buffer_size" json:"buffer_size,omitempty"`
	MaxRetryCount              *int32  `protobuf:"varint,10,req,name=max_retry_count" json:"max_retry_count,omitempty"`
	PreferRoundRobin           *bool   `protobuf:"varint,11,req,name=prefer_round_robin" json:"prefer_round_robin,omitempty"`
	CheckpointAfterTime        *int32  `protobuf:"varint,12,req,name=checkpoint_after_time" json:"checkpoint_after_time,omitempty"`
	CheckpointMaxCount         *int32  `protobuf:"varint,13,req,name=checkpoint_max_count" json:"checkpoint_max_count,omitempty"`
	CheckpointMinCount         *int32  `protobuf:"varint,14,req,name=checkpoint_min_count" json:"checkpoint_min_count,omitempty"`
	SubscriberMaxCount         *int32  `protobuf:"varint,15,req,name=subscriber_max_count" json:"subscriber_max_count,omitempty"`
	NamedConsumerStrategy      *string `protobuf:"bytes,16,opt,name=named_consumer_strategy" json:"named_consumer_strategy,omitempty"`
	XXX_unrecognized           []byte  `json:"-"`
}

func (*CreatePersistentSubscription) Descriptor

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

func (*CreatePersistentSubscription) GetBufferSize

func (m *CreatePersistentSubscription) GetBufferSize() int32

func (*CreatePersistentSubscription) GetCheckpointAfterTime

func (m *CreatePersistentSubscription) GetCheckpointAfterTime() int32

func (*CreatePersistentSubscription) GetCheckpointMaxCount

func (m *CreatePersistentSubscription) GetCheckpointMaxCount() int32

func (*CreatePersistentSubscription) GetCheckpointMinCount

func (m *CreatePersistentSubscription) GetCheckpointMinCount() int32

func (*CreatePersistentSubscription) GetEventStreamId

func (m *CreatePersistentSubscription) GetEventStreamId() string

func (*CreatePersistentSubscription) GetLiveBufferSize

func (m *CreatePersistentSubscription) GetLiveBufferSize() int32

func (*CreatePersistentSubscription) GetMaxRetryCount

func (m *CreatePersistentSubscription) GetMaxRetryCount() int32

func (*CreatePersistentSubscription) GetMessageTimeoutMilliseconds

func (m *CreatePersistentSubscription) GetMessageTimeoutMilliseconds() int32

func (*CreatePersistentSubscription) GetNamedConsumerStrategy

func (m *CreatePersistentSubscription) GetNamedConsumerStrategy() string

func (*CreatePersistentSubscription) GetPreferRoundRobin

func (m *CreatePersistentSubscription) GetPreferRoundRobin() bool

func (*CreatePersistentSubscription) GetReadBatchSize

func (m *CreatePersistentSubscription) GetReadBatchSize() int32

func (*CreatePersistentSubscription) GetRecordStatistics

func (m *CreatePersistentSubscription) GetRecordStatistics() bool

func (*CreatePersistentSubscription) GetResolveLinkTos

func (m *CreatePersistentSubscription) GetResolveLinkTos() bool

func (*CreatePersistentSubscription) GetStartFrom

func (m *CreatePersistentSubscription) GetStartFrom() int32

func (*CreatePersistentSubscription) GetSubscriberMaxCount

func (m *CreatePersistentSubscription) GetSubscriberMaxCount() int32

func (*CreatePersistentSubscription) GetSubscriptionGroupName

func (m *CreatePersistentSubscription) GetSubscriptionGroupName() string

func (*CreatePersistentSubscription) ProtoMessage

func (*CreatePersistentSubscription) ProtoMessage()

func (*CreatePersistentSubscription) Reset

func (m *CreatePersistentSubscription) Reset()

func (*CreatePersistentSubscription) String

type CreatePersistentSubscriptionCompleted

type CreatePersistentSubscriptionCompleted struct {
	Result           *CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult `` /* 152-byte string literal not displayed */
	Reason           *string                                                                   `protobuf:"bytes,2,opt,name=reason" json:"reason,omitempty"`
	XXX_unrecognized []byte                                                                    `json:"-"`
}

func (*CreatePersistentSubscriptionCompleted) Descriptor

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

func (*CreatePersistentSubscriptionCompleted) GetReason

func (*CreatePersistentSubscriptionCompleted) ProtoMessage

func (*CreatePersistentSubscriptionCompleted) ProtoMessage()

func (*CreatePersistentSubscriptionCompleted) Reset

func (*CreatePersistentSubscriptionCompleted) String

type CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult

type CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult int32
const (
	CreatePersistentSubscriptionCompleted_Success       CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult = 0
	CreatePersistentSubscriptionCompleted_AlreadyExists CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult = 1
	CreatePersistentSubscriptionCompleted_Fail          CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult = 2
	CreatePersistentSubscriptionCompleted_AccessDenied  CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult = 3
)

func (CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult) Enum

func (CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult) EnumDescriptor

func (CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult) String

func (*CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult) UnmarshalJSON

type DeletePersistentSubscription

type DeletePersistentSubscription struct {
	SubscriptionGroupName *string `protobuf:"bytes,1,req,name=subscription_group_name" json:"subscription_group_name,omitempty"`
	EventStreamId         *string `protobuf:"bytes,2,req,name=event_stream_id" json:"event_stream_id,omitempty"`
	XXX_unrecognized      []byte  `json:"-"`
}

func (*DeletePersistentSubscription) Descriptor

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

func (*DeletePersistentSubscription) GetEventStreamId

func (m *DeletePersistentSubscription) GetEventStreamId() string

func (*DeletePersistentSubscription) GetSubscriptionGroupName

func (m *DeletePersistentSubscription) GetSubscriptionGroupName() string

func (*DeletePersistentSubscription) ProtoMessage

func (*DeletePersistentSubscription) ProtoMessage()

func (*DeletePersistentSubscription) Reset

func (m *DeletePersistentSubscription) Reset()

func (*DeletePersistentSubscription) String

type DeletePersistentSubscriptionCompleted

type DeletePersistentSubscriptionCompleted struct {
	Result           *DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult `` /* 152-byte string literal not displayed */
	Reason           *string                                                                   `protobuf:"bytes,2,opt,name=reason" json:"reason,omitempty"`
	XXX_unrecognized []byte                                                                    `json:"-"`
}

func (*DeletePersistentSubscriptionCompleted) Descriptor

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

func (*DeletePersistentSubscriptionCompleted) GetReason

func (*DeletePersistentSubscriptionCompleted) ProtoMessage

func (*DeletePersistentSubscriptionCompleted) ProtoMessage()

func (*DeletePersistentSubscriptionCompleted) Reset

func (*DeletePersistentSubscriptionCompleted) String

type DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult

type DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult int32
const (
	DeletePersistentSubscriptionCompleted_Success      DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult = 0
	DeletePersistentSubscriptionCompleted_DoesNotExist DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult = 1
	DeletePersistentSubscriptionCompleted_Fail         DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult = 2
	DeletePersistentSubscriptionCompleted_AccessDenied DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult = 3
)

func (DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult) Enum

func (DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult) EnumDescriptor

func (DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult) String

func (*DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult) UnmarshalJSON

type DeleteStream

type DeleteStream struct {
	EventStreamId    *string `protobuf:"bytes,1,req,name=event_stream_id" json:"event_stream_id,omitempty"`
	ExpectedVersion  *int32  `protobuf:"varint,2,req,name=expected_version" json:"expected_version,omitempty"`
	RequireMaster    *bool   `protobuf:"varint,3,req,name=require_master" json:"require_master,omitempty"`
	HardDelete       *bool   `protobuf:"varint,4,opt,name=hard_delete" json:"hard_delete,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*DeleteStream) Descriptor

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

func (*DeleteStream) GetEventStreamId

func (m *DeleteStream) GetEventStreamId() string

func (*DeleteStream) GetExpectedVersion

func (m *DeleteStream) GetExpectedVersion() int32

func (*DeleteStream) GetHardDelete

func (m *DeleteStream) GetHardDelete() bool

func (*DeleteStream) GetRequireMaster

func (m *DeleteStream) GetRequireMaster() bool

func (*DeleteStream) ProtoMessage

func (*DeleteStream) ProtoMessage()

func (*DeleteStream) Reset

func (m *DeleteStream) Reset()

func (*DeleteStream) String

func (m *DeleteStream) String() string

type DeleteStreamCompleted

type DeleteStreamCompleted struct {
	Result           *OperationResult `protobuf:"varint,1,req,name=result,enum=messages.OperationResult" json:"result,omitempty"`
	Message          *string          `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"`
	PreparePosition  *int64           `protobuf:"varint,3,opt,name=prepare_position" json:"prepare_position,omitempty"`
	CommitPosition   *int64           `protobuf:"varint,4,opt,name=commit_position" json:"commit_position,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*DeleteStreamCompleted) Descriptor

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

func (*DeleteStreamCompleted) GetCommitPosition

func (m *DeleteStreamCompleted) GetCommitPosition() int64

func (*DeleteStreamCompleted) GetMessage

func (m *DeleteStreamCompleted) GetMessage() string

func (*DeleteStreamCompleted) GetPreparePosition

func (m *DeleteStreamCompleted) GetPreparePosition() int64

func (*DeleteStreamCompleted) GetResult

func (m *DeleteStreamCompleted) GetResult() OperationResult

func (*DeleteStreamCompleted) ProtoMessage

func (*DeleteStreamCompleted) ProtoMessage()

func (*DeleteStreamCompleted) Reset

func (m *DeleteStreamCompleted) Reset()

func (*DeleteStreamCompleted) String

func (m *DeleteStreamCompleted) String() string

type EventRecord

type EventRecord struct {
	EventStreamId       *string `protobuf:"bytes,1,req,name=event_stream_id" json:"event_stream_id,omitempty"`
	EventNumber         *int32  `protobuf:"varint,2,req,name=event_number" json:"event_number,omitempty"`
	EventId             []byte  `protobuf:"bytes,3,req,name=event_id" json:"event_id,omitempty"`
	EventType           *string `protobuf:"bytes,4,req,name=event_type" json:"event_type,omitempty"`
	DataContentType     *int32  `protobuf:"varint,5,req,name=data_content_type" json:"data_content_type,omitempty"`
	MetadataContentType *int32  `protobuf:"varint,6,req,name=metadata_content_type" json:"metadata_content_type,omitempty"`
	Data                []byte  `protobuf:"bytes,7,req,name=data" json:"data,omitempty"`
	Metadata            []byte  `protobuf:"bytes,8,opt,name=metadata" json:"metadata,omitempty"`
	Created             *int64  `protobuf:"varint,9,opt,name=created" json:"created,omitempty"`
	CreatedEpoch        *int64  `protobuf:"varint,10,opt,name=created_epoch" json:"created_epoch,omitempty"`
	XXX_unrecognized    []byte  `json:"-"`
}

func (*EventRecord) Descriptor

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

func (*EventRecord) GetCreated

func (m *EventRecord) GetCreated() int64

func (*EventRecord) GetCreatedEpoch

func (m *EventRecord) GetCreatedEpoch() int64

func (*EventRecord) GetData

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

func (*EventRecord) GetDataContentType

func (m *EventRecord) GetDataContentType() int32

func (*EventRecord) GetEventId

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

func (*EventRecord) GetEventNumber

func (m *EventRecord) GetEventNumber() int32

func (*EventRecord) GetEventStreamId

func (m *EventRecord) GetEventStreamId() string

func (*EventRecord) GetEventType

func (m *EventRecord) GetEventType() string

func (*EventRecord) GetMetadata

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

func (*EventRecord) GetMetadataContentType

func (m *EventRecord) GetMetadataContentType() int32

func (*EventRecord) ProtoMessage

func (*EventRecord) ProtoMessage()

func (*EventRecord) Reset

func (m *EventRecord) Reset()

func (*EventRecord) String

func (m *EventRecord) String() string

type MemberInfoDto

type MemberInfoDto struct {
	InstanceId uuid.UUID

	Timestamp time.Time
	State     VNodeState
	IsAlive   bool

	InternalTcpIp         string
	InternalTcpPort       int
	InternalSecureTcpPort int

	ExternalTcpIp         string
	ExternalTcpPort       int
	ExternalSecureTcpPort int

	InternalHttpIp   string
	InternalHttpPort int

	ExternalHttpIp   string
	ExternalHttpPort int

	LastCommitPosition int64
	WriterCheckpoint   int64
	ChaserCheckpoint   int64

	EpochPosition int64
	EpochNumber   int
	EpochId       uuid.UUID

	NodePriority int
}

func (MemberInfoDto) String

func (x MemberInfoDto) String() string

type NewEvent

type NewEvent struct {
	EventId             []byte  `protobuf:"bytes,1,req,name=event_id" json:"event_id,omitempty"`
	EventType           *string `protobuf:"bytes,2,req,name=event_type" json:"event_type,omitempty"`
	DataContentType     *int32  `protobuf:"varint,3,req,name=data_content_type" json:"data_content_type,omitempty"`
	MetadataContentType *int32  `protobuf:"varint,4,req,name=metadata_content_type" json:"metadata_content_type,omitempty"`
	Data                []byte  `protobuf:"bytes,5,req,name=data" json:"data,omitempty"`
	Metadata            []byte  `protobuf:"bytes,6,opt,name=metadata" json:"metadata,omitempty"`
	XXX_unrecognized    []byte  `json:"-"`
}

func (*NewEvent) Descriptor

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

func (*NewEvent) GetData

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

func (*NewEvent) GetDataContentType

func (m *NewEvent) GetDataContentType() int32

func (*NewEvent) GetEventId

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

func (*NewEvent) GetEventType

func (m *NewEvent) GetEventType() string

func (*NewEvent) GetMetadata

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

func (*NewEvent) GetMetadataContentType

func (m *NewEvent) GetMetadataContentType() int32

func (*NewEvent) ProtoMessage

func (*NewEvent) ProtoMessage()

func (*NewEvent) Reset

func (m *NewEvent) Reset()

func (*NewEvent) String

func (m *NewEvent) String() string

type NotHandled

type NotHandled struct {
	Reason           *NotHandled_NotHandledReason `protobuf:"varint,1,req,name=reason,enum=messages.NotHandled_NotHandledReason" json:"reason,omitempty"`
	AdditionalInfo   []byte                       `protobuf:"bytes,2,opt,name=additional_info" json:"additional_info,omitempty"`
	XXX_unrecognized []byte                       `json:"-"`
}

func (*NotHandled) Descriptor

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

func (*NotHandled) GetAdditionalInfo

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

func (*NotHandled) GetReason

func (m *NotHandled) GetReason() NotHandled_NotHandledReason

func (*NotHandled) ProtoMessage

func (*NotHandled) ProtoMessage()

func (*NotHandled) Reset

func (m *NotHandled) Reset()

func (*NotHandled) String

func (m *NotHandled) String() string

type NotHandled_MasterInfo

type NotHandled_MasterInfo struct {
	ExternalTcpAddress       *string `protobuf:"bytes,1,req,name=external_tcp_address" json:"external_tcp_address,omitempty"`
	ExternalTcpPort          *int32  `protobuf:"varint,2,req,name=external_tcp_port" json:"external_tcp_port,omitempty"`
	ExternalHttpAddress      *string `protobuf:"bytes,3,req,name=external_http_address" json:"external_http_address,omitempty"`
	ExternalHttpPort         *int32  `protobuf:"varint,4,req,name=external_http_port" json:"external_http_port,omitempty"`
	ExternalSecureTcpAddress *string `protobuf:"bytes,5,opt,name=external_secure_tcp_address" json:"external_secure_tcp_address,omitempty"`
	ExternalSecureTcpPort    *int32  `protobuf:"varint,6,opt,name=external_secure_tcp_port" json:"external_secure_tcp_port,omitempty"`
	XXX_unrecognized         []byte  `json:"-"`
}

func (*NotHandled_MasterInfo) Descriptor

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

func (*NotHandled_MasterInfo) GetExternalHttpAddress

func (m *NotHandled_MasterInfo) GetExternalHttpAddress() string

func (*NotHandled_MasterInfo) GetExternalHttpPort

func (m *NotHandled_MasterInfo) GetExternalHttpPort() int32

func (*NotHandled_MasterInfo) GetExternalSecureTcpAddress

func (m *NotHandled_MasterInfo) GetExternalSecureTcpAddress() string

func (*NotHandled_MasterInfo) GetExternalSecureTcpPort

func (m *NotHandled_MasterInfo) GetExternalSecureTcpPort() int32

func (*NotHandled_MasterInfo) GetExternalTcpAddress

func (m *NotHandled_MasterInfo) GetExternalTcpAddress() string

func (*NotHandled_MasterInfo) GetExternalTcpPort

func (m *NotHandled_MasterInfo) GetExternalTcpPort() int32

func (*NotHandled_MasterInfo) ProtoMessage

func (*NotHandled_MasterInfo) ProtoMessage()

func (*NotHandled_MasterInfo) Reset

func (m *NotHandled_MasterInfo) Reset()

func (*NotHandled_MasterInfo) String

func (m *NotHandled_MasterInfo) String() string

type NotHandled_NotHandledReason

type NotHandled_NotHandledReason int32
const (
	NotHandled_NotReady  NotHandled_NotHandledReason = 0
	NotHandled_TooBusy   NotHandled_NotHandledReason = 1
	NotHandled_NotMaster NotHandled_NotHandledReason = 2
)

func (NotHandled_NotHandledReason) Enum

func (NotHandled_NotHandledReason) EnumDescriptor

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

func (NotHandled_NotHandledReason) String

func (*NotHandled_NotHandledReason) UnmarshalJSON

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

type OperationResult

type OperationResult int32
const (
	OperationResult_Success              OperationResult = 0
	OperationResult_PrepareTimeout       OperationResult = 1
	OperationResult_CommitTimeout        OperationResult = 2
	OperationResult_ForwardTimeout       OperationResult = 3
	OperationResult_WrongExpectedVersion OperationResult = 4
	OperationResult_StreamDeleted        OperationResult = 5
	OperationResult_InvalidTransaction   OperationResult = 6
	OperationResult_AccessDenied         OperationResult = 7
)

func (OperationResult) Enum

func (x OperationResult) Enum() *OperationResult

func (OperationResult) EnumDescriptor

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

func (OperationResult) String

func (x OperationResult) String() string

func (*OperationResult) UnmarshalJSON

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

type PersistentSubscriptionAckEvents

type PersistentSubscriptionAckEvents struct {
	SubscriptionId    *string  `protobuf:"bytes,1,req,name=subscription_id" json:"subscription_id,omitempty"`
	ProcessedEventIds [][]byte `protobuf:"bytes,2,rep,name=processed_event_ids" json:"processed_event_ids,omitempty"`
	XXX_unrecognized  []byte   `json:"-"`
}

func (*PersistentSubscriptionAckEvents) Descriptor

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

func (*PersistentSubscriptionAckEvents) GetProcessedEventIds

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

func (*PersistentSubscriptionAckEvents) GetSubscriptionId

func (m *PersistentSubscriptionAckEvents) GetSubscriptionId() string

func (*PersistentSubscriptionAckEvents) ProtoMessage

func (*PersistentSubscriptionAckEvents) ProtoMessage()

func (*PersistentSubscriptionAckEvents) Reset

func (*PersistentSubscriptionAckEvents) String

type PersistentSubscriptionConfirmation

type PersistentSubscriptionConfirmation struct {
	LastCommitPosition *int64  `protobuf:"varint,1,req,name=last_commit_position" json:"last_commit_position,omitempty"`
	SubscriptionId     *string `protobuf:"bytes,2,req,name=subscription_id" json:"subscription_id,omitempty"`
	LastEventNumber    *int32  `protobuf:"varint,3,opt,name=last_event_number" json:"last_event_number,omitempty"`
	XXX_unrecognized   []byte  `json:"-"`
}

func (*PersistentSubscriptionConfirmation) Descriptor

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

func (*PersistentSubscriptionConfirmation) GetLastCommitPosition

func (m *PersistentSubscriptionConfirmation) GetLastCommitPosition() int64

func (*PersistentSubscriptionConfirmation) GetLastEventNumber

func (m *PersistentSubscriptionConfirmation) GetLastEventNumber() int32

func (*PersistentSubscriptionConfirmation) GetSubscriptionId

func (m *PersistentSubscriptionConfirmation) GetSubscriptionId() string

func (*PersistentSubscriptionConfirmation) ProtoMessage

func (*PersistentSubscriptionConfirmation) ProtoMessage()

func (*PersistentSubscriptionConfirmation) Reset

func (*PersistentSubscriptionConfirmation) String

type PersistentSubscriptionNakEvents

type PersistentSubscriptionNakEvents struct {
	SubscriptionId    *string                                    `protobuf:"bytes,1,req,name=subscription_id" json:"subscription_id,omitempty"`
	ProcessedEventIds [][]byte                                   `protobuf:"bytes,2,rep,name=processed_event_ids" json:"processed_event_ids,omitempty"`
	Message           *string                                    `protobuf:"bytes,3,opt,name=message" json:"message,omitempty"`
	Action            *PersistentSubscriptionNakEvents_NakAction `protobuf:"varint,4,req,name=action,enum=messages.PersistentSubscriptionNakEvents_NakAction,def=0" json:"action,omitempty"`
	XXX_unrecognized  []byte                                     `json:"-"`
}

func (*PersistentSubscriptionNakEvents) Descriptor

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

func (*PersistentSubscriptionNakEvents) GetAction

func (*PersistentSubscriptionNakEvents) GetMessage

func (m *PersistentSubscriptionNakEvents) GetMessage() string

func (*PersistentSubscriptionNakEvents) GetProcessedEventIds

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

func (*PersistentSubscriptionNakEvents) GetSubscriptionId

func (m *PersistentSubscriptionNakEvents) GetSubscriptionId() string

func (*PersistentSubscriptionNakEvents) ProtoMessage

func (*PersistentSubscriptionNakEvents) ProtoMessage()

func (*PersistentSubscriptionNakEvents) Reset

func (*PersistentSubscriptionNakEvents) String

type PersistentSubscriptionNakEvents_NakAction

type PersistentSubscriptionNakEvents_NakAction int32
const (
	PersistentSubscriptionNakEvents_Unknown PersistentSubscriptionNakEvents_NakAction = 0
	PersistentSubscriptionNakEvents_Park    PersistentSubscriptionNakEvents_NakAction = 1
	PersistentSubscriptionNakEvents_Retry   PersistentSubscriptionNakEvents_NakAction = 2
	PersistentSubscriptionNakEvents_Skip    PersistentSubscriptionNakEvents_NakAction = 3
	PersistentSubscriptionNakEvents_Stop    PersistentSubscriptionNakEvents_NakAction = 4
)
const Default_PersistentSubscriptionNakEvents_Action PersistentSubscriptionNakEvents_NakAction = PersistentSubscriptionNakEvents_Unknown

func (PersistentSubscriptionNakEvents_NakAction) Enum

func (PersistentSubscriptionNakEvents_NakAction) EnumDescriptor

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

func (PersistentSubscriptionNakEvents_NakAction) String

func (*PersistentSubscriptionNakEvents_NakAction) UnmarshalJSON

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

type PersistentSubscriptionStreamEventAppeared

type PersistentSubscriptionStreamEventAppeared struct {
	Event            *ResolvedIndexedEvent `protobuf:"bytes,1,req,name=event" json:"event,omitempty"`
	XXX_unrecognized []byte                `json:"-"`
}

func (*PersistentSubscriptionStreamEventAppeared) Descriptor

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

func (*PersistentSubscriptionStreamEventAppeared) GetEvent

func (*PersistentSubscriptionStreamEventAppeared) ProtoMessage

func (*PersistentSubscriptionStreamEventAppeared) Reset

func (*PersistentSubscriptionStreamEventAppeared) String

type ReadAllEvents

type ReadAllEvents struct {
	CommitPosition   *int64 `protobuf:"varint,1,req,name=commit_position" json:"commit_position,omitempty"`
	PreparePosition  *int64 `protobuf:"varint,2,req,name=prepare_position" json:"prepare_position,omitempty"`
	MaxCount         *int32 `protobuf:"varint,3,req,name=max_count" json:"max_count,omitempty"`
	ResolveLinkTos   *bool  `protobuf:"varint,4,req,name=resolve_link_tos" json:"resolve_link_tos,omitempty"`
	RequireMaster    *bool  `protobuf:"varint,5,req,name=require_master" json:"require_master,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*ReadAllEvents) Descriptor

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

func (*ReadAllEvents) GetCommitPosition

func (m *ReadAllEvents) GetCommitPosition() int64

func (*ReadAllEvents) GetMaxCount

func (m *ReadAllEvents) GetMaxCount() int32

func (*ReadAllEvents) GetPreparePosition

func (m *ReadAllEvents) GetPreparePosition() int64

func (*ReadAllEvents) GetRequireMaster

func (m *ReadAllEvents) GetRequireMaster() bool

func (*ReadAllEvents) GetResolveLinkTos

func (m *ReadAllEvents) GetResolveLinkTos() bool

func (*ReadAllEvents) ProtoMessage

func (*ReadAllEvents) ProtoMessage()

func (*ReadAllEvents) Reset

func (m *ReadAllEvents) Reset()

func (*ReadAllEvents) String

func (m *ReadAllEvents) String() string

type ReadAllEventsCompleted

type ReadAllEventsCompleted struct {
	CommitPosition      *int64                                `protobuf:"varint,1,req,name=commit_position" json:"commit_position,omitempty"`
	PreparePosition     *int64                                `protobuf:"varint,2,req,name=prepare_position" json:"prepare_position,omitempty"`
	Events              []*ResolvedEvent                      `protobuf:"bytes,3,rep,name=events" json:"events,omitempty"`
	NextCommitPosition  *int64                                `protobuf:"varint,4,req,name=next_commit_position" json:"next_commit_position,omitempty"`
	NextPreparePosition *int64                                `protobuf:"varint,5,req,name=next_prepare_position" json:"next_prepare_position,omitempty"`
	Result              *ReadAllEventsCompleted_ReadAllResult `protobuf:"varint,6,opt,name=result,enum=messages.ReadAllEventsCompleted_ReadAllResult,def=0" json:"result,omitempty"`
	Error               *string                               `protobuf:"bytes,7,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized    []byte                                `json:"-"`
}

func (*ReadAllEventsCompleted) Descriptor

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

func (*ReadAllEventsCompleted) GetCommitPosition

func (m *ReadAllEventsCompleted) GetCommitPosition() int64

func (*ReadAllEventsCompleted) GetError

func (m *ReadAllEventsCompleted) GetError() string

func (*ReadAllEventsCompleted) GetEvents

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

func (*ReadAllEventsCompleted) GetNextCommitPosition

func (m *ReadAllEventsCompleted) GetNextCommitPosition() int64

func (*ReadAllEventsCompleted) GetNextPreparePosition

func (m *ReadAllEventsCompleted) GetNextPreparePosition() int64

func (*ReadAllEventsCompleted) GetPreparePosition

func (m *ReadAllEventsCompleted) GetPreparePosition() int64

func (*ReadAllEventsCompleted) GetResult

func (*ReadAllEventsCompleted) ProtoMessage

func (*ReadAllEventsCompleted) ProtoMessage()

func (*ReadAllEventsCompleted) Reset

func (m *ReadAllEventsCompleted) Reset()

func (*ReadAllEventsCompleted) String

func (m *ReadAllEventsCompleted) String() string

type ReadAllEventsCompleted_ReadAllResult

type ReadAllEventsCompleted_ReadAllResult int32
const (
	ReadAllEventsCompleted_Success      ReadAllEventsCompleted_ReadAllResult = 0
	ReadAllEventsCompleted_NotModified  ReadAllEventsCompleted_ReadAllResult = 1
	ReadAllEventsCompleted_Error        ReadAllEventsCompleted_ReadAllResult = 2
	ReadAllEventsCompleted_AccessDenied ReadAllEventsCompleted_ReadAllResult = 3
)
const Default_ReadAllEventsCompleted_Result ReadAllEventsCompleted_ReadAllResult = ReadAllEventsCompleted_Success

func (ReadAllEventsCompleted_ReadAllResult) Enum

func (ReadAllEventsCompleted_ReadAllResult) EnumDescriptor

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

func (ReadAllEventsCompleted_ReadAllResult) String

func (*ReadAllEventsCompleted_ReadAllResult) UnmarshalJSON

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

type ReadEvent

type ReadEvent struct {
	EventStreamId    *string `protobuf:"bytes,1,req,name=event_stream_id" json:"event_stream_id,omitempty"`
	EventNumber      *int32  `protobuf:"varint,2,req,name=event_number" json:"event_number,omitempty"`
	ResolveLinkTos   *bool   `protobuf:"varint,3,req,name=resolve_link_tos" json:"resolve_link_tos,omitempty"`
	RequireMaster    *bool   `protobuf:"varint,4,req,name=require_master" json:"require_master,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ReadEvent) Descriptor

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

func (*ReadEvent) GetEventNumber

func (m *ReadEvent) GetEventNumber() int32

func (*ReadEvent) GetEventStreamId

func (m *ReadEvent) GetEventStreamId() string

func (*ReadEvent) GetRequireMaster

func (m *ReadEvent) GetRequireMaster() bool

func (*ReadEvent) GetResolveLinkTos

func (m *ReadEvent) GetResolveLinkTos() bool

func (*ReadEvent) ProtoMessage

func (*ReadEvent) ProtoMessage()

func (*ReadEvent) Reset

func (m *ReadEvent) Reset()

func (*ReadEvent) String

func (m *ReadEvent) String() string

type ReadEventCompleted

type ReadEventCompleted struct {
	Result           *ReadEventCompleted_ReadEventResult `protobuf:"varint,1,req,name=result,enum=messages.ReadEventCompleted_ReadEventResult" json:"result,omitempty"`
	Event            *ResolvedIndexedEvent               `protobuf:"bytes,2,req,name=event" json:"event,omitempty"`
	Error            *string                             `protobuf:"bytes,3,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte                              `json:"-"`
}

func (*ReadEventCompleted) Descriptor

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

func (*ReadEventCompleted) GetError

func (m *ReadEventCompleted) GetError() string

func (*ReadEventCompleted) GetEvent

func (*ReadEventCompleted) GetResult

func (*ReadEventCompleted) ProtoMessage

func (*ReadEventCompleted) ProtoMessage()

func (*ReadEventCompleted) Reset

func (m *ReadEventCompleted) Reset()

func (*ReadEventCompleted) String

func (m *ReadEventCompleted) String() string

type ReadEventCompleted_ReadEventResult

type ReadEventCompleted_ReadEventResult int32
const (
	ReadEventCompleted_Success       ReadEventCompleted_ReadEventResult = 0
	ReadEventCompleted_NotFound      ReadEventCompleted_ReadEventResult = 1
	ReadEventCompleted_NoStream      ReadEventCompleted_ReadEventResult = 2
	ReadEventCompleted_StreamDeleted ReadEventCompleted_ReadEventResult = 3
	ReadEventCompleted_Error         ReadEventCompleted_ReadEventResult = 4
	ReadEventCompleted_AccessDenied  ReadEventCompleted_ReadEventResult = 5
)

func (ReadEventCompleted_ReadEventResult) Enum

func (ReadEventCompleted_ReadEventResult) EnumDescriptor

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

func (ReadEventCompleted_ReadEventResult) String

func (*ReadEventCompleted_ReadEventResult) UnmarshalJSON

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

type ReadStreamEvents

type ReadStreamEvents struct {
	EventStreamId    *string `protobuf:"bytes,1,req,name=event_stream_id" json:"event_stream_id,omitempty"`
	FromEventNumber  *int32  `protobuf:"varint,2,req,name=from_event_number" json:"from_event_number,omitempty"`
	MaxCount         *int32  `protobuf:"varint,3,req,name=max_count" json:"max_count,omitempty"`
	ResolveLinkTos   *bool   `protobuf:"varint,4,req,name=resolve_link_tos" json:"resolve_link_tos,omitempty"`
	RequireMaster    *bool   `protobuf:"varint,5,req,name=require_master" json:"require_master,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ReadStreamEvents) Descriptor

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

func (*ReadStreamEvents) GetEventStreamId

func (m *ReadStreamEvents) GetEventStreamId() string

func (*ReadStreamEvents) GetFromEventNumber

func (m *ReadStreamEvents) GetFromEventNumber() int32

func (*ReadStreamEvents) GetMaxCount

func (m *ReadStreamEvents) GetMaxCount() int32

func (*ReadStreamEvents) GetRequireMaster

func (m *ReadStreamEvents) GetRequireMaster() bool

func (*ReadStreamEvents) GetResolveLinkTos

func (m *ReadStreamEvents) GetResolveLinkTos() bool

func (*ReadStreamEvents) ProtoMessage

func (*ReadStreamEvents) ProtoMessage()

func (*ReadStreamEvents) Reset

func (m *ReadStreamEvents) Reset()

func (*ReadStreamEvents) String

func (m *ReadStreamEvents) String() string

type ReadStreamEventsCompleted

type ReadStreamEventsCompleted struct {
	Events             []*ResolvedIndexedEvent                     `protobuf:"bytes,1,rep,name=events" json:"events,omitempty"`
	Result             *ReadStreamEventsCompleted_ReadStreamResult `protobuf:"varint,2,req,name=result,enum=messages.ReadStreamEventsCompleted_ReadStreamResult" json:"result,omitempty"`
	NextEventNumber    *int32                                      `protobuf:"varint,3,req,name=next_event_number" json:"next_event_number,omitempty"`
	LastEventNumber    *int32                                      `protobuf:"varint,4,req,name=last_event_number" json:"last_event_number,omitempty"`
	IsEndOfStream      *bool                                       `protobuf:"varint,5,req,name=is_end_of_stream" json:"is_end_of_stream,omitempty"`
	LastCommitPosition *int64                                      `protobuf:"varint,6,req,name=last_commit_position" json:"last_commit_position,omitempty"`
	Error              *string                                     `protobuf:"bytes,7,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized   []byte                                      `json:"-"`
}

func (*ReadStreamEventsCompleted) Descriptor

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

func (*ReadStreamEventsCompleted) GetError

func (m *ReadStreamEventsCompleted) GetError() string

func (*ReadStreamEventsCompleted) GetEvents

func (*ReadStreamEventsCompleted) GetIsEndOfStream

func (m *ReadStreamEventsCompleted) GetIsEndOfStream() bool

func (*ReadStreamEventsCompleted) GetLastCommitPosition

func (m *ReadStreamEventsCompleted) GetLastCommitPosition() int64

func (*ReadStreamEventsCompleted) GetLastEventNumber

func (m *ReadStreamEventsCompleted) GetLastEventNumber() int32

func (*ReadStreamEventsCompleted) GetNextEventNumber

func (m *ReadStreamEventsCompleted) GetNextEventNumber() int32

func (*ReadStreamEventsCompleted) GetResult

func (*ReadStreamEventsCompleted) ProtoMessage

func (*ReadStreamEventsCompleted) ProtoMessage()

func (*ReadStreamEventsCompleted) Reset

func (m *ReadStreamEventsCompleted) Reset()

func (*ReadStreamEventsCompleted) String

func (m *ReadStreamEventsCompleted) String() string

type ReadStreamEventsCompleted_ReadStreamResult

type ReadStreamEventsCompleted_ReadStreamResult int32
const (
	ReadStreamEventsCompleted_Success       ReadStreamEventsCompleted_ReadStreamResult = 0
	ReadStreamEventsCompleted_NoStream      ReadStreamEventsCompleted_ReadStreamResult = 1
	ReadStreamEventsCompleted_StreamDeleted ReadStreamEventsCompleted_ReadStreamResult = 2
	ReadStreamEventsCompleted_NotModified   ReadStreamEventsCompleted_ReadStreamResult = 3
	ReadStreamEventsCompleted_Error         ReadStreamEventsCompleted_ReadStreamResult = 4
	ReadStreamEventsCompleted_AccessDenied  ReadStreamEventsCompleted_ReadStreamResult = 5
)

func (ReadStreamEventsCompleted_ReadStreamResult) Enum

func (ReadStreamEventsCompleted_ReadStreamResult) EnumDescriptor

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

func (ReadStreamEventsCompleted_ReadStreamResult) String

func (*ReadStreamEventsCompleted_ReadStreamResult) UnmarshalJSON

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

type ResolvedEvent

type ResolvedEvent struct {
	Event            *EventRecord `protobuf:"bytes,1,req,name=event" json:"event,omitempty"`
	Link             *EventRecord `protobuf:"bytes,2,opt,name=link" json:"link,omitempty"`
	CommitPosition   *int64       `protobuf:"varint,3,req,name=commit_position" json:"commit_position,omitempty"`
	PreparePosition  *int64       `protobuf:"varint,4,req,name=prepare_position" json:"prepare_position,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*ResolvedEvent) Descriptor

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

func (*ResolvedEvent) GetCommitPosition

func (m *ResolvedEvent) GetCommitPosition() int64

func (*ResolvedEvent) GetEvent

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

func (*ResolvedEvent) GetPreparePosition

func (m *ResolvedEvent) GetPreparePosition() int64

func (*ResolvedEvent) ProtoMessage

func (*ResolvedEvent) ProtoMessage()

func (*ResolvedEvent) Reset

func (m *ResolvedEvent) Reset()

func (*ResolvedEvent) String

func (m *ResolvedEvent) String() string

type ResolvedIndexedEvent

type ResolvedIndexedEvent struct {
	Event            *EventRecord `protobuf:"bytes,1,opt,name=event" json:"event,omitempty"`
	Link             *EventRecord `protobuf:"bytes,2,opt,name=link" json:"link,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*ResolvedIndexedEvent) Descriptor

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

func (*ResolvedIndexedEvent) GetEvent

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

func (*ResolvedIndexedEvent) ProtoMessage

func (*ResolvedIndexedEvent) ProtoMessage()

func (*ResolvedIndexedEvent) Reset

func (m *ResolvedIndexedEvent) Reset()

func (*ResolvedIndexedEvent) String

func (m *ResolvedIndexedEvent) String() string

type ScavengeDatabase

type ScavengeDatabase struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*ScavengeDatabase) Descriptor

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

func (*ScavengeDatabase) ProtoMessage

func (*ScavengeDatabase) ProtoMessage()

func (*ScavengeDatabase) Reset

func (m *ScavengeDatabase) Reset()

func (*ScavengeDatabase) String

func (m *ScavengeDatabase) String() string

type ScavengeDatabaseCompleted

type ScavengeDatabaseCompleted struct {
	Result           *ScavengeDatabaseCompleted_ScavengeResult `protobuf:"varint,1,req,name=result,enum=messages.ScavengeDatabaseCompleted_ScavengeResult" json:"result,omitempty"`
	Error            *string                                   `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	TotalTimeMs      *int32                                    `protobuf:"varint,3,req,name=total_time_ms" json:"total_time_ms,omitempty"`
	TotalSpaceSaved  *int64                                    `protobuf:"varint,4,req,name=total_space_saved" json:"total_space_saved,omitempty"`
	XXX_unrecognized []byte                                    `json:"-"`
}

func (*ScavengeDatabaseCompleted) Descriptor

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

func (*ScavengeDatabaseCompleted) GetError

func (m *ScavengeDatabaseCompleted) GetError() string

func (*ScavengeDatabaseCompleted) GetResult

func (*ScavengeDatabaseCompleted) GetTotalSpaceSaved

func (m *ScavengeDatabaseCompleted) GetTotalSpaceSaved() int64

func (*ScavengeDatabaseCompleted) GetTotalTimeMs

func (m *ScavengeDatabaseCompleted) GetTotalTimeMs() int32

func (*ScavengeDatabaseCompleted) ProtoMessage

func (*ScavengeDatabaseCompleted) ProtoMessage()

func (*ScavengeDatabaseCompleted) Reset

func (m *ScavengeDatabaseCompleted) Reset()

func (*ScavengeDatabaseCompleted) String

func (m *ScavengeDatabaseCompleted) String() string

type ScavengeDatabaseCompleted_ScavengeResult

type ScavengeDatabaseCompleted_ScavengeResult int32
const (
	ScavengeDatabaseCompleted_Success    ScavengeDatabaseCompleted_ScavengeResult = 0
	ScavengeDatabaseCompleted_InProgress ScavengeDatabaseCompleted_ScavengeResult = 1
	ScavengeDatabaseCompleted_Failed     ScavengeDatabaseCompleted_ScavengeResult = 2
)

func (ScavengeDatabaseCompleted_ScavengeResult) Enum

func (ScavengeDatabaseCompleted_ScavengeResult) EnumDescriptor

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

func (ScavengeDatabaseCompleted_ScavengeResult) String

func (*ScavengeDatabaseCompleted_ScavengeResult) UnmarshalJSON

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

type StreamEventAppeared

type StreamEventAppeared struct {
	Event            *ResolvedEvent `protobuf:"bytes,1,req,name=event" json:"event,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*StreamEventAppeared) Descriptor

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

func (*StreamEventAppeared) GetEvent

func (m *StreamEventAppeared) GetEvent() *ResolvedEvent

func (*StreamEventAppeared) ProtoMessage

func (*StreamEventAppeared) ProtoMessage()

func (*StreamEventAppeared) Reset

func (m *StreamEventAppeared) Reset()

func (*StreamEventAppeared) String

func (m *StreamEventAppeared) String() string

type SubscribeToStream

type SubscribeToStream struct {
	EventStreamId    *string `protobuf:"bytes,1,req,name=event_stream_id" json:"event_stream_id,omitempty"`
	ResolveLinkTos   *bool   `protobuf:"varint,2,req,name=resolve_link_tos" json:"resolve_link_tos,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*SubscribeToStream) Descriptor

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

func (*SubscribeToStream) GetEventStreamId

func (m *SubscribeToStream) GetEventStreamId() string

func (*SubscribeToStream) GetResolveLinkTos

func (m *SubscribeToStream) GetResolveLinkTos() bool

func (*SubscribeToStream) ProtoMessage

func (*SubscribeToStream) ProtoMessage()

func (*SubscribeToStream) Reset

func (m *SubscribeToStream) Reset()

func (*SubscribeToStream) String

func (m *SubscribeToStream) String() string

type SubscriptionConfirmation

type SubscriptionConfirmation struct {
	LastCommitPosition *int64 `protobuf:"varint,1,req,name=last_commit_position" json:"last_commit_position,omitempty"`
	LastEventNumber    *int32 `protobuf:"varint,2,opt,name=last_event_number" json:"last_event_number,omitempty"`
	XXX_unrecognized   []byte `json:"-"`
}

func (*SubscriptionConfirmation) Descriptor

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

func (*SubscriptionConfirmation) GetLastCommitPosition

func (m *SubscriptionConfirmation) GetLastCommitPosition() int64

func (*SubscriptionConfirmation) GetLastEventNumber

func (m *SubscriptionConfirmation) GetLastEventNumber() int32

func (*SubscriptionConfirmation) ProtoMessage

func (*SubscriptionConfirmation) ProtoMessage()

func (*SubscriptionConfirmation) Reset

func (m *SubscriptionConfirmation) Reset()

func (*SubscriptionConfirmation) String

func (m *SubscriptionConfirmation) String() string

type SubscriptionDropped

type SubscriptionDropped struct {
	Reason           *SubscriptionDropped_SubscriptionDropReason `protobuf:"varint,1,opt,name=reason,enum=messages.SubscriptionDropped_SubscriptionDropReason,def=0" json:"reason,omitempty"`
	XXX_unrecognized []byte                                      `json:"-"`
}

func (*SubscriptionDropped) Descriptor

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

func (*SubscriptionDropped) GetReason

func (*SubscriptionDropped) ProtoMessage

func (*SubscriptionDropped) ProtoMessage()

func (*SubscriptionDropped) Reset

func (m *SubscriptionDropped) Reset()

func (*SubscriptionDropped) String

func (m *SubscriptionDropped) String() string

type SubscriptionDropped_SubscriptionDropReason

type SubscriptionDropped_SubscriptionDropReason int32
const (
	SubscriptionDropped_Unsubscribed                  SubscriptionDropped_SubscriptionDropReason = 0
	SubscriptionDropped_AccessDenied                  SubscriptionDropped_SubscriptionDropReason = 1
	SubscriptionDropped_NotFound                      SubscriptionDropped_SubscriptionDropReason = 2
	SubscriptionDropped_PersistentSubscriptionDeleted SubscriptionDropped_SubscriptionDropReason = 3
	SubscriptionDropped_SubscriberMaxCountReached     SubscriptionDropped_SubscriptionDropReason = 4
)

func (SubscriptionDropped_SubscriptionDropReason) Enum

func (SubscriptionDropped_SubscriptionDropReason) EnumDescriptor

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

func (SubscriptionDropped_SubscriptionDropReason) String

func (*SubscriptionDropped_SubscriptionDropReason) UnmarshalJSON

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

type TransactionCommit

type TransactionCommit struct {
	TransactionId    *int64 `protobuf:"varint,1,req,name=transaction_id" json:"transaction_id,omitempty"`
	RequireMaster    *bool  `protobuf:"varint,2,req,name=require_master" json:"require_master,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TransactionCommit) Descriptor

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

func (*TransactionCommit) GetRequireMaster

func (m *TransactionCommit) GetRequireMaster() bool

func (*TransactionCommit) GetTransactionId

func (m *TransactionCommit) GetTransactionId() int64

func (*TransactionCommit) ProtoMessage

func (*TransactionCommit) ProtoMessage()

func (*TransactionCommit) Reset

func (m *TransactionCommit) Reset()

func (*TransactionCommit) String

func (m *TransactionCommit) String() string

type TransactionCommitCompleted

type TransactionCommitCompleted struct {
	TransactionId    *int64           `protobuf:"varint,1,req,name=transaction_id" json:"transaction_id,omitempty"`
	Result           *OperationResult `protobuf:"varint,2,req,name=result,enum=messages.OperationResult" json:"result,omitempty"`
	Message          *string          `protobuf:"bytes,3,opt,name=message" json:"message,omitempty"`
	FirstEventNumber *int32           `protobuf:"varint,4,req,name=first_event_number" json:"first_event_number,omitempty"`
	LastEventNumber  *int32           `protobuf:"varint,5,req,name=last_event_number" json:"last_event_number,omitempty"`
	PreparePosition  *int64           `protobuf:"varint,6,opt,name=prepare_position" json:"prepare_position,omitempty"`
	CommitPosition   *int64           `protobuf:"varint,7,opt,name=commit_position" json:"commit_position,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*TransactionCommitCompleted) Descriptor

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

func (*TransactionCommitCompleted) GetCommitPosition

func (m *TransactionCommitCompleted) GetCommitPosition() int64

func (*TransactionCommitCompleted) GetFirstEventNumber

func (m *TransactionCommitCompleted) GetFirstEventNumber() int32

func (*TransactionCommitCompleted) GetLastEventNumber

func (m *TransactionCommitCompleted) GetLastEventNumber() int32

func (*TransactionCommitCompleted) GetMessage

func (m *TransactionCommitCompleted) GetMessage() string

func (*TransactionCommitCompleted) GetPreparePosition

func (m *TransactionCommitCompleted) GetPreparePosition() int64

func (*TransactionCommitCompleted) GetResult

func (*TransactionCommitCompleted) GetTransactionId

func (m *TransactionCommitCompleted) GetTransactionId() int64

func (*TransactionCommitCompleted) ProtoMessage

func (*TransactionCommitCompleted) ProtoMessage()

func (*TransactionCommitCompleted) Reset

func (m *TransactionCommitCompleted) Reset()

func (*TransactionCommitCompleted) String

func (m *TransactionCommitCompleted) String() string

type TransactionStart

type TransactionStart struct {
	EventStreamId    *string `protobuf:"bytes,1,req,name=event_stream_id" json:"event_stream_id,omitempty"`
	ExpectedVersion  *int32  `protobuf:"varint,2,req,name=expected_version" json:"expected_version,omitempty"`
	RequireMaster    *bool   `protobuf:"varint,3,req,name=require_master" json:"require_master,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*TransactionStart) Descriptor

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

func (*TransactionStart) GetEventStreamId

func (m *TransactionStart) GetEventStreamId() string

func (*TransactionStart) GetExpectedVersion

func (m *TransactionStart) GetExpectedVersion() int32

func (*TransactionStart) GetRequireMaster

func (m *TransactionStart) GetRequireMaster() bool

func (*TransactionStart) ProtoMessage

func (*TransactionStart) ProtoMessage()

func (*TransactionStart) Reset

func (m *TransactionStart) Reset()

func (*TransactionStart) String

func (m *TransactionStart) String() string

type TransactionStartCompleted

type TransactionStartCompleted struct {
	TransactionId    *int64           `protobuf:"varint,1,req,name=transaction_id" json:"transaction_id,omitempty"`
	Result           *OperationResult `protobuf:"varint,2,req,name=result,enum=messages.OperationResult" json:"result,omitempty"`
	Message          *string          `protobuf:"bytes,3,opt,name=message" json:"message,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*TransactionStartCompleted) Descriptor

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

func (*TransactionStartCompleted) GetMessage

func (m *TransactionStartCompleted) GetMessage() string

func (*TransactionStartCompleted) GetResult

func (*TransactionStartCompleted) GetTransactionId

func (m *TransactionStartCompleted) GetTransactionId() int64

func (*TransactionStartCompleted) ProtoMessage

func (*TransactionStartCompleted) ProtoMessage()

func (*TransactionStartCompleted) Reset

func (m *TransactionStartCompleted) Reset()

func (*TransactionStartCompleted) String

func (m *TransactionStartCompleted) String() string

type TransactionWrite

type TransactionWrite struct {
	TransactionId    *int64      `protobuf:"varint,1,req,name=transaction_id" json:"transaction_id,omitempty"`
	Events           []*NewEvent `protobuf:"bytes,2,rep,name=events" json:"events,omitempty"`
	RequireMaster    *bool       `protobuf:"varint,3,req,name=require_master" json:"require_master,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*TransactionWrite) Descriptor

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

func (*TransactionWrite) GetEvents

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

func (*TransactionWrite) GetRequireMaster

func (m *TransactionWrite) GetRequireMaster() bool

func (*TransactionWrite) GetTransactionId

func (m *TransactionWrite) GetTransactionId() int64

func (*TransactionWrite) ProtoMessage

func (*TransactionWrite) ProtoMessage()

func (*TransactionWrite) Reset

func (m *TransactionWrite) Reset()

func (*TransactionWrite) String

func (m *TransactionWrite) String() string

type TransactionWriteCompleted

type TransactionWriteCompleted struct {
	TransactionId    *int64           `protobuf:"varint,1,req,name=transaction_id" json:"transaction_id,omitempty"`
	Result           *OperationResult `protobuf:"varint,2,req,name=result,enum=messages.OperationResult" json:"result,omitempty"`
	Message          *string          `protobuf:"bytes,3,opt,name=message" json:"message,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*TransactionWriteCompleted) Descriptor

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

func (*TransactionWriteCompleted) GetMessage

func (m *TransactionWriteCompleted) GetMessage() string

func (*TransactionWriteCompleted) GetResult

func (*TransactionWriteCompleted) GetTransactionId

func (m *TransactionWriteCompleted) GetTransactionId() int64

func (*TransactionWriteCompleted) ProtoMessage

func (*TransactionWriteCompleted) ProtoMessage()

func (*TransactionWriteCompleted) Reset

func (m *TransactionWriteCompleted) Reset()

func (*TransactionWriteCompleted) String

func (m *TransactionWriteCompleted) String() string

type UnsubscribeFromStream

type UnsubscribeFromStream struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*UnsubscribeFromStream) Descriptor

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

func (*UnsubscribeFromStream) ProtoMessage

func (*UnsubscribeFromStream) ProtoMessage()

func (*UnsubscribeFromStream) Reset

func (m *UnsubscribeFromStream) Reset()

func (*UnsubscribeFromStream) String

func (m *UnsubscribeFromStream) String() string

type UpdatePersistentSubscription

type UpdatePersistentSubscription struct {
	SubscriptionGroupName      *string `protobuf:"bytes,1,req,name=subscription_group_name" json:"subscription_group_name,omitempty"`
	EventStreamId              *string `protobuf:"bytes,2,req,name=event_stream_id" json:"event_stream_id,omitempty"`
	ResolveLinkTos             *bool   `protobuf:"varint,3,req,name=resolve_link_tos" json:"resolve_link_tos,omitempty"`
	StartFrom                  *int32  `protobuf:"varint,4,req,name=start_from" json:"start_from,omitempty"`
	MessageTimeoutMilliseconds *int32  `protobuf:"varint,5,req,name=message_timeout_milliseconds" json:"message_timeout_milliseconds,omitempty"`
	RecordStatistics           *bool   `protobuf:"varint,6,req,name=record_statistics" json:"record_statistics,omitempty"`
	LiveBufferSize             *int32  `protobuf:"varint,7,req,name=live_buffer_size" json:"live_buffer_size,omitempty"`
	ReadBatchSize              *int32  `protobuf:"varint,8,req,name=read_batch_size" json:"read_batch_size,omitempty"`
	BufferSize                 *int32  `protobuf:"varint,9,req,name=buffer_size" json:"buffer_size,omitempty"`
	MaxRetryCount              *int32  `protobuf:"varint,10,req,name=max_retry_count" json:"max_retry_count,omitempty"`
	PreferRoundRobin           *bool   `protobuf:"varint,11,req,name=prefer_round_robin" json:"prefer_round_robin,omitempty"`
	CheckpointAfterTime        *int32  `protobuf:"varint,12,req,name=checkpoint_after_time" json:"checkpoint_after_time,omitempty"`
	CheckpointMaxCount         *int32  `protobuf:"varint,13,req,name=checkpoint_max_count" json:"checkpoint_max_count,omitempty"`
	CheckpointMinCount         *int32  `protobuf:"varint,14,req,name=checkpoint_min_count" json:"checkpoint_min_count,omitempty"`
	SubscriberMaxCount         *int32  `protobuf:"varint,15,req,name=subscriber_max_count" json:"subscriber_max_count,omitempty"`
	NamedConsumerStrategy      *string `protobuf:"bytes,16,opt,name=named_consumer_strategy" json:"named_consumer_strategy,omitempty"`
	XXX_unrecognized           []byte  `json:"-"`
}

func (*UpdatePersistentSubscription) Descriptor

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

func (*UpdatePersistentSubscription) GetBufferSize

func (m *UpdatePersistentSubscription) GetBufferSize() int32

func (*UpdatePersistentSubscription) GetCheckpointAfterTime

func (m *UpdatePersistentSubscription) GetCheckpointAfterTime() int32

func (*UpdatePersistentSubscription) GetCheckpointMaxCount

func (m *UpdatePersistentSubscription) GetCheckpointMaxCount() int32

func (*UpdatePersistentSubscription) GetCheckpointMinCount

func (m *UpdatePersistentSubscription) GetCheckpointMinCount() int32

func (*UpdatePersistentSubscription) GetEventStreamId

func (m *UpdatePersistentSubscription) GetEventStreamId() string

func (*UpdatePersistentSubscription) GetLiveBufferSize

func (m *UpdatePersistentSubscription) GetLiveBufferSize() int32

func (*UpdatePersistentSubscription) GetMaxRetryCount

func (m *UpdatePersistentSubscription) GetMaxRetryCount() int32

func (*UpdatePersistentSubscription) GetMessageTimeoutMilliseconds

func (m *UpdatePersistentSubscription) GetMessageTimeoutMilliseconds() int32

func (*UpdatePersistentSubscription) GetNamedConsumerStrategy

func (m *UpdatePersistentSubscription) GetNamedConsumerStrategy() string

func (*UpdatePersistentSubscription) GetPreferRoundRobin

func (m *UpdatePersistentSubscription) GetPreferRoundRobin() bool

func (*UpdatePersistentSubscription) GetReadBatchSize

func (m *UpdatePersistentSubscription) GetReadBatchSize() int32

func (*UpdatePersistentSubscription) GetRecordStatistics

func (m *UpdatePersistentSubscription) GetRecordStatistics() bool

func (*UpdatePersistentSubscription) GetResolveLinkTos

func (m *UpdatePersistentSubscription) GetResolveLinkTos() bool

func (*UpdatePersistentSubscription) GetStartFrom

func (m *UpdatePersistentSubscription) GetStartFrom() int32

func (*UpdatePersistentSubscription) GetSubscriberMaxCount

func (m *UpdatePersistentSubscription) GetSubscriberMaxCount() int32

func (*UpdatePersistentSubscription) GetSubscriptionGroupName

func (m *UpdatePersistentSubscription) GetSubscriptionGroupName() string

func (*UpdatePersistentSubscription) ProtoMessage

func (*UpdatePersistentSubscription) ProtoMessage()

func (*UpdatePersistentSubscription) Reset

func (m *UpdatePersistentSubscription) Reset()

func (*UpdatePersistentSubscription) String

type UpdatePersistentSubscriptionCompleted

type UpdatePersistentSubscriptionCompleted struct {
	Result           *UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult `` /* 152-byte string literal not displayed */
	Reason           *string                                                                   `protobuf:"bytes,2,opt,name=reason" json:"reason,omitempty"`
	XXX_unrecognized []byte                                                                    `json:"-"`
}

func (*UpdatePersistentSubscriptionCompleted) Descriptor

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

func (*UpdatePersistentSubscriptionCompleted) GetReason

func (*UpdatePersistentSubscriptionCompleted) ProtoMessage

func (*UpdatePersistentSubscriptionCompleted) ProtoMessage()

func (*UpdatePersistentSubscriptionCompleted) Reset

func (*UpdatePersistentSubscriptionCompleted) String

type UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult

type UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult int32
const (
	UpdatePersistentSubscriptionCompleted_Success      UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult = 0
	UpdatePersistentSubscriptionCompleted_DoesNotExist UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult = 1
	UpdatePersistentSubscriptionCompleted_Fail         UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult = 2
	UpdatePersistentSubscriptionCompleted_AccessDenied UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult = 3
)

func (UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult) Enum

func (UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult) EnumDescriptor

func (UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult) String

func (*UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult) UnmarshalJSON

type VNodeState

type VNodeState int
const (
	VNodeState_Initializing VNodeState = 0
	VNodeState_Unknown      VNodeState = 1
	VNodeState_PreReplica   VNodeState = 2
	VNodeState_CatchingUp   VNodeState = 3
	VNodeState_Clone        VNodeState = 4
	VNodeState_Slave        VNodeState = 5
	VNodeState_PreMaster    VNodeState = 6
	VNodeState_Master       VNodeState = 7
	VNodeState_Manager      VNodeState = 8
	VNodeState_ShuttingDown VNodeState = 9
	VNodeState_Shutdown     VNodeState = 10
)

func (VNodeState) String

func (x VNodeState) String() string

type WriteEvents

type WriteEvents struct {
	EventStreamId    *string     `protobuf:"bytes,1,req,name=event_stream_id" json:"event_stream_id,omitempty"`
	ExpectedVersion  *int32      `protobuf:"varint,2,req,name=expected_version" json:"expected_version,omitempty"`
	Events           []*NewEvent `protobuf:"bytes,3,rep,name=events" json:"events,omitempty"`
	RequireMaster    *bool       `protobuf:"varint,4,req,name=require_master" json:"require_master,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*WriteEvents) Descriptor

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

func (*WriteEvents) GetEventStreamId

func (m *WriteEvents) GetEventStreamId() string

func (*WriteEvents) GetEvents

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

func (*WriteEvents) GetExpectedVersion

func (m *WriteEvents) GetExpectedVersion() int32

func (*WriteEvents) GetRequireMaster

func (m *WriteEvents) GetRequireMaster() bool

func (*WriteEvents) ProtoMessage

func (*WriteEvents) ProtoMessage()

func (*WriteEvents) Reset

func (m *WriteEvents) Reset()

func (*WriteEvents) String

func (m *WriteEvents) String() string

type WriteEventsCompleted

type WriteEventsCompleted struct {
	Result           *OperationResult `protobuf:"varint,1,req,name=result,enum=messages.OperationResult" json:"result,omitempty"`
	Message          *string          `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"`
	FirstEventNumber *int32           `protobuf:"varint,3,req,name=first_event_number" json:"first_event_number,omitempty"`
	LastEventNumber  *int32           `protobuf:"varint,4,req,name=last_event_number" json:"last_event_number,omitempty"`
	PreparePosition  *int64           `protobuf:"varint,5,opt,name=prepare_position" json:"prepare_position,omitempty"`
	CommitPosition   *int64           `protobuf:"varint,6,opt,name=commit_position" json:"commit_position,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*WriteEventsCompleted) Descriptor

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

func (*WriteEventsCompleted) GetCommitPosition

func (m *WriteEventsCompleted) GetCommitPosition() int64

func (*WriteEventsCompleted) GetFirstEventNumber

func (m *WriteEventsCompleted) GetFirstEventNumber() int32

func (*WriteEventsCompleted) GetLastEventNumber

func (m *WriteEventsCompleted) GetLastEventNumber() int32

func (*WriteEventsCompleted) GetMessage

func (m *WriteEventsCompleted) GetMessage() string

func (*WriteEventsCompleted) GetPreparePosition

func (m *WriteEventsCompleted) GetPreparePosition() int64

func (*WriteEventsCompleted) GetResult

func (m *WriteEventsCompleted) GetResult() OperationResult

func (*WriteEventsCompleted) ProtoMessage

func (*WriteEventsCompleted) ProtoMessage()

func (*WriteEventsCompleted) Reset

func (m *WriteEventsCompleted) Reset()

func (*WriteEventsCompleted) String

func (m *WriteEventsCompleted) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL