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 (m *ConnectToPersistentSubscription) Reset()

func (*ConnectToPersistentSubscription) String 

func (m *ConnectToPersistentSubscription) String() 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 

func (m *CreatePersistentSubscription) String() 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 (m *CreatePersistentSubscriptionCompleted) GetReason() string

func (*CreatePersistentSubscriptionCompleted) GetResult 

func (m *CreatePersistentSubscriptionCompleted) GetResult() CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult

func (*CreatePersistentSubscriptionCompleted) ProtoMessage 

func (*CreatePersistentSubscriptionCompleted) ProtoMessage()

func (*CreatePersistentSubscriptionCompleted) Reset 

func (m *CreatePersistentSubscriptionCompleted) Reset()

func (*CreatePersistentSubscriptionCompleted) String 

func (m *CreatePersistentSubscriptionCompleted) String() 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
)
const Default_CreatePersistentSubscriptionCompleted_Result CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult = CreatePersistentSubscriptionCompleted_Success

func (CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult) Enum 

func (x CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult) Enum() *CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult

func (CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult) EnumDescriptor 

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

func (CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult) String 

func (x CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult) String() string

func (*CreatePersistentSubscriptionCompleted_CreatePersistentSubscriptionResult) UnmarshalJSON 

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

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 

func (m *DeletePersistentSubscription) String() 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 (m *DeletePersistentSubscriptionCompleted) GetReason() string

func (*DeletePersistentSubscriptionCompleted) GetResult 

func (m *DeletePersistentSubscriptionCompleted) GetResult() DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult

func (*DeletePersistentSubscriptionCompleted) ProtoMessage 

func (*DeletePersistentSubscriptionCompleted) ProtoMessage()

func (*DeletePersistentSubscriptionCompleted) Reset 

func (m *DeletePersistentSubscriptionCompleted) Reset()

func (*DeletePersistentSubscriptionCompleted) String 

func (m *DeletePersistentSubscriptionCompleted) String() 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
)
const Default_DeletePersistentSubscriptionCompleted_Result DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult = DeletePersistentSubscriptionCompleted_Success

func (DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult) Enum 

func (x DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult) Enum() *DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult

func (DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult) EnumDescriptor 

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

func (DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult) String 

func (x DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult) String() string

func (*DeletePersistentSubscriptionCompleted_DeletePersistentSubscriptionResult) UnmarshalJSON 

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

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 (x NotHandled_NotHandledReason) Enum() *NotHandled_NotHandledReason

func (NotHandled_NotHandledReason) EnumDescriptor 

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

func (NotHandled_NotHandledReason) String 

func (x NotHandled_NotHandledReason) String() 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 (m *PersistentSubscriptionAckEvents) Reset()

func (*PersistentSubscriptionAckEvents) String 

func (m *PersistentSubscriptionAckEvents) String() 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 (m *PersistentSubscriptionConfirmation) Reset()

func (*PersistentSubscriptionConfirmation) String 

func (m *PersistentSubscriptionConfirmation) String() 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 (m *PersistentSubscriptionNakEvents) GetAction() PersistentSubscriptionNakEvents_NakAction

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 (m *PersistentSubscriptionNakEvents) Reset()

func (*PersistentSubscriptionNakEvents) String 

func (m *PersistentSubscriptionNakEvents) String() 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 (x PersistentSubscriptionNakEvents_NakAction) Enum() *PersistentSubscriptionNakEvents_NakAction

func (PersistentSubscriptionNakEvents_NakAction) EnumDescriptor 

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

func (PersistentSubscriptionNakEvents_NakAction) String 

func (x PersistentSubscriptionNakEvents_NakAction) String() 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 (m *PersistentSubscriptionStreamEventAppeared) GetEvent() *ResolvedIndexedEvent

func (*PersistentSubscriptionStreamEventAppeared) ProtoMessage 

func (*PersistentSubscriptionStreamEventAppeared) ProtoMessage()

func (*PersistentSubscriptionStreamEventAppeared) Reset 

func (m *PersistentSubscriptionStreamEventAppeared) Reset()

func (*PersistentSubscriptionStreamEventAppeared) String 

func (m *PersistentSubscriptionStreamEventAppeared) String() 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 (m *ReadAllEventsCompleted) GetResult() ReadAllEventsCompleted_ReadAllResult

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 (x ReadAllEventsCompleted_ReadAllResult) Enum() *ReadAllEventsCompleted_ReadAllResult

func (ReadAllEventsCompleted_ReadAllResult) EnumDescriptor 

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

func (ReadAllEventsCompleted_ReadAllResult) String 

func (x ReadAllEventsCompleted_ReadAllResult) String() 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 (m *ReadEventCompleted) GetEvent() *ResolvedIndexedEvent

func (*ReadEventCompleted) GetResult 

func (m *ReadEventCompleted) GetResult() ReadEventCompleted_ReadEventResult

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 (x ReadEventCompleted_ReadEventResult) Enum() *ReadEventCompleted_ReadEventResult

func (ReadEventCompleted_ReadEventResult) EnumDescriptor 

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

func (ReadEventCompleted_ReadEventResult) String 

func (x ReadEventCompleted_ReadEventResult) String() 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 (m *ReadStreamEventsCompleted) GetEvents() []*ResolvedIndexedEvent

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 (m *ReadStreamEventsCompleted) GetResult() ReadStreamEventsCompleted_ReadStreamResult

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 (x ReadStreamEventsCompleted_ReadStreamResult) Enum() *ReadStreamEventsCompleted_ReadStreamResult

func (ReadStreamEventsCompleted_ReadStreamResult) EnumDescriptor 

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

func (ReadStreamEventsCompleted_ReadStreamResult) String 

func (x ReadStreamEventsCompleted_ReadStreamResult) String() 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 (m *ScavengeDatabaseCompleted) GetResult() ScavengeDatabaseCompleted_ScavengeResult

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 (x ScavengeDatabaseCompleted_ScavengeResult) Enum() *ScavengeDatabaseCompleted_ScavengeResult

func (ScavengeDatabaseCompleted_ScavengeResult) EnumDescriptor 

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

func (ScavengeDatabaseCompleted_ScavengeResult) String 

func (x ScavengeDatabaseCompleted_ScavengeResult) String() 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 (m *SubscriptionDropped) GetReason() SubscriptionDropped_SubscriptionDropReason

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
)
const Default_SubscriptionDropped_Reason SubscriptionDropped_SubscriptionDropReason = SubscriptionDropped_Unsubscribed

func (SubscriptionDropped_SubscriptionDropReason) Enum 

func (x SubscriptionDropped_SubscriptionDropReason) Enum() *SubscriptionDropped_SubscriptionDropReason

func (SubscriptionDropped_SubscriptionDropReason) EnumDescriptor 

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

func (SubscriptionDropped_SubscriptionDropReason) String 

func (x SubscriptionDropped_SubscriptionDropReason) String() 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 (m *TransactionCommitCompleted) GetResult() OperationResult

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 (m *TransactionStartCompleted) GetResult() OperationResult

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 (m *TransactionWriteCompleted) GetResult() OperationResult

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 

func (m *UpdatePersistentSubscription) String() 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 (m *UpdatePersistentSubscriptionCompleted) GetReason() string

func (*UpdatePersistentSubscriptionCompleted) GetResult 

func (m *UpdatePersistentSubscriptionCompleted) GetResult() UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult

func (*UpdatePersistentSubscriptionCompleted) ProtoMessage 

func (*UpdatePersistentSubscriptionCompleted) ProtoMessage()

func (*UpdatePersistentSubscriptionCompleted) Reset 

func (m *UpdatePersistentSubscriptionCompleted) Reset()

func (*UpdatePersistentSubscriptionCompleted) String 

func (m *UpdatePersistentSubscriptionCompleted) String() 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
)
const Default_UpdatePersistentSubscriptionCompleted_Result UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult = UpdatePersistentSubscriptionCompleted_Success

func (UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult) Enum 

func (x UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult) Enum() *UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult

func (UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult) EnumDescriptor 

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

func (UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult) String 

func (x UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult) String() string

func (*UpdatePersistentSubscriptionCompleted_UpdatePersistentSubscriptionResult) UnmarshalJSON 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.