axon_server

package
v0.0.6 Latest Latest
Warning

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

 Go to latest Published: May 28, 2020 License: MIT Imports: 8 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ProcessingKey_name = map[int32]string{
	0: "ROUTING_KEY",
	1: "PRIORITY",
	2: "TIMEOUT",
	3: "NR_OF_RESULTS",
}
View Source 
var ProcessingKey_value = map[string]int32{
	"ROUTING_KEY":   0,
	"PRIORITY":      1,
	"TIMEOUT":       2,
	"NR_OF_RESULTS": 3,
}

Functions

func RegisterCommandServiceServer 

func RegisterCommandServiceServer(s *grpc.Server, srv CommandServiceServer)

func RegisterEventStoreServer 

func RegisterEventStoreServer(s *grpc.Server, srv EventStoreServer)

func RegisterPlatformServiceServer 

func RegisterPlatformServiceServer(s *grpc.Server, srv PlatformServiceServer)

func RegisterQueryServiceServer 

func RegisterQueryServiceServer(s *grpc.Server, srv QueryServiceServer)

Types

type ClientIdentification 

type ClientIdentification struct {
	// A unique identifier for this client instance. Is used to distinguish different instances of the same component
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// The name of the component. Several instances of the same component should share this name
	ComponentName string `protobuf:"bytes,2,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"`
	// Any tags associated with the client, which may provide hints and preferences for setting up connections
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// Axon framework version used by the client application instance
	Version              string   `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message containing details about the Client Application

func (*ClientIdentification) Descriptor 

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

func (*ClientIdentification) GetClientId 

func (m *ClientIdentification) GetClientId() string

func (*ClientIdentification) GetComponentName 

func (m *ClientIdentification) GetComponentName() string

func (*ClientIdentification) GetTags 

func (m *ClientIdentification) GetTags() map[string]string

func (*ClientIdentification) GetVersion 

func (m *ClientIdentification) GetVersion() string

func (*ClientIdentification) ProtoMessage 

func (*ClientIdentification) ProtoMessage()

func (*ClientIdentification) Reset 

func (m *ClientIdentification) Reset()

func (*ClientIdentification) String 

func (m *ClientIdentification) String() string

func (*ClientIdentification) XXX_DiscardUnknown 

func (m *ClientIdentification) XXX_DiscardUnknown()

func (*ClientIdentification) XXX_Marshal 

func (m *ClientIdentification) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientIdentification) XXX_Merge 

func (m *ClientIdentification) XXX_Merge(src proto.Message)

func (*ClientIdentification) XXX_Size 

func (m *ClientIdentification) XXX_Size() int

func (*ClientIdentification) XXX_Unmarshal 

func (m *ClientIdentification) XXX_Unmarshal(b []byte) error

type ColumnsResponse 

type ColumnsResponse struct {
	// The names of the columns provided in the query
	Column               []string `protobuf:"bytes,1,rep,name=column,proto3" json:"column,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message containing the names of the columns returned in a Query

func (*ColumnsResponse) Descriptor 

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

func (*ColumnsResponse) GetColumn 

func (m *ColumnsResponse) GetColumn() []string

func (*ColumnsResponse) ProtoMessage 

func (*ColumnsResponse) ProtoMessage()

func (*ColumnsResponse) Reset 

func (m *ColumnsResponse) Reset()

func (*ColumnsResponse) String 

func (m *ColumnsResponse) String() string

func (*ColumnsResponse) XXX_DiscardUnknown 

func (m *ColumnsResponse) XXX_DiscardUnknown()

func (*ColumnsResponse) XXX_Marshal 

func (m *ColumnsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ColumnsResponse) XXX_Merge 

func (m *ColumnsResponse) XXX_Merge(src proto.Message)

func (*ColumnsResponse) XXX_Size 

func (m *ColumnsResponse) XXX_Size() int

func (*ColumnsResponse) XXX_Unmarshal 

func (m *ColumnsResponse) XXX_Unmarshal(b []byte) error

type Command 

type Command struct {
	// The unique identifier of the Command Message
	MessageIdentifier string `protobuf:"bytes,1,opt,name=message_identifier,json=messageIdentifier,proto3" json:"message_identifier,omitempty"`
	// The name of the command, used for routing it to a destination capable of handling it
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// The time at which the command was dispatched
	Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// The payload of the Command, providing details on the instructions for the recipient
	Payload *SerializedObject `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
	// Meta Data entries of the Command Message, providing contextual information to the recipient
	MetaData map[string]*MetaDataValue `` /* 173-byte string literal not displayed */
	// Instructions for AxonServer when routing this Command Message
	ProcessingInstructions []*ProcessingInstruction `` /* 127-byte string literal not displayed */
	// The unique identifier of the component dispatching this message
	ClientId string `protobuf:"bytes,7,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// The name/type of the component dispatching this message
	ComponentName        string   `protobuf:"bytes,8,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A message representing a Command that needs to be routed to a component capable of handling it

func (*Command) Descriptor 

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

func (*Command) GetClientId 

func (m *Command) GetClientId() string

func (*Command) GetComponentName 

func (m *Command) GetComponentName() string

func (*Command) GetMessageIdentifier 

func (m *Command) GetMessageIdentifier() string

func (*Command) GetMetaData 

func (m *Command) GetMetaData() map[string]*MetaDataValue

func (*Command) GetName 

func (m *Command) GetName() string

func (*Command) GetPayload 

func (m *Command) GetPayload() *SerializedObject

func (*Command) GetProcessingInstructions 

func (m *Command) GetProcessingInstructions() []*ProcessingInstruction

func (*Command) GetTimestamp 

func (m *Command) GetTimestamp() int64

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) Reset 

func (m *Command) Reset()

func (*Command) String 

func (m *Command) String() string

func (*Command) XXX_DiscardUnknown 

func (m *Command) XXX_DiscardUnknown()

func (*Command) XXX_Marshal 

func (m *Command) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Command) XXX_Merge 

func (m *Command) XXX_Merge(src proto.Message)

func (*Command) XXX_Size 

func (m *Command) XXX_Size() int

func (*Command) XXX_Unmarshal 

func (m *Command) XXX_Unmarshal(b []byte) error

type CommandProviderInbound 

type CommandProviderInbound struct {
	// The instruction from AxonServer for this component
	//
	// Types that are valid to be assigned to Request:
	//	*CommandProviderInbound_Ack
	//	*CommandProviderInbound_Command
	Request isCommandProviderInbound_Request `protobuf_oneof:"request"`
	// Instruction identifier. If this identifier is set, this instruction will be acknowledged via outbound stream
	InstructionId        string   `protobuf:"bytes,3,opt,name=instruction_id,json=instructionId,proto3" json:"instruction_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

An instruction or confirmation from AxonServer towards the component that provides the Command Handler

func (*CommandProviderInbound) Descriptor 

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

func (*CommandProviderInbound) GetAck 

func (m *CommandProviderInbound) GetAck() *InstructionAck

func (*CommandProviderInbound) GetCommand 

func (m *CommandProviderInbound) GetCommand() *Command

func (*CommandProviderInbound) GetInstructionId 

func (m *CommandProviderInbound) GetInstructionId() string

func (*CommandProviderInbound) GetRequest 

func (m *CommandProviderInbound) GetRequest() isCommandProviderInbound_Request

func (*CommandProviderInbound) ProtoMessage 

func (*CommandProviderInbound) ProtoMessage()

func (*CommandProviderInbound) Reset 

func (m *CommandProviderInbound) Reset()

func (*CommandProviderInbound) String 

func (m *CommandProviderInbound) String() string

func (*CommandProviderInbound) XXX_DiscardUnknown 

func (m *CommandProviderInbound) XXX_DiscardUnknown()

func (*CommandProviderInbound) XXX_Marshal 

func (m *CommandProviderInbound) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandProviderInbound) XXX_Merge 

func (m *CommandProviderInbound) XXX_Merge(src proto.Message)

func (*CommandProviderInbound) XXX_OneofWrappers 

func (*CommandProviderInbound) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*CommandProviderInbound) XXX_Size 

func (m *CommandProviderInbound) XXX_Size() int

func (*CommandProviderInbound) XXX_Unmarshal 

func (m *CommandProviderInbound) XXX_Unmarshal(b []byte) error

type CommandProviderInbound_Ack 

type CommandProviderInbound_Ack struct {
	Ack *InstructionAck `protobuf:"bytes,1,opt,name=ack,proto3,oneof"`
}

type CommandProviderInbound_Command 

type CommandProviderInbound_Command struct {
	Command *Command `protobuf:"bytes,2,opt,name=command,proto3,oneof"`
}

type CommandProviderOutbound 

type CommandProviderOutbound struct {
	// The instruction for AxonServer
	//
	// Types that are valid to be assigned to Request:
	//	*CommandProviderOutbound_Subscribe
	//	*CommandProviderOutbound_Unsubscribe
	//	*CommandProviderOutbound_FlowControl
	//	*CommandProviderOutbound_CommandResponse
	//	*CommandProviderOutbound_Ack
	Request isCommandProviderOutbound_Request `protobuf_oneof:"request"`
	// Instruction identifier. If this identifier is set, this instruction will be acknowledged via inbound stream
	InstructionId        string   `protobuf:"bytes,6,opt,name=instruction_id,json=instructionId,proto3" json:"instruction_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

An instruction from the components that provides the Command Handler towards AxonServer.

func (*CommandProviderOutbound) Descriptor 

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

func (*CommandProviderOutbound) GetAck 

func (m *CommandProviderOutbound) GetAck() *InstructionAck

func (*CommandProviderOutbound) GetCommandResponse 

func (m *CommandProviderOutbound) GetCommandResponse() *CommandResponse

func (*CommandProviderOutbound) GetFlowControl 

func (m *CommandProviderOutbound) GetFlowControl() *FlowControl

func (*CommandProviderOutbound) GetInstructionId 

func (m *CommandProviderOutbound) GetInstructionId() string

func (*CommandProviderOutbound) GetRequest 

func (m *CommandProviderOutbound) GetRequest() isCommandProviderOutbound_Request

func (*CommandProviderOutbound) GetSubscribe 

func (m *CommandProviderOutbound) GetSubscribe() *CommandSubscription

func (*CommandProviderOutbound) GetUnsubscribe 

func (m *CommandProviderOutbound) GetUnsubscribe() *CommandSubscription

func (*CommandProviderOutbound) ProtoMessage 

func (*CommandProviderOutbound) ProtoMessage()

func (*CommandProviderOutbound) Reset 

func (m *CommandProviderOutbound) Reset()

func (*CommandProviderOutbound) String 

func (m *CommandProviderOutbound) String() string

func (*CommandProviderOutbound) XXX_DiscardUnknown 

func (m *CommandProviderOutbound) XXX_DiscardUnknown()

func (*CommandProviderOutbound) XXX_Marshal 

func (m *CommandProviderOutbound) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandProviderOutbound) XXX_Merge 

func (m *CommandProviderOutbound) XXX_Merge(src proto.Message)

func (*CommandProviderOutbound) XXX_OneofWrappers 

func (*CommandProviderOutbound) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*CommandProviderOutbound) XXX_Size 

func (m *CommandProviderOutbound) XXX_Size() int

func (*CommandProviderOutbound) XXX_Unmarshal 

func (m *CommandProviderOutbound) XXX_Unmarshal(b []byte) error

type CommandProviderOutbound_Ack 

type CommandProviderOutbound_Ack struct {
	Ack *InstructionAck `protobuf:"bytes,5,opt,name=ack,proto3,oneof"`
}

type CommandProviderOutbound_CommandResponse 

type CommandProviderOutbound_CommandResponse struct {
	CommandResponse *CommandResponse `protobuf:"bytes,4,opt,name=command_response,json=commandResponse,proto3,oneof"`
}

type CommandProviderOutbound_FlowControl 

type CommandProviderOutbound_FlowControl struct {
	FlowControl *FlowControl `protobuf:"bytes,3,opt,name=flow_control,json=flowControl,proto3,oneof"`
}

type CommandProviderOutbound_Subscribe 

type CommandProviderOutbound_Subscribe struct {
	Subscribe *CommandSubscription `protobuf:"bytes,1,opt,name=subscribe,proto3,oneof"`
}

type CommandProviderOutbound_Unsubscribe 

type CommandProviderOutbound_Unsubscribe struct {
	Unsubscribe *CommandSubscription `protobuf:"bytes,2,opt,name=unsubscribe,proto3,oneof"`
}

type CommandResponse 

type CommandResponse struct {
	// The unique identifier of the response message
	MessageIdentifier string `protobuf:"bytes,1,opt,name=message_identifier,json=messageIdentifier,proto3" json:"message_identifier,omitempty"`
	// An error code describing the error, if any
	ErrorCode string `protobuf:"bytes,2,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"`
	// A detailed description of the error
	ErrorMessage *ErrorMessage `protobuf:"bytes,3,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// The payload to provide as a result to the dispatcher
	Payload *SerializedObject `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
	// Any meta data entries providing contextual information back to the dispatcher
	MetaData map[string]*MetaDataValue `` /* 173-byte string literal not displayed */
	// Instructions for AxonServer when routing this Command Response Message
	ProcessingInstructions []*ProcessingInstruction `` /* 127-byte string literal not displayed */
	// The unique identifier of the Command Message for which this is the response
	RequestIdentifier    string   `protobuf:"bytes,7,opt,name=request_identifier,json=requestIdentifier,proto3" json:"request_identifier,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message representing the result of Command Handler execution

func (*CommandResponse) Descriptor 

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

func (*CommandResponse) GetErrorCode 

func (m *CommandResponse) GetErrorCode() string

func (*CommandResponse) GetErrorMessage 

func (m *CommandResponse) GetErrorMessage() *ErrorMessage

func (*CommandResponse) GetMessageIdentifier 

func (m *CommandResponse) GetMessageIdentifier() string

func (*CommandResponse) GetMetaData 

func (m *CommandResponse) GetMetaData() map[string]*MetaDataValue

func (*CommandResponse) GetPayload 

func (m *CommandResponse) GetPayload() *SerializedObject

func (*CommandResponse) GetProcessingInstructions 

func (m *CommandResponse) GetProcessingInstructions() []*ProcessingInstruction

func (*CommandResponse) GetRequestIdentifier 

func (m *CommandResponse) GetRequestIdentifier() string

func (*CommandResponse) ProtoMessage 

func (*CommandResponse) ProtoMessage()

func (*CommandResponse) Reset 

func (m *CommandResponse) Reset()

func (*CommandResponse) String 

func (m *CommandResponse) String() string

func (*CommandResponse) XXX_DiscardUnknown 

func (m *CommandResponse) XXX_DiscardUnknown()

func (*CommandResponse) XXX_Marshal 

func (m *CommandResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandResponse) XXX_Merge 

func (m *CommandResponse) XXX_Merge(src proto.Message)

func (*CommandResponse) XXX_Size 

func (m *CommandResponse) XXX_Size() int

func (*CommandResponse) XXX_Unmarshal 

func (m *CommandResponse) XXX_Unmarshal(b []byte) error

type CommandServiceClient 

type CommandServiceClient interface {
	// Opens a stream allowing clients to register command handlers and receive commands.
	OpenStream(ctx context.Context, opts ...grpc.CallOption) (CommandService_OpenStreamClient, error)
	// Dispatches the given command, returning the result of command execution
	Dispatch(ctx context.Context, in *Command, opts ...grpc.CallOption) (*CommandResponse, error)
}

CommandServiceClient is the client API for CommandService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewCommandServiceClient 

func NewCommandServiceClient(cc grpc.ClientConnInterface) CommandServiceClient

type CommandServiceServer 

type CommandServiceServer interface {
	// Opens a stream allowing clients to register command handlers and receive commands.
	OpenStream(CommandService_OpenStreamServer) error
	// Dispatches the given command, returning the result of command execution
	Dispatch(context.Context, *Command) (*CommandResponse, error)
}

CommandServiceServer is the server API for CommandService service.

type CommandService_OpenStreamClient 

type CommandService_OpenStreamClient interface {
	Send(*CommandProviderOutbound) error
	Recv() (*CommandProviderInbound, error)
	grpc.ClientStream
}

type CommandService_OpenStreamServer 

type CommandService_OpenStreamServer interface {
	Send(*CommandProviderInbound) error
	Recv() (*CommandProviderOutbound, error)
	grpc.ServerStream
}

type CommandSubscription 

type CommandSubscription struct {
	// A unique identifier for this subscription. This identifier is returned in Acknowledgements to allow
	//pipelining of subscription messages
	MessageId string `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// The name of the command the component can handle
	Command string `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
	// The name/type of the component handling the command
	ComponentName string `protobuf:"bytes,3,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"`
	// The unique identifier of the component instance subscribing
	ClientId string `protobuf:"bytes,4,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// A number that represents the client's relative load capacity compared to other clients.
	//This information is interpreted by Axon Server in relation to the other connected nodes' values.
	//Used to balance the dispatching of commands. If set to 0, Axon Server consider 100 as default value.
	LoadFactor           int32    `protobuf:"varint,5,opt,name=load_factor,json=loadFactor,proto3" json:"load_factor,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message describing a component's capability of handling a command type

func (*CommandSubscription) Descriptor 

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

func (*CommandSubscription) GetClientId 

func (m *CommandSubscription) GetClientId() string

func (*CommandSubscription) GetCommand 

func (m *CommandSubscription) GetCommand() string

func (*CommandSubscription) GetComponentName 

func (m *CommandSubscription) GetComponentName() string

func (*CommandSubscription) GetLoadFactor 

func (m *CommandSubscription) GetLoadFactor() int32

func (*CommandSubscription) GetMessageId 

func (m *CommandSubscription) GetMessageId() string

func (*CommandSubscription) ProtoMessage 

func (*CommandSubscription) ProtoMessage()

func (*CommandSubscription) Reset 

func (m *CommandSubscription) Reset()

func (*CommandSubscription) String 

func (m *CommandSubscription) String() string

func (*CommandSubscription) XXX_DiscardUnknown 

func (m *CommandSubscription) XXX_DiscardUnknown()

func (*CommandSubscription) XXX_Marshal 

func (m *CommandSubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandSubscription) XXX_Merge 

func (m *CommandSubscription) XXX_Merge(src proto.Message)

func (*CommandSubscription) XXX_Size 

func (m *CommandSubscription) XXX_Size() int

func (*CommandSubscription) XXX_Unmarshal 

func (m *CommandSubscription) XXX_Unmarshal(b []byte) error

type Confirmation 

type Confirmation struct {
	// True when successful, otherwise false
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A confirmation to a request from the client

func (*Confirmation) Descriptor 

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

func (*Confirmation) GetSuccess 

func (m *Confirmation) GetSuccess() bool

func (*Confirmation) ProtoMessage 

func (*Confirmation) ProtoMessage()

func (*Confirmation) Reset 

func (m *Confirmation) Reset()

func (*Confirmation) String 

func (m *Confirmation) String() string

func (*Confirmation) XXX_DiscardUnknown 

func (m *Confirmation) XXX_DiscardUnknown()

func (*Confirmation) XXX_Marshal 

func (m *Confirmation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Confirmation) XXX_Merge 

func (m *Confirmation) XXX_Merge(src proto.Message)

func (*Confirmation) XXX_Size 

func (m *Confirmation) XXX_Size() int

func (*Confirmation) XXX_Unmarshal 

func (m *Confirmation) XXX_Unmarshal(b []byte) error

type ErrorMessage 

type ErrorMessage struct {
	// A human readable message explaining the error
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// A description of the location (client component, server) where the error occurred
	Location string `protobuf:"bytes,2,opt,name=location,proto3" json:"location,omitempty"`
	// A collection of messages providing more details about root causes of the error
	Details []string `protobuf:"bytes,3,rep,name=details,proto3" json:"details,omitempty"`
	// An Error Code identifying the type of error
	ErrorCode            string   `protobuf:"bytes,4,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message containing details of an error

func (*ErrorMessage) Descriptor 

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

func (*ErrorMessage) GetDetails 

func (m *ErrorMessage) GetDetails() []string

func (*ErrorMessage) GetErrorCode 

func (m *ErrorMessage) GetErrorCode() string

func (*ErrorMessage) GetLocation 

func (m *ErrorMessage) GetLocation() string

func (*ErrorMessage) GetMessage 

func (m *ErrorMessage) GetMessage() string

func (*ErrorMessage) ProtoMessage 

func (*ErrorMessage) ProtoMessage()

func (*ErrorMessage) Reset 

func (m *ErrorMessage) Reset()

func (*ErrorMessage) String 

func (m *ErrorMessage) String() string

func (*ErrorMessage) XXX_DiscardUnknown 

func (m *ErrorMessage) XXX_DiscardUnknown()

func (*ErrorMessage) XXX_Marshal 

func (m *ErrorMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ErrorMessage) XXX_Merge 

func (m *ErrorMessage) XXX_Merge(src proto.Message)

func (*ErrorMessage) XXX_Size 

func (m *ErrorMessage) XXX_Size() int

func (*ErrorMessage) XXX_Unmarshal 

func (m *ErrorMessage) XXX_Unmarshal(b []byte) error

type Event 

type Event struct {
	// The unique identifier of this event
	MessageIdentifier string `protobuf:"bytes,1,opt,name=message_identifier,json=messageIdentifier,proto3" json:"message_identifier,omitempty"`
	// The identifier of the Aggregate instance that published this event, if any
	AggregateIdentifier string `protobuf:"bytes,2,opt,name=aggregate_identifier,json=aggregateIdentifier,proto3" json:"aggregate_identifier,omitempty"`
	// The sequence number of the Event in the Aggregate instance that published it, if any
	AggregateSequenceNumber int64 `` /* 133-byte string literal not displayed */
	// The Type of the Aggregate instance that published this Event, if any
	AggregateType string `protobuf:"bytes,4,opt,name=aggregate_type,json=aggregateType,proto3" json:"aggregate_type,omitempty"`
	// The timestamp of the Event
	Timestamp int64 `protobuf:"varint,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// The Payload of the Event
	Payload *SerializedObject `protobuf:"bytes,6,opt,name=payload,proto3" json:"payload,omitempty"`
	// The Meta Data of the Event
	MetaData map[string]*MetaDataValue `` /* 173-byte string literal not displayed */
	// Flag indicating whether the Event is a snapshot Event
	Snapshot             bool     `protobuf:"varint,8,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message containing the information of an Event

func (*Event) Descriptor 

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

func (*Event) GetAggregateIdentifier 

func (m *Event) GetAggregateIdentifier() string

func (*Event) GetAggregateSequenceNumber 

func (m *Event) GetAggregateSequenceNumber() int64

func (*Event) GetAggregateType 

func (m *Event) GetAggregateType() string

func (*Event) GetMessageIdentifier 

func (m *Event) GetMessageIdentifier() string

func (*Event) GetMetaData 

func (m *Event) GetMetaData() map[string]*MetaDataValue

func (*Event) GetPayload 

func (m *Event) GetPayload() *SerializedObject

func (*Event) GetSnapshot 

func (m *Event) GetSnapshot() bool

func (*Event) GetTimestamp 

func (m *Event) GetTimestamp() int64

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) String 

func (m *Event) String() string

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event) XXX_Merge 

func (m *Event) XXX_Merge(src proto.Message)

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

func (m *Event) XXX_Unmarshal(b []byte) error

type EventProcessorInfo 

type EventProcessorInfo struct {
	// The logical name of this processor.
	ProcessorName string `protobuf:"bytes,1,opt,name=processor_name,json=processorName,proto3" json:"processor_name,omitempty"`
	// The mode in which this processor is reading Events, for example: 'Tracking' or 'Subscribing'
	Mode string `protobuf:"bytes,2,opt,name=mode,proto3" json:"mode,omitempty"`
	// The number of threads currently actively processing Events
	ActiveThreads int32 `protobuf:"varint,3,opt,name=active_threads,json=activeThreads,proto3" json:"active_threads,omitempty"`
	// Flag indicating whether the processor is running
	Running bool `protobuf:"varint,4,opt,name=running,proto3" json:"running,omitempty"`
	// Flag indicating whether the processor, when stopped, did so because of an irrecoverable Error
	Error bool `protobuf:"varint,5,opt,name=error,proto3" json:"error,omitempty"`
	// Status details of each of the Segments for which Events are being processed. This is only provided by Tracking
	//Event Processors.
	SegmentStatus []*EventProcessorInfo_SegmentStatus `protobuf:"bytes,6,rep,name=segment_status,json=segmentStatus,proto3" json:"segment_status,omitempty"`
	// The number of threads the processor has available to assign to Segments.
	//Will report 0 if all threads are assigned a Segment.
	AvailableThreads     int32    `protobuf:"varint,7,opt,name=available_threads,json=availableThreads,proto3" json:"available_threads,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message containing information about the status of a Tracking Event Processor

func (*EventProcessorInfo) Descriptor 

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

func (*EventProcessorInfo) GetActiveThreads 

func (m *EventProcessorInfo) GetActiveThreads() int32

func (*EventProcessorInfo) GetAvailableThreads 

func (m *EventProcessorInfo) GetAvailableThreads() int32

func (*EventProcessorInfo) GetError 

func (m *EventProcessorInfo) GetError() bool

func (*EventProcessorInfo) GetMode 

func (m *EventProcessorInfo) GetMode() string

func (*EventProcessorInfo) GetProcessorName 

func (m *EventProcessorInfo) GetProcessorName() string

func (*EventProcessorInfo) GetRunning 

func (m *EventProcessorInfo) GetRunning() bool

func (*EventProcessorInfo) GetSegmentStatus 

func (m *EventProcessorInfo) GetSegmentStatus() []*EventProcessorInfo_SegmentStatus

func (*EventProcessorInfo) ProtoMessage 

func (*EventProcessorInfo) ProtoMessage()

func (*EventProcessorInfo) Reset 

func (m *EventProcessorInfo) Reset()

func (*EventProcessorInfo) String 

func (m *EventProcessorInfo) String() string

func (*EventProcessorInfo) XXX_DiscardUnknown 

func (m *EventProcessorInfo) XXX_DiscardUnknown()

func (*EventProcessorInfo) XXX_Marshal 

func (m *EventProcessorInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventProcessorInfo) XXX_Merge 

func (m *EventProcessorInfo) XXX_Merge(src proto.Message)

func (*EventProcessorInfo) XXX_Size 

func (m *EventProcessorInfo) XXX_Size() int

func (*EventProcessorInfo) XXX_Unmarshal 

func (m *EventProcessorInfo) XXX_Unmarshal(b []byte) error

type EventProcessorInfo_SegmentStatus 

type EventProcessorInfo_SegmentStatus struct {
	// The ID of the Segment for which the status is reported
	SegmentId int32 `protobuf:"varint,1,opt,name=segment_id,json=segmentId,proto3" json:"segment_id,omitempty"`
	// Indicates whether the Segment has "Caught Up" with the Head of the Event Stream
	CaughtUp bool `protobuf:"varint,2,opt,name=caught_up,json=caughtUp,proto3" json:"caught_up,omitempty"`
	// Indicates whether the Segment is "Replaying" historic events after a Reset.
	Replaying bool `protobuf:"varint,3,opt,name=replaying,proto3" json:"replaying,omitempty"`
	// The fraction this segment processes. A fraction of 2 means 1/2, 4 means 1/4, etc.
	OnePartOf int32 `protobuf:"varint,4,opt,name=one_part_of,json=onePartOf,proto3" json:"one_part_of,omitempty"`
	// The approximate position of the token in the stream.
	TokenPosition int64 `protobuf:"varint,5,opt,name=token_position,json=tokenPosition,proto3" json:"token_position,omitempty"`
	// Information about the error state of the Segment, if applicable.
	ErrorState           string   `protobuf:"bytes,6,opt,name=error_state,json=errorState,proto3" json:"error_state,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message containing information about the status of a Segment of a Tracking Event Processor

func (*EventProcessorInfo_SegmentStatus) Descriptor 

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

func (*EventProcessorInfo_SegmentStatus) GetCaughtUp 

func (m *EventProcessorInfo_SegmentStatus) GetCaughtUp() bool

func (*EventProcessorInfo_SegmentStatus) GetErrorState 

func (m *EventProcessorInfo_SegmentStatus) GetErrorState() string

func (*EventProcessorInfo_SegmentStatus) GetOnePartOf 

func (m *EventProcessorInfo_SegmentStatus) GetOnePartOf() int32

func (*EventProcessorInfo_SegmentStatus) GetReplaying 

func (m *EventProcessorInfo_SegmentStatus) GetReplaying() bool

func (*EventProcessorInfo_SegmentStatus) GetSegmentId 

func (m *EventProcessorInfo_SegmentStatus) GetSegmentId() int32

func (*EventProcessorInfo_SegmentStatus) GetTokenPosition 

func (m *EventProcessorInfo_SegmentStatus) GetTokenPosition() int64

func (*EventProcessorInfo_SegmentStatus) ProtoMessage 

func (*EventProcessorInfo_SegmentStatus) ProtoMessage()

func (*EventProcessorInfo_SegmentStatus) Reset 

func (m *EventProcessorInfo_SegmentStatus) Reset()

func (*EventProcessorInfo_SegmentStatus) String 

func (m *EventProcessorInfo_SegmentStatus) String() string

func (*EventProcessorInfo_SegmentStatus) XXX_DiscardUnknown 

func (m *EventProcessorInfo_SegmentStatus) XXX_DiscardUnknown()

func (*EventProcessorInfo_SegmentStatus) XXX_Marshal 

func (m *EventProcessorInfo_SegmentStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventProcessorInfo_SegmentStatus) XXX_Merge 

func (m *EventProcessorInfo_SegmentStatus) XXX_Merge(src proto.Message)

func (*EventProcessorInfo_SegmentStatus) XXX_Size 

func (m *EventProcessorInfo_SegmentStatus) XXX_Size() int

func (*EventProcessorInfo_SegmentStatus) XXX_Unmarshal 

func (m *EventProcessorInfo_SegmentStatus) XXX_Unmarshal(b []byte) error

type EventProcessorReference 

type EventProcessorReference struct {
	// The name of the Event Processor
	ProcessorName        string   `protobuf:"bytes,1,opt,name=processor_name,json=processorName,proto3" json:"processor_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message providing reference to an Event Processor

func (*EventProcessorReference) Descriptor 

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

func (*EventProcessorReference) GetProcessorName 

func (m *EventProcessorReference) GetProcessorName() string

func (*EventProcessorReference) ProtoMessage 

func (*EventProcessorReference) ProtoMessage()

func (*EventProcessorReference) Reset 

func (m *EventProcessorReference) Reset()

func (*EventProcessorReference) String 

func (m *EventProcessorReference) String() string

func (*EventProcessorReference) XXX_DiscardUnknown 

func (m *EventProcessorReference) XXX_DiscardUnknown()

func (*EventProcessorReference) XXX_Marshal 

func (m *EventProcessorReference) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventProcessorReference) XXX_Merge 

func (m *EventProcessorReference) XXX_Merge(src proto.Message)

func (*EventProcessorReference) XXX_Size 

func (m *EventProcessorReference) XXX_Size() int

func (*EventProcessorReference) XXX_Unmarshal 

func (m *EventProcessorReference) XXX_Unmarshal(b []byte) error

type EventProcessorSegmentReference 

type EventProcessorSegmentReference struct {
	// The name of the Event Processor
	ProcessorName string `protobuf:"bytes,1,opt,name=processor_name,json=processorName,proto3" json:"processor_name,omitempty"`
	// The identifier of the Segment
	SegmentIdentifier    int32    `protobuf:"varint,2,opt,name=segment_identifier,json=segmentIdentifier,proto3" json:"segment_identifier,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message providing reference to a Segment of an Event Processor

func (*EventProcessorSegmentReference) Descriptor 

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

func (*EventProcessorSegmentReference) GetProcessorName 

func (m *EventProcessorSegmentReference) GetProcessorName() string

func (*EventProcessorSegmentReference) GetSegmentIdentifier 

func (m *EventProcessorSegmentReference) GetSegmentIdentifier() int32

func (*EventProcessorSegmentReference) ProtoMessage 

func (*EventProcessorSegmentReference) ProtoMessage()

func (*EventProcessorSegmentReference) Reset 

func (m *EventProcessorSegmentReference) Reset()

func (*EventProcessorSegmentReference) String 

func (m *EventProcessorSegmentReference) String() string

func (*EventProcessorSegmentReference) XXX_DiscardUnknown 

func (m *EventProcessorSegmentReference) XXX_DiscardUnknown()

func (*EventProcessorSegmentReference) XXX_Marshal 

func (m *EventProcessorSegmentReference) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventProcessorSegmentReference) XXX_Merge 

func (m *EventProcessorSegmentReference) XXX_Merge(src proto.Message)

func (*EventProcessorSegmentReference) XXX_Size 

func (m *EventProcessorSegmentReference) XXX_Size() int

func (*EventProcessorSegmentReference) XXX_Unmarshal 

func (m *EventProcessorSegmentReference) XXX_Unmarshal(b []byte) error

type EventStoreClient 

type EventStoreClient interface {
	// Accepts a stream of Events returning a Confirmation when completed.
	AppendEvent(ctx context.Context, opts ...grpc.CallOption) (EventStore_AppendEventClient, error)
	// Accepts a Snapshot event returning a Confirmation when completed.
	AppendSnapshot(ctx context.Context, in *Event, opts ...grpc.CallOption) (*Confirmation, error)
	// Retrieves the Events for a given aggregate. Results are streamed rather than returned at once.
	ListAggregateEvents(ctx context.Context, in *GetAggregateEventsRequest, opts ...grpc.CallOption) (EventStore_ListAggregateEventsClient, error)
	// Retrieves the Snapshots for a given aggregate. Results are streamed rather than returned at once.
	ListAggregateSnapshots(ctx context.Context, in *GetAggregateSnapshotsRequest, opts ...grpc.CallOption) (EventStore_ListAggregateSnapshotsClient, error)
	// Retrieves the Events from a given tracking token. Results are streamed rather than returned at once.
	ListEvents(ctx context.Context, opts ...grpc.CallOption) (EventStore_ListEventsClient, error)
	// Gets the highest sequence number for a specific aggregate.
	ReadHighestSequenceNr(ctx context.Context, in *ReadHighestSequenceNrRequest, opts ...grpc.CallOption) (*ReadHighestSequenceNrResponse, error)
	// Performs a query on the event store, returns a stream of results. Input is a stream to allow flow control from the
	// client
	QueryEvents(ctx context.Context, opts ...grpc.CallOption) (EventStore_QueryEventsClient, error)
	// Retrieves the first token available in event store (typically 0). Returns 0 when no events in store.
	GetFirstToken(ctx context.Context, in *GetFirstTokenRequest, opts ...grpc.CallOption) (*TrackingToken, error)
	// Retrieves the last committed token in event store. Returns -1 when no events in store.
	GetLastToken(ctx context.Context, in *GetLastTokenRequest, opts ...grpc.CallOption) (*TrackingToken, error)
	// Retrieves the token of the first token of an event from specified time in event store. Returns -1 when no events in store.
	GetTokenAt(ctx context.Context, in *GetTokenAtRequest, opts ...grpc.CallOption) (*TrackingToken, error)
}

EventStoreClient is the client API for EventStore service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewEventStoreClient 

func NewEventStoreClient(cc grpc.ClientConnInterface) EventStoreClient

type EventStoreServer 

type EventStoreServer interface {
	// Accepts a stream of Events returning a Confirmation when completed.
	AppendEvent(EventStore_AppendEventServer) error
	// Accepts a Snapshot event returning a Confirmation when completed.
	AppendSnapshot(context.Context, *Event) (*Confirmation, error)
	// Retrieves the Events for a given aggregate. Results are streamed rather than returned at once.
	ListAggregateEvents(*GetAggregateEventsRequest, EventStore_ListAggregateEventsServer) error
	// Retrieves the Snapshots for a given aggregate. Results are streamed rather than returned at once.
	ListAggregateSnapshots(*GetAggregateSnapshotsRequest, EventStore_ListAggregateSnapshotsServer) error
	// Retrieves the Events from a given tracking token. Results are streamed rather than returned at once.
	ListEvents(EventStore_ListEventsServer) error
	// Gets the highest sequence number for a specific aggregate.
	ReadHighestSequenceNr(context.Context, *ReadHighestSequenceNrRequest) (*ReadHighestSequenceNrResponse, error)
	// Performs a query on the event store, returns a stream of results. Input is a stream to allow flow control from the
	// client
	QueryEvents(EventStore_QueryEventsServer) error
	// Retrieves the first token available in event store (typically 0). Returns 0 when no events in store.
	GetFirstToken(context.Context, *GetFirstTokenRequest) (*TrackingToken, error)
	// Retrieves the last committed token in event store. Returns -1 when no events in store.
	GetLastToken(context.Context, *GetLastTokenRequest) (*TrackingToken, error)
	// Retrieves the token of the first token of an event from specified time in event store. Returns -1 when no events in store.
	GetTokenAt(context.Context, *GetTokenAtRequest) (*TrackingToken, error)
}

EventStoreServer is the server API for EventStore service.

type EventStore_AppendEventClient 

type EventStore_AppendEventClient interface {
	Send(*Event) error
	CloseAndRecv() (*Confirmation, error)
	grpc.ClientStream
}

type EventStore_AppendEventServer 

type EventStore_AppendEventServer interface {
	SendAndClose(*Confirmation) error
	Recv() (*Event, error)
	grpc.ServerStream
}

type EventStore_ListAggregateEventsClient 

type EventStore_ListAggregateEventsClient interface {
	Recv() (*Event, error)
	grpc.ClientStream
}

type EventStore_ListAggregateEventsServer 

type EventStore_ListAggregateEventsServer interface {
	Send(*Event) error
	grpc.ServerStream
}

type EventStore_ListAggregateSnapshotsClient 

type EventStore_ListAggregateSnapshotsClient interface {
	Recv() (*Event, error)
	grpc.ClientStream
}

type EventStore_ListAggregateSnapshotsServer 

type EventStore_ListAggregateSnapshotsServer interface {
	Send(*Event) error
	grpc.ServerStream
}

type EventStore_ListEventsClient 

type EventStore_ListEventsClient interface {
	Send(*GetEventsRequest) error
	Recv() (*EventWithToken, error)
	grpc.ClientStream
}

type EventStore_ListEventsServer 

type EventStore_ListEventsServer interface {
	Send(*EventWithToken) error
	Recv() (*GetEventsRequest, error)
	grpc.ServerStream
}

type EventStore_QueryEventsClient 

type EventStore_QueryEventsClient interface {
	Send(*QueryEventsRequest) error
	Recv() (*QueryEventsResponse, error)
	grpc.ClientStream
}

type EventStore_QueryEventsServer 

type EventStore_QueryEventsServer interface {
	Send(*QueryEventsResponse) error
	Recv() (*QueryEventsRequest, error)
	grpc.ServerStream
}

type EventWithToken 

type EventWithToken struct {
	// The Token representing the position of this Event in the Stream
	Token int64 `protobuf:"varint,1,opt,name=token,proto3" json:"token,omitempty"`
	// The actual Event Message
	Event                *Event   `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message wrapping an Event and a Tracking Token

func (*EventWithToken) Descriptor 

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

func (*EventWithToken) GetEvent 

func (m *EventWithToken) GetEvent() *Event

func (*EventWithToken) GetToken 

func (m *EventWithToken) GetToken() int64

func (*EventWithToken) ProtoMessage 

func (*EventWithToken) ProtoMessage()

func (*EventWithToken) Reset 

func (m *EventWithToken) Reset()

func (*EventWithToken) String 

func (m *EventWithToken) String() string

func (*EventWithToken) XXX_DiscardUnknown 

func (m *EventWithToken) XXX_DiscardUnknown()

func (*EventWithToken) XXX_Marshal 

func (m *EventWithToken) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventWithToken) XXX_Merge 

func (m *EventWithToken) XXX_Merge(src proto.Message)

func (*EventWithToken) XXX_Size 

func (m *EventWithToken) XXX_Size() int

func (*EventWithToken) XXX_Unmarshal 

func (m *EventWithToken) XXX_Unmarshal(b []byte) error

type FlowControl 

type FlowControl struct {
	// The ClientID of the component providing additional permits
	ClientId string `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// The number of permits to provide
	Permits              int64    `protobuf:"varint,3,opt,name=permits,proto3" json:"permits,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message used for Flow Control instruction, providing the counterpart with additional permits for sending messages

func (*FlowControl) Descriptor 

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

func (*FlowControl) GetClientId 

func (m *FlowControl) GetClientId() string

func (*FlowControl) GetPermits 

func (m *FlowControl) GetPermits() int64

func (*FlowControl) ProtoMessage 

func (*FlowControl) ProtoMessage()

func (*FlowControl) Reset 

func (m *FlowControl) Reset()

func (*FlowControl) String 

func (m *FlowControl) String() string

func (*FlowControl) XXX_DiscardUnknown 

func (m *FlowControl) XXX_DiscardUnknown()

func (*FlowControl) XXX_Marshal 

func (m *FlowControl) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlowControl) XXX_Merge 

func (m *FlowControl) XXX_Merge(src proto.Message)

func (*FlowControl) XXX_Size 

func (m *FlowControl) XXX_Size() int

func (*FlowControl) XXX_Unmarshal 

func (m *FlowControl) XXX_Unmarshal(b []byte) error

type GetAggregateEventsRequest 

type GetAggregateEventsRequest struct {
	// The identifier of the aggregate to read events for
	AggregateId string `protobuf:"bytes,1,opt,name=aggregate_id,json=aggregateId,proto3" json:"aggregate_id,omitempty"`
	// The sequence number of the first event to receive
	InitialSequence int64 `protobuf:"varint,2,opt,name=initial_sequence,json=initialSequence,proto3" json:"initial_sequence,omitempty"`
	// Whether a snapshot may be returned as first element in the stream
	AllowSnapshots       bool     `protobuf:"varint,3,opt,name=allow_snapshots,json=allowSnapshots,proto3" json:"allow_snapshots,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request describing the desire to read events for a specific Aggregate

func (*GetAggregateEventsRequest) Descriptor 

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

func (*GetAggregateEventsRequest) GetAggregateId 

func (m *GetAggregateEventsRequest) GetAggregateId() string

func (*GetAggregateEventsRequest) GetAllowSnapshots 

func (m *GetAggregateEventsRequest) GetAllowSnapshots() bool

func (*GetAggregateEventsRequest) GetInitialSequence 

func (m *GetAggregateEventsRequest) GetInitialSequence() int64

func (*GetAggregateEventsRequest) ProtoMessage 

func (*GetAggregateEventsRequest) ProtoMessage()

func (*GetAggregateEventsRequest) Reset 

func (m *GetAggregateEventsRequest) Reset()

func (*GetAggregateEventsRequest) String 

func (m *GetAggregateEventsRequest) String() string

func (*GetAggregateEventsRequest) XXX_DiscardUnknown 

func (m *GetAggregateEventsRequest) XXX_DiscardUnknown()

func (*GetAggregateEventsRequest) XXX_Marshal 

func (m *GetAggregateEventsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetAggregateEventsRequest) XXX_Merge 

func (m *GetAggregateEventsRequest) XXX_Merge(src proto.Message)

func (*GetAggregateEventsRequest) XXX_Size 

func (m *GetAggregateEventsRequest) XXX_Size() int

func (*GetAggregateEventsRequest) XXX_Unmarshal 

func (m *GetAggregateEventsRequest) XXX_Unmarshal(b []byte) error

type GetAggregateSnapshotsRequest 

type GetAggregateSnapshotsRequest struct {
	// The identifier to fetch the snapshots for
	AggregateId string `protobuf:"bytes,1,opt,name=aggregate_id,json=aggregateId,proto3" json:"aggregate_id,omitempty"`
	// The minimal sequence number of the snapshots to retrieve
	InitialSequence int64 `protobuf:"varint,2,opt,name=initial_sequence,json=initialSequence,proto3" json:"initial_sequence,omitempty"`
	// The maximum sequence number of the snapshots to retrieve
	MaxSequence int64 `protobuf:"varint,3,opt,name=max_sequence,json=maxSequence,proto3" json:"max_sequence,omitempty"`
	// The maximum number of results to stream
	MaxResults           int32    `protobuf:"varint,4,opt,name=max_results,json=maxResults,proto3" json:"max_results,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request message to retrieve Snapshot Events for a specific Aggregate instance

func (*GetAggregateSnapshotsRequest) Descriptor 

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

func (*GetAggregateSnapshotsRequest) GetAggregateId 

func (m *GetAggregateSnapshotsRequest) GetAggregateId() string

func (*GetAggregateSnapshotsRequest) GetInitialSequence 

func (m *GetAggregateSnapshotsRequest) GetInitialSequence() int64

func (*GetAggregateSnapshotsRequest) GetMaxResults 

func (m *GetAggregateSnapshotsRequest) GetMaxResults() int32

func (*GetAggregateSnapshotsRequest) GetMaxSequence 

func (m *GetAggregateSnapshotsRequest) GetMaxSequence() int64

func (*GetAggregateSnapshotsRequest) ProtoMessage 

func (*GetAggregateSnapshotsRequest) ProtoMessage()

func (*GetAggregateSnapshotsRequest) Reset 

func (m *GetAggregateSnapshotsRequest) Reset()

func (*GetAggregateSnapshotsRequest) String 

func (m *GetAggregateSnapshotsRequest) String() string

func (*GetAggregateSnapshotsRequest) XXX_DiscardUnknown 

func (m *GetAggregateSnapshotsRequest) XXX_DiscardUnknown()

func (*GetAggregateSnapshotsRequest) XXX_Marshal 

func (m *GetAggregateSnapshotsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetAggregateSnapshotsRequest) XXX_Merge 

func (m *GetAggregateSnapshotsRequest) XXX_Merge(src proto.Message)

func (*GetAggregateSnapshotsRequest) XXX_Size 

func (m *GetAggregateSnapshotsRequest) XXX_Size() int

func (*GetAggregateSnapshotsRequest) XXX_Unmarshal 

func (m *GetAggregateSnapshotsRequest) XXX_Unmarshal(b []byte) error

type GetEventsRequest 

type GetEventsRequest struct {
	// The token to start streaming from
	TrackingToken int64 `protobuf:"varint,1,opt,name=tracking_token,json=trackingToken,proto3" json:"tracking_token,omitempty"`
	// The number of messages the server may send before it needs to wait for more permits
	NumberOfPermits int64 `protobuf:"varint,2,opt,name=number_of_permits,json=numberOfPermits,proto3" json:"number_of_permits,omitempty"`
	// The unique identifier of this client instance. Used for monitoring.
	ClientId string `protobuf:"bytes,3,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// The component name of this client instance. Used for monitoring.
	ComponentName string `protobuf:"bytes,4,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"`
	// The name of the processor requesting this stream. Used for monitoring.
	Processor string `protobuf:"bytes,5,opt,name=processor,proto3" json:"processor,omitempty"`
	// An enumeration of payload types that need to be blacklisted. The Server will stop sending messages of these
	//types in order to reduce I/O. Note that the Server may occasionally send a blacklisted message to prevent
	//time-outs and stale tokens on clients.
	Blacklist            []*PayloadDescription `protobuf:"bytes,6,rep,name=blacklist,proto3" json:"blacklist,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

Request message to open an Event Stream from the Event Store.

func (*GetEventsRequest) Descriptor 

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

func (*GetEventsRequest) GetBlacklist 

func (m *GetEventsRequest) GetBlacklist() []*PayloadDescription

func (*GetEventsRequest) GetClientId 

func (m *GetEventsRequest) GetClientId() string

func (*GetEventsRequest) GetComponentName 

func (m *GetEventsRequest) GetComponentName() string

func (*GetEventsRequest) GetNumberOfPermits 

func (m *GetEventsRequest) GetNumberOfPermits() int64

func (*GetEventsRequest) GetProcessor 

func (m *GetEventsRequest) GetProcessor() string

func (*GetEventsRequest) GetTrackingToken 

func (m *GetEventsRequest) GetTrackingToken() int64

func (*GetEventsRequest) ProtoMessage 

func (*GetEventsRequest) ProtoMessage()

func (*GetEventsRequest) Reset 

func (m *GetEventsRequest) Reset()

func (*GetEventsRequest) String 

func (m *GetEventsRequest) String() string

func (*GetEventsRequest) XXX_DiscardUnknown 

func (m *GetEventsRequest) XXX_DiscardUnknown()

func (*GetEventsRequest) XXX_Marshal 

func (m *GetEventsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetEventsRequest) XXX_Merge 

func (m *GetEventsRequest) XXX_Merge(src proto.Message)

func (*GetEventsRequest) XXX_Size 

func (m *GetEventsRequest) XXX_Size() int

func (*GetEventsRequest) XXX_Unmarshal 

func (m *GetEventsRequest) XXX_Unmarshal(b []byte) error

type GetFirstTokenRequest 

type GetFirstTokenRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request message to receive the first Token (Tail Token) of the Event Stream

func (*GetFirstTokenRequest) Descriptor 

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

func (*GetFirstTokenRequest) ProtoMessage 

func (*GetFirstTokenRequest) ProtoMessage()

func (*GetFirstTokenRequest) Reset 

func (m *GetFirstTokenRequest) Reset()

func (*GetFirstTokenRequest) String 

func (m *GetFirstTokenRequest) String() string

func (*GetFirstTokenRequest) XXX_DiscardUnknown 

func (m *GetFirstTokenRequest) XXX_DiscardUnknown()

func (*GetFirstTokenRequest) XXX_Marshal 

func (m *GetFirstTokenRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetFirstTokenRequest) XXX_Merge 

func (m *GetFirstTokenRequest) XXX_Merge(src proto.Message)

func (*GetFirstTokenRequest) XXX_Size 

func (m *GetFirstTokenRequest) XXX_Size() int

func (*GetFirstTokenRequest) XXX_Unmarshal 

func (m *GetFirstTokenRequest) XXX_Unmarshal(b []byte) error

type GetLastTokenRequest 

type GetLastTokenRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request message to receive the last Token (Head Token) of the Event Stream

func (*GetLastTokenRequest) Descriptor 

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

func (*GetLastTokenRequest) ProtoMessage 

func (*GetLastTokenRequest) ProtoMessage()

func (*GetLastTokenRequest) Reset 

func (m *GetLastTokenRequest) Reset()

func (*GetLastTokenRequest) String 

func (m *GetLastTokenRequest) String() string

func (*GetLastTokenRequest) XXX_DiscardUnknown 

func (m *GetLastTokenRequest) XXX_DiscardUnknown()

func (*GetLastTokenRequest) XXX_Marshal 

func (m *GetLastTokenRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetLastTokenRequest) XXX_Merge 

func (m *GetLastTokenRequest) XXX_Merge(src proto.Message)

func (*GetLastTokenRequest) XXX_Size 

func (m *GetLastTokenRequest) XXX_Size() int

func (*GetLastTokenRequest) XXX_Unmarshal 

func (m *GetLastTokenRequest) XXX_Unmarshal(b []byte) error

type GetTokenAtRequest 

type GetTokenAtRequest struct {
	// Timestamp expressed as milliseconds since epoch
	Instant              int64    `protobuf:"varint,1,opt,name=instant,proto3" json:"instant,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request message to receive the Token that starts streaming events from the given timestamp

func (*GetTokenAtRequest) Descriptor 

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

func (*GetTokenAtRequest) GetInstant 

func (m *GetTokenAtRequest) GetInstant() int64

func (*GetTokenAtRequest) ProtoMessage 

func (*GetTokenAtRequest) ProtoMessage()

func (*GetTokenAtRequest) Reset 

func (m *GetTokenAtRequest) Reset()

func (*GetTokenAtRequest) String 

func (m *GetTokenAtRequest) String() string

func (*GetTokenAtRequest) XXX_DiscardUnknown 

func (m *GetTokenAtRequest) XXX_DiscardUnknown()

func (*GetTokenAtRequest) XXX_Marshal 

func (m *GetTokenAtRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetTokenAtRequest) XXX_Merge 

func (m *GetTokenAtRequest) XXX_Merge(src proto.Message)

func (*GetTokenAtRequest) XXX_Size 

func (m *GetTokenAtRequest) XXX_Size() int

func (*GetTokenAtRequest) XXX_Unmarshal 

func (m *GetTokenAtRequest) XXX_Unmarshal(b []byte) error

type Heartbeat 

type Heartbeat struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Heartbeat) Descriptor 

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

func (*Heartbeat) ProtoMessage 

func (*Heartbeat) ProtoMessage()

func (*Heartbeat) Reset 

func (m *Heartbeat) Reset()

func (*Heartbeat) String 

func (m *Heartbeat) String() string

func (*Heartbeat) XXX_DiscardUnknown 

func (m *Heartbeat) XXX_DiscardUnknown()

func (*Heartbeat) XXX_Marshal 

func (m *Heartbeat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Heartbeat) XXX_Merge 

func (m *Heartbeat) XXX_Merge(src proto.Message)

func (*Heartbeat) XXX_Size 

func (m *Heartbeat) XXX_Size() int

func (*Heartbeat) XXX_Unmarshal 

func (m *Heartbeat) XXX_Unmarshal(b []byte) error

type InstructionAck 

type InstructionAck struct {
	// The identifier of the instruction
	InstructionId string `protobuf:"bytes,1,opt,name=instruction_id,json=instructionId,proto3" json:"instruction_id,omitempty"`
	// Indicator whether the instruction was acknowledged successfully
	Success bool `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	// Set if instruction acknowledgement failed.
	Error                *ErrorMessage `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Message describing instruction acknowledgement

func (*InstructionAck) Descriptor 

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

func (*InstructionAck) GetError 

func (m *InstructionAck) GetError() *ErrorMessage

func (*InstructionAck) GetInstructionId 

func (m *InstructionAck) GetInstructionId() string

func (*InstructionAck) GetSuccess 

func (m *InstructionAck) GetSuccess() bool

func (*InstructionAck) ProtoMessage 

func (*InstructionAck) ProtoMessage()

func (*InstructionAck) Reset 

func (m *InstructionAck) Reset()

func (*InstructionAck) String 

func (m *InstructionAck) String() string

func (*InstructionAck) XXX_DiscardUnknown 

func (m *InstructionAck) XXX_DiscardUnknown()

func (*InstructionAck) XXX_Marshal 

func (m *InstructionAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InstructionAck) XXX_Merge 

func (m *InstructionAck) XXX_Merge(src proto.Message)

func (*InstructionAck) XXX_Size 

func (m *InstructionAck) XXX_Size() int

func (*InstructionAck) XXX_Unmarshal 

func (m *InstructionAck) XXX_Unmarshal(b []byte) error

type MetaDataValue 

type MetaDataValue struct {
	// The data of the MetaData entry, depending on the type of data it contains.
	//
	// Types that are valid to be assigned to Data:
	//	*MetaDataValue_TextValue
	//	*MetaDataValue_NumberValue
	//	*MetaDataValue_BooleanValue
	//	*MetaDataValue_DoubleValue
	//	*MetaDataValue_BytesValue
	Data                 isMetaDataValue_Data `protobuf_oneof:"data"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

The value of a MetaData entry.

func (*MetaDataValue) Descriptor 

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

func (*MetaDataValue) GetBooleanValue 

func (m *MetaDataValue) GetBooleanValue() bool

func (*MetaDataValue) GetBytesValue 

func (m *MetaDataValue) GetBytesValue() *SerializedObject

func (*MetaDataValue) GetData 

func (m *MetaDataValue) GetData() isMetaDataValue_Data

func (*MetaDataValue) GetDoubleValue 

func (m *MetaDataValue) GetDoubleValue() float64

func (*MetaDataValue) GetNumberValue 

func (m *MetaDataValue) GetNumberValue() int64

func (*MetaDataValue) GetTextValue 

func (m *MetaDataValue) GetTextValue() string

func (*MetaDataValue) ProtoMessage 

func (*MetaDataValue) ProtoMessage()

func (*MetaDataValue) Reset 

func (m *MetaDataValue) Reset()

func (*MetaDataValue) String 

func (m *MetaDataValue) String() string

func (*MetaDataValue) XXX_DiscardUnknown 

func (m *MetaDataValue) XXX_DiscardUnknown()

func (*MetaDataValue) XXX_Marshal 

func (m *MetaDataValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetaDataValue) XXX_Merge 

func (m *MetaDataValue) XXX_Merge(src proto.Message)

func (*MetaDataValue) XXX_OneofWrappers 

func (*MetaDataValue) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*MetaDataValue) XXX_Size 

func (m *MetaDataValue) XXX_Size() int

func (*MetaDataValue) XXX_Unmarshal 

func (m *MetaDataValue) XXX_Unmarshal(b []byte) error

type MetaDataValue_BooleanValue 

type MetaDataValue_BooleanValue struct {
	BooleanValue bool `protobuf:"varint,3,opt,name=boolean_value,json=booleanValue,proto3,oneof"`
}

type MetaDataValue_BytesValue 

type MetaDataValue_BytesValue struct {
	BytesValue *SerializedObject `protobuf:"bytes,5,opt,name=bytes_value,json=bytesValue,proto3,oneof"`
}

type MetaDataValue_DoubleValue 

type MetaDataValue_DoubleValue struct {
	DoubleValue float64 `protobuf:"fixed64,4,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

type MetaDataValue_NumberValue 

type MetaDataValue_NumberValue struct {
	NumberValue int64 `protobuf:"zigzag64,2,opt,name=number_value,json=numberValue,proto3,oneof"`
}

type MetaDataValue_TextValue 

type MetaDataValue_TextValue struct {
	TextValue string `protobuf:"bytes,1,opt,name=text_value,json=textValue,proto3,oneof"`
}

type NodeInfo 

type NodeInfo struct {
	// The host name to use when connecting to this node
	HostName string `protobuf:"bytes,1,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"`
	// The port number for gRPC connections
	GrpcPort int32 `protobuf:"varint,2,opt,name=grpc_port,json=grpcPort,proto3" json:"grpc_port,omitempty"`
	// The port number for HTTP connections
	HttpPort int32 `protobuf:"varint,3,opt,name=http_port,json=httpPort,proto3" json:"http_port,omitempty"`
	// The version identifier of the API
	Version int32 `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"`
	// The unique name of the node to connect with, for purpose of debugging
	NodeName             string   `protobuf:"bytes,5,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message containing connection information for an AxonServer Node

func (*NodeInfo) Descriptor 

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

func (*NodeInfo) GetGrpcPort 

func (m *NodeInfo) GetGrpcPort() int32

func (*NodeInfo) GetHostName 

func (m *NodeInfo) GetHostName() string

func (*NodeInfo) GetHttpPort 

func (m *NodeInfo) GetHttpPort() int32

func (*NodeInfo) GetNodeName 

func (m *NodeInfo) GetNodeName() string

func (*NodeInfo) GetVersion 

func (m *NodeInfo) GetVersion() int32

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) Reset 

func (m *NodeInfo) Reset()

func (*NodeInfo) String 

func (m *NodeInfo) String() string

func (*NodeInfo) XXX_DiscardUnknown 

func (m *NodeInfo) XXX_DiscardUnknown()

func (*NodeInfo) XXX_Marshal 

func (m *NodeInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeInfo) XXX_Merge 

func (m *NodeInfo) XXX_Merge(src proto.Message)

func (*NodeInfo) XXX_Size 

func (m *NodeInfo) XXX_Size() int

func (*NodeInfo) XXX_Unmarshal 

func (m *NodeInfo) XXX_Unmarshal(b []byte) error

type PayloadDescription 

type PayloadDescription struct {
	// The type identifier of the Payload
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// The revision of the Payload Type
	Revision             string   `protobuf:"bytes,2,opt,name=revision,proto3" json:"revision,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Description of a Payload Type

func (*PayloadDescription) Descriptor 

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

func (*PayloadDescription) GetRevision 

func (m *PayloadDescription) GetRevision() string

func (*PayloadDescription) GetType 

func (m *PayloadDescription) GetType() string

func (*PayloadDescription) ProtoMessage 

func (*PayloadDescription) ProtoMessage()

func (*PayloadDescription) Reset 

func (m *PayloadDescription) Reset()

func (*PayloadDescription) String 

func (m *PayloadDescription) String() string

func (*PayloadDescription) XXX_DiscardUnknown 

func (m *PayloadDescription) XXX_DiscardUnknown()

func (*PayloadDescription) XXX_Marshal 

func (m *PayloadDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PayloadDescription) XXX_Merge 

func (m *PayloadDescription) XXX_Merge(src proto.Message)

func (*PayloadDescription) XXX_Size 

func (m *PayloadDescription) XXX_Size() int

func (*PayloadDescription) XXX_Unmarshal 

func (m *PayloadDescription) XXX_Unmarshal(b []byte) error

type PlatformInboundInstruction 

type PlatformInboundInstruction struct {
	// The actual instruction to send
	//
	// Types that are valid to be assigned to Request:
	//	*PlatformInboundInstruction_Register
	//	*PlatformInboundInstruction_EventProcessorInfo
	//	*PlatformInboundInstruction_Heartbeat
	//	*PlatformInboundInstruction_Ack
	Request isPlatformInboundInstruction_Request `protobuf_oneof:"request"`
	// Instruction identifier. If this identifier is set, this instruction will be acknowledged via outbound stream
	InstructionId        string   `protobuf:"bytes,5,opt,name=instruction_id,json=instructionId,proto3" json:"instruction_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

An instruction from Application Node to the AxonServer platform

func (*PlatformInboundInstruction) Descriptor 

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

func (*PlatformInboundInstruction) GetAck 

func (m *PlatformInboundInstruction) GetAck() *InstructionAck

func (*PlatformInboundInstruction) GetEventProcessorInfo 

func (m *PlatformInboundInstruction) GetEventProcessorInfo() *EventProcessorInfo

func (*PlatformInboundInstruction) GetHeartbeat 

func (m *PlatformInboundInstruction) GetHeartbeat() *Heartbeat

func (*PlatformInboundInstruction) GetInstructionId 

func (m *PlatformInboundInstruction) GetInstructionId() string

func (*PlatformInboundInstruction) GetRegister 

func (m *PlatformInboundInstruction) GetRegister() *ClientIdentification

func (*PlatformInboundInstruction) GetRequest 

func (m *PlatformInboundInstruction) GetRequest() isPlatformInboundInstruction_Request

func (*PlatformInboundInstruction) ProtoMessage 

func (*PlatformInboundInstruction) ProtoMessage()

func (*PlatformInboundInstruction) Reset 

func (m *PlatformInboundInstruction) Reset()

func (*PlatformInboundInstruction) String 

func (m *PlatformInboundInstruction) String() string

func (*PlatformInboundInstruction) XXX_DiscardUnknown 

func (m *PlatformInboundInstruction) XXX_DiscardUnknown()

func (*PlatformInboundInstruction) XXX_Marshal 

func (m *PlatformInboundInstruction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PlatformInboundInstruction) XXX_Merge 

func (m *PlatformInboundInstruction) XXX_Merge(src proto.Message)

func (*PlatformInboundInstruction) XXX_OneofWrappers 

func (*PlatformInboundInstruction) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*PlatformInboundInstruction) XXX_Size 

func (m *PlatformInboundInstruction) XXX_Size() int

func (*PlatformInboundInstruction) XXX_Unmarshal 

func (m *PlatformInboundInstruction) XXX_Unmarshal(b []byte) error

type PlatformInboundInstruction_Ack 

type PlatformInboundInstruction_Ack struct {
	Ack *InstructionAck `protobuf:"bytes,4,opt,name=ack,proto3,oneof"`
}

type PlatformInboundInstruction_EventProcessorInfo 

type PlatformInboundInstruction_EventProcessorInfo struct {
	EventProcessorInfo *EventProcessorInfo `protobuf:"bytes,2,opt,name=event_processor_info,json=eventProcessorInfo,proto3,oneof"`
}

type PlatformInboundInstruction_Heartbeat 

type PlatformInboundInstruction_Heartbeat struct {
	Heartbeat *Heartbeat `protobuf:"bytes,3,opt,name=heartbeat,proto3,oneof"`
}

type PlatformInboundInstruction_Register 

type PlatformInboundInstruction_Register struct {
	Register *ClientIdentification `protobuf:"bytes,1,opt,name=register,proto3,oneof"`
}

type PlatformInfo 

type PlatformInfo struct {
	// The connection details of the node the client should connect with
	Primary *NodeInfo `protobuf:"bytes,1,opt,name=primary,proto3" json:"primary,omitempty"`
	// Flag indicating that the connection may be reused to connect. When true, the client _may_ reuse the connection
	//established for the GetPlatformServer request for subsequent requests.
	SameConnection       bool     `protobuf:"varint,2,opt,name=same_connection,json=sameConnection,proto3" json:"same_connection,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message containing connection information of the node to Connect with

func (*PlatformInfo) Descriptor 

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

func (*PlatformInfo) GetPrimary 

func (m *PlatformInfo) GetPrimary() *NodeInfo

func (*PlatformInfo) GetSameConnection 

func (m *PlatformInfo) GetSameConnection() bool

func (*PlatformInfo) ProtoMessage 

func (*PlatformInfo) ProtoMessage()

func (*PlatformInfo) Reset 

func (m *PlatformInfo) Reset()

func (*PlatformInfo) String 

func (m *PlatformInfo) String() string

func (*PlatformInfo) XXX_DiscardUnknown 

func (m *PlatformInfo) XXX_DiscardUnknown()

func (*PlatformInfo) XXX_Marshal 

func (m *PlatformInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PlatformInfo) XXX_Merge 

func (m *PlatformInfo) XXX_Merge(src proto.Message)

func (*PlatformInfo) XXX_Size 

func (m *PlatformInfo) XXX_Size() int

func (*PlatformInfo) XXX_Unmarshal 

func (m *PlatformInfo) XXX_Unmarshal(b []byte) error

type PlatformOutboundInstruction 

type PlatformOutboundInstruction struct {
	// The actual instruction or information
	//
	// Types that are valid to be assigned to Request:
	//	*PlatformOutboundInstruction_NodeNotification
	//	*PlatformOutboundInstruction_RequestReconnect
	//	*PlatformOutboundInstruction_PauseEventProcessor
	//	*PlatformOutboundInstruction_StartEventProcessor
	//	*PlatformOutboundInstruction_ReleaseSegment
	//	*PlatformOutboundInstruction_RequestEventProcessorInfo
	//	*PlatformOutboundInstruction_SplitEventProcessorSegment
	//	*PlatformOutboundInstruction_MergeEventProcessorSegment
	//	*PlatformOutboundInstruction_Heartbeat
	//	*PlatformOutboundInstruction_Ack
	Request isPlatformOutboundInstruction_Request `protobuf_oneof:"request"`
	// Instruction identifier. If this identifier is set, this instruction will be acknowledged via inbound stream
	InstructionId        string   `protobuf:"bytes,12,opt,name=instruction_id,json=instructionId,proto3" json:"instruction_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

An instruction or information from the AxonServer Platform to the Application Node

func (*PlatformOutboundInstruction) Descriptor 

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

func (*PlatformOutboundInstruction) GetAck 

func (m *PlatformOutboundInstruction) GetAck() *InstructionAck

func (*PlatformOutboundInstruction) GetHeartbeat 

func (m *PlatformOutboundInstruction) GetHeartbeat() *Heartbeat

func (*PlatformOutboundInstruction) GetInstructionId 

func (m *PlatformOutboundInstruction) GetInstructionId() string

func (*PlatformOutboundInstruction) GetMergeEventProcessorSegment 

func (m *PlatformOutboundInstruction) GetMergeEventProcessorSegment() *EventProcessorSegmentReference

func (*PlatformOutboundInstruction) GetNodeNotification 

func (m *PlatformOutboundInstruction) GetNodeNotification() *NodeInfo

func (*PlatformOutboundInstruction) GetPauseEventProcessor 

func (m *PlatformOutboundInstruction) GetPauseEventProcessor() *EventProcessorReference

func (*PlatformOutboundInstruction) GetReleaseSegment 

func (m *PlatformOutboundInstruction) GetReleaseSegment() *EventProcessorSegmentReference

func (*PlatformOutboundInstruction) GetRequest 

func (m *PlatformOutboundInstruction) GetRequest() isPlatformOutboundInstruction_Request

func (*PlatformOutboundInstruction) GetRequestEventProcessorInfo 

func (m *PlatformOutboundInstruction) GetRequestEventProcessorInfo() *EventProcessorReference

func (*PlatformOutboundInstruction) GetRequestReconnect 

func (m *PlatformOutboundInstruction) GetRequestReconnect() *RequestReconnect

func (*PlatformOutboundInstruction) GetSplitEventProcessorSegment 

func (m *PlatformOutboundInstruction) GetSplitEventProcessorSegment() *EventProcessorSegmentReference

func (*PlatformOutboundInstruction) GetStartEventProcessor 

func (m *PlatformOutboundInstruction) GetStartEventProcessor() *EventProcessorReference

func (*PlatformOutboundInstruction) ProtoMessage 

func (*PlatformOutboundInstruction) ProtoMessage()

func (*PlatformOutboundInstruction) Reset 

func (m *PlatformOutboundInstruction) Reset()

func (*PlatformOutboundInstruction) String 

func (m *PlatformOutboundInstruction) String() string

func (*PlatformOutboundInstruction) XXX_DiscardUnknown 

func (m *PlatformOutboundInstruction) XXX_DiscardUnknown()

func (*PlatformOutboundInstruction) XXX_Marshal 

func (m *PlatformOutboundInstruction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PlatformOutboundInstruction) XXX_Merge 

func (m *PlatformOutboundInstruction) XXX_Merge(src proto.Message)

func (*PlatformOutboundInstruction) XXX_OneofWrappers 

func (*PlatformOutboundInstruction) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*PlatformOutboundInstruction) XXX_Size 

func (m *PlatformOutboundInstruction) XXX_Size() int

func (*PlatformOutboundInstruction) XXX_Unmarshal 

func (m *PlatformOutboundInstruction) XXX_Unmarshal(b []byte) error

type PlatformOutboundInstruction_Ack 

type PlatformOutboundInstruction_Ack struct {
	Ack *InstructionAck `protobuf:"bytes,11,opt,name=ack,proto3,oneof"`
}

type PlatformOutboundInstruction_Heartbeat 

type PlatformOutboundInstruction_Heartbeat struct {
	Heartbeat *Heartbeat `protobuf:"bytes,10,opt,name=heartbeat,proto3,oneof"`
}

type PlatformOutboundInstruction_MergeEventProcessorSegment 

type PlatformOutboundInstruction_MergeEventProcessorSegment struct {
	MergeEventProcessorSegment *EventProcessorSegmentReference `protobuf:"bytes,9,opt,name=merge_event_processor_segment,json=mergeEventProcessorSegment,proto3,oneof"`
}

type PlatformOutboundInstruction_NodeNotification 

type PlatformOutboundInstruction_NodeNotification struct {
	NodeNotification *NodeInfo `protobuf:"bytes,1,opt,name=node_notification,json=nodeNotification,proto3,oneof"`
}

type PlatformOutboundInstruction_PauseEventProcessor 

type PlatformOutboundInstruction_PauseEventProcessor struct {
	PauseEventProcessor *EventProcessorReference `protobuf:"bytes,4,opt,name=pause_event_processor,json=pauseEventProcessor,proto3,oneof"`
}

type PlatformOutboundInstruction_ReleaseSegment 

type PlatformOutboundInstruction_ReleaseSegment struct {
	ReleaseSegment *EventProcessorSegmentReference `protobuf:"bytes,6,opt,name=release_segment,json=releaseSegment,proto3,oneof"`
}

type PlatformOutboundInstruction_RequestEventProcessorInfo 

type PlatformOutboundInstruction_RequestEventProcessorInfo struct {
	RequestEventProcessorInfo *EventProcessorReference `protobuf:"bytes,7,opt,name=request_event_processor_info,json=requestEventProcessorInfo,proto3,oneof"`
}

type PlatformOutboundInstruction_RequestReconnect 

type PlatformOutboundInstruction_RequestReconnect struct {
	RequestReconnect *RequestReconnect `protobuf:"bytes,3,opt,name=request_reconnect,json=requestReconnect,proto3,oneof"`
}

type PlatformOutboundInstruction_SplitEventProcessorSegment 

type PlatformOutboundInstruction_SplitEventProcessorSegment struct {
	SplitEventProcessorSegment *EventProcessorSegmentReference `protobuf:"bytes,8,opt,name=split_event_processor_segment,json=splitEventProcessorSegment,proto3,oneof"`
}

type PlatformOutboundInstruction_StartEventProcessor 

type PlatformOutboundInstruction_StartEventProcessor struct {
	StartEventProcessor *EventProcessorReference `protobuf:"bytes,5,opt,name=start_event_processor,json=startEventProcessor,proto3,oneof"`
}

type PlatformServiceClient 

type PlatformServiceClient interface {
	// Obtains connection information for the Server that a Client should use for its connections.
	GetPlatformServer(ctx context.Context, in *ClientIdentification, opts ...grpc.CallOption) (*PlatformInfo, error)
	// Opens an instruction stream to the Platform, allowing AxonServer to provide management instructions to the application
	OpenStream(ctx context.Context, opts ...grpc.CallOption) (PlatformService_OpenStreamClient, error)
}

PlatformServiceClient is the client API for PlatformService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPlatformServiceClient 

func NewPlatformServiceClient(cc grpc.ClientConnInterface) PlatformServiceClient

type PlatformServiceServer 

type PlatformServiceServer interface {
	// Obtains connection information for the Server that a Client should use for its connections.
	GetPlatformServer(context.Context, *ClientIdentification) (*PlatformInfo, error)
	// Opens an instruction stream to the Platform, allowing AxonServer to provide management instructions to the application
	OpenStream(PlatformService_OpenStreamServer) error
}

PlatformServiceServer is the server API for PlatformService service.

type PlatformService_OpenStreamClient 

type PlatformService_OpenStreamClient interface {
	Send(*PlatformInboundInstruction) error
	Recv() (*PlatformOutboundInstruction, error)
	grpc.ClientStream
}

type PlatformService_OpenStreamServer 

type PlatformService_OpenStreamServer interface {
	Send(*PlatformOutboundInstruction) error
	Recv() (*PlatformInboundInstruction, error)
	grpc.ServerStream
}

type ProcessingInstruction 

type ProcessingInstruction struct {
	// The type of processing message.
	Key ProcessingKey `protobuf:"varint,1,opt,name=key,proto3,enum=io.axoniq.axonserver.grpc.ProcessingKey" json:"key,omitempty"`
	// The value associated with the processing key.
	Value                *MetaDataValue `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

An instruction for routing components when routing or processing a message.

func (*ProcessingInstruction) Descriptor 

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

func (*ProcessingInstruction) GetKey 

func (m *ProcessingInstruction) GetKey() ProcessingKey

func (*ProcessingInstruction) GetValue 

func (m *ProcessingInstruction) GetValue() *MetaDataValue

func (*ProcessingInstruction) ProtoMessage 

func (*ProcessingInstruction) ProtoMessage()

func (*ProcessingInstruction) Reset 

func (m *ProcessingInstruction) Reset()

func (*ProcessingInstruction) String 

func (m *ProcessingInstruction) String() string

func (*ProcessingInstruction) XXX_DiscardUnknown 

func (m *ProcessingInstruction) XXX_DiscardUnknown()

func (*ProcessingInstruction) XXX_Marshal 

func (m *ProcessingInstruction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcessingInstruction) XXX_Merge 

func (m *ProcessingInstruction) XXX_Merge(src proto.Message)

func (*ProcessingInstruction) XXX_Size 

func (m *ProcessingInstruction) XXX_Size() int

func (*ProcessingInstruction) XXX_Unmarshal 

func (m *ProcessingInstruction) XXX_Unmarshal(b []byte) error

type ProcessingKey 

type ProcessingKey int32

An enumeration of possible keys for processing instructions. 

const (
	// key indicating that the attached value should be used for consistent routing.
	ProcessingKey_ROUTING_KEY ProcessingKey = 0
	// key indicating that the attached value indicates relative priority of this message.
	ProcessingKey_PRIORITY ProcessingKey = 1
	// key indicating that the accompanied message has a finite validity. The attached value contains the number of milliseconds.
	ProcessingKey_TIMEOUT ProcessingKey = 2
	// key indicating that the requester expects at most the given number of results from this message. Use -1 for unlimited.
	ProcessingKey_NR_OF_RESULTS ProcessingKey = 3
)

func (ProcessingKey) EnumDescriptor 

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

func (ProcessingKey) String 

func (x ProcessingKey) String() string

type QueryComplete 

type QueryComplete struct {
	// A unique identifier for this message
	MessageId string `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// The identifier of the incoming query to complete
	RequestId            string   `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message indicating that all available responses to an incoming Query have been provided.

func (*QueryComplete) Descriptor 

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

func (*QueryComplete) GetMessageId 

func (m *QueryComplete) GetMessageId() string

func (*QueryComplete) GetRequestId 

func (m *QueryComplete) GetRequestId() string

func (*QueryComplete) ProtoMessage 

func (*QueryComplete) ProtoMessage()

func (*QueryComplete) Reset 

func (m *QueryComplete) Reset()

func (*QueryComplete) String 

func (m *QueryComplete) String() string

func (*QueryComplete) XXX_DiscardUnknown 

func (m *QueryComplete) XXX_DiscardUnknown()

func (*QueryComplete) XXX_Marshal 

func (m *QueryComplete) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryComplete) XXX_Merge 

func (m *QueryComplete) XXX_Merge(src proto.Message)

func (*QueryComplete) XXX_Size 

func (m *QueryComplete) XXX_Size() int

func (*QueryComplete) XXX_Unmarshal 

func (m *QueryComplete) XXX_Unmarshal(b []byte) error

type QueryEventsRequest 

type QueryEventsRequest struct {
	// The query to execute against the Event Stream
	Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// The number of results AxonServer may send before new permits need to be provided
	NumberOfPermits int64 `protobuf:"varint,2,opt,name=number_of_permits,json=numberOfPermits,proto3" json:"number_of_permits,omitempty"`
	// Whether to keep the query running against incoming events once the Head of the Stream is reached
	LiveEvents           bool     `protobuf:"varint,3,opt,name=live_events,json=liveEvents,proto3" json:"live_events,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message providing the parameters for executing a Query against AxonServer.

func (*QueryEventsRequest) Descriptor 

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

func (*QueryEventsRequest) GetLiveEvents 

func (m *QueryEventsRequest) GetLiveEvents() bool

func (*QueryEventsRequest) GetNumberOfPermits 

func (m *QueryEventsRequest) GetNumberOfPermits() int64

func (*QueryEventsRequest) GetQuery 

func (m *QueryEventsRequest) GetQuery() string

func (*QueryEventsRequest) ProtoMessage 

func (*QueryEventsRequest) ProtoMessage()

func (*QueryEventsRequest) Reset 

func (m *QueryEventsRequest) Reset()

func (*QueryEventsRequest) String 

func (m *QueryEventsRequest) String() string

func (*QueryEventsRequest) XXX_DiscardUnknown 

func (m *QueryEventsRequest) XXX_DiscardUnknown()

func (*QueryEventsRequest) XXX_Marshal 

func (m *QueryEventsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryEventsRequest) XXX_Merge 

func (m *QueryEventsRequest) XXX_Merge(src proto.Message)

func (*QueryEventsRequest) XXX_Size 

func (m *QueryEventsRequest) XXX_Size() int

func (*QueryEventsRequest) XXX_Unmarshal 

func (m *QueryEventsRequest) XXX_Unmarshal(b []byte) error

type QueryEventsResponse 

type QueryEventsResponse struct {
	// The actual contents of this response
	//
	// Types that are valid to be assigned to Data:
	//	*QueryEventsResponse_Columns
	//	*QueryEventsResponse_Row
	//	*QueryEventsResponse_FilesCompleted
	Data                 isQueryEventsResponse_Data `protobuf_oneof:"data"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

A message describing a response to a Query request

func (*QueryEventsResponse) Descriptor 

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

func (*QueryEventsResponse) GetColumns 

func (m *QueryEventsResponse) GetColumns() *ColumnsResponse

func (*QueryEventsResponse) GetData 

func (m *QueryEventsResponse) GetData() isQueryEventsResponse_Data

func (*QueryEventsResponse) GetFilesCompleted 

func (m *QueryEventsResponse) GetFilesCompleted() *Confirmation

func (*QueryEventsResponse) GetRow 

func (m *QueryEventsResponse) GetRow() *RowResponse

func (*QueryEventsResponse) ProtoMessage 

func (*QueryEventsResponse) ProtoMessage()

func (*QueryEventsResponse) Reset 

func (m *QueryEventsResponse) Reset()

func (*QueryEventsResponse) String 

func (m *QueryEventsResponse) String() string

func (*QueryEventsResponse) XXX_DiscardUnknown 

func (m *QueryEventsResponse) XXX_DiscardUnknown()

func (*QueryEventsResponse) XXX_Marshal 

func (m *QueryEventsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryEventsResponse) XXX_Merge 

func (m *QueryEventsResponse) XXX_Merge(src proto.Message)

func (*QueryEventsResponse) XXX_OneofWrappers 

func (*QueryEventsResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*QueryEventsResponse) XXX_Size 

func (m *QueryEventsResponse) XXX_Size() int

func (*QueryEventsResponse) XXX_Unmarshal 

func (m *QueryEventsResponse) XXX_Unmarshal(b []byte) error

type QueryEventsResponse_Columns 

type QueryEventsResponse_Columns struct {
	Columns *ColumnsResponse `protobuf:"bytes,1,opt,name=columns,proto3,oneof"`
}

type QueryEventsResponse_FilesCompleted 

type QueryEventsResponse_FilesCompleted struct {
	FilesCompleted *Confirmation `protobuf:"bytes,3,opt,name=files_completed,json=filesCompleted,proto3,oneof"`
}

type QueryEventsResponse_Row 

type QueryEventsResponse_Row struct {
	Row *RowResponse `protobuf:"bytes,2,opt,name=row,proto3,oneof"`
}

type QueryProviderInbound 

type QueryProviderInbound struct {
	// The actual query or instruction
	//
	// Types that are valid to be assigned to Request:
	//	*QueryProviderInbound_Ack
	//	*QueryProviderInbound_Query
	//	*QueryProviderInbound_SubscriptionQueryRequest
	Request isQueryProviderInbound_Request `protobuf_oneof:"request"`
	// Instruction identifier. If this identifier is set, this instruction will be acknowledged via outbound stream
	InstructionId        string   `protobuf:"bytes,4,opt,name=instruction_id,json=instructionId,proto3" json:"instruction_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Queries or Query related instructions from AxonServer for the connected application

func (*QueryProviderInbound) Descriptor 

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

func (*QueryProviderInbound) GetAck 

func (m *QueryProviderInbound) GetAck() *InstructionAck

func (*QueryProviderInbound) GetInstructionId 

func (m *QueryProviderInbound) GetInstructionId() string

func (*QueryProviderInbound) GetQuery 

func (m *QueryProviderInbound) GetQuery() *QueryRequest

func (*QueryProviderInbound) GetRequest 

func (m *QueryProviderInbound) GetRequest() isQueryProviderInbound_Request

func (*QueryProviderInbound) GetSubscriptionQueryRequest 

func (m *QueryProviderInbound) GetSubscriptionQueryRequest() *SubscriptionQueryRequest

func (*QueryProviderInbound) ProtoMessage 

func (*QueryProviderInbound) ProtoMessage()

func (*QueryProviderInbound) Reset 

func (m *QueryProviderInbound) Reset()

func (*QueryProviderInbound) String 

func (m *QueryProviderInbound) String() string

func (*QueryProviderInbound) XXX_DiscardUnknown 

func (m *QueryProviderInbound) XXX_DiscardUnknown()

func (*QueryProviderInbound) XXX_Marshal 

func (m *QueryProviderInbound) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryProviderInbound) XXX_Merge 

func (m *QueryProviderInbound) XXX_Merge(src proto.Message)

func (*QueryProviderInbound) XXX_OneofWrappers 

func (*QueryProviderInbound) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*QueryProviderInbound) XXX_Size 

func (m *QueryProviderInbound) XXX_Size() int

func (*QueryProviderInbound) XXX_Unmarshal 

func (m *QueryProviderInbound) XXX_Unmarshal(b []byte) error

type QueryProviderInbound_Ack 

type QueryProviderInbound_Ack struct {
	Ack *InstructionAck `protobuf:"bytes,1,opt,name=ack,proto3,oneof"`
}

type QueryProviderInbound_Query 

type QueryProviderInbound_Query struct {
	Query *QueryRequest `protobuf:"bytes,2,opt,name=query,proto3,oneof"`
}

type QueryProviderInbound_SubscriptionQueryRequest 

type QueryProviderInbound_SubscriptionQueryRequest struct {
	SubscriptionQueryRequest *SubscriptionQueryRequest `protobuf:"bytes,3,opt,name=subscription_query_request,json=subscriptionQueryRequest,proto3,oneof"`
}

type QueryProviderOutbound 

type QueryProviderOutbound struct {
	// The actual instruction to send
	//
	// Types that are valid to be assigned to Request:
	//	*QueryProviderOutbound_Subscribe
	//	*QueryProviderOutbound_Unsubscribe
	//	*QueryProviderOutbound_FlowControl
	//	*QueryProviderOutbound_QueryResponse
	//	*QueryProviderOutbound_QueryComplete
	//	*QueryProviderOutbound_SubscriptionQueryResponse
	//	*QueryProviderOutbound_Ack
	Request isQueryProviderOutbound_Request `protobuf_oneof:"request"`
	// Instruction identifier. If this identifier is set, this instruction will be acknowledged via inbound stream
	InstructionId        string   `protobuf:"bytes,8,opt,name=instruction_id,json=instructionId,proto3" json:"instruction_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message containing Query related instructions for Axon Server

func (*QueryProviderOutbound) Descriptor 

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

func (*QueryProviderOutbound) GetAck 

func (m *QueryProviderOutbound) GetAck() *InstructionAck

func (*QueryProviderOutbound) GetFlowControl 

func (m *QueryProviderOutbound) GetFlowControl() *FlowControl

func (*QueryProviderOutbound) GetInstructionId 

func (m *QueryProviderOutbound) GetInstructionId() string

func (*QueryProviderOutbound) GetQueryComplete 

func (m *QueryProviderOutbound) GetQueryComplete() *QueryComplete

func (*QueryProviderOutbound) GetQueryResponse 

func (m *QueryProviderOutbound) GetQueryResponse() *QueryResponse

func (*QueryProviderOutbound) GetRequest 

func (m *QueryProviderOutbound) GetRequest() isQueryProviderOutbound_Request

func (*QueryProviderOutbound) GetSubscribe 

func (m *QueryProviderOutbound) GetSubscribe() *QuerySubscription

func (*QueryProviderOutbound) GetSubscriptionQueryResponse 

func (m *QueryProviderOutbound) GetSubscriptionQueryResponse() *SubscriptionQueryResponse

func (*QueryProviderOutbound) GetUnsubscribe 

func (m *QueryProviderOutbound) GetUnsubscribe() *QuerySubscription

func (*QueryProviderOutbound) ProtoMessage 

func (*QueryProviderOutbound) ProtoMessage()

func (*QueryProviderOutbound) Reset 

func (m *QueryProviderOutbound) Reset()

func (*QueryProviderOutbound) String 

func (m *QueryProviderOutbound) String() string

func (*QueryProviderOutbound) XXX_DiscardUnknown 

func (m *QueryProviderOutbound) XXX_DiscardUnknown()

func (*QueryProviderOutbound) XXX_Marshal 

func (m *QueryProviderOutbound) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryProviderOutbound) XXX_Merge 

func (m *QueryProviderOutbound) XXX_Merge(src proto.Message)

func (*QueryProviderOutbound) XXX_OneofWrappers 

func (*QueryProviderOutbound) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*QueryProviderOutbound) XXX_Size 

func (m *QueryProviderOutbound) XXX_Size() int

func (*QueryProviderOutbound) XXX_Unmarshal 

func (m *QueryProviderOutbound) XXX_Unmarshal(b []byte) error

type QueryProviderOutbound_Ack 

type QueryProviderOutbound_Ack struct {
	Ack *InstructionAck `protobuf:"bytes,7,opt,name=ack,proto3,oneof"`
}

type QueryProviderOutbound_FlowControl 

type QueryProviderOutbound_FlowControl struct {
	FlowControl *FlowControl `protobuf:"bytes,3,opt,name=flow_control,json=flowControl,proto3,oneof"`
}

type QueryProviderOutbound_QueryComplete 

type QueryProviderOutbound_QueryComplete struct {
	QueryComplete *QueryComplete `protobuf:"bytes,5,opt,name=query_complete,json=queryComplete,proto3,oneof"`
}

type QueryProviderOutbound_QueryResponse 

type QueryProviderOutbound_QueryResponse struct {
	QueryResponse *QueryResponse `protobuf:"bytes,4,opt,name=query_response,json=queryResponse,proto3,oneof"`
}

type QueryProviderOutbound_Subscribe 

type QueryProviderOutbound_Subscribe struct {
	Subscribe *QuerySubscription `protobuf:"bytes,1,opt,name=subscribe,proto3,oneof"`
}

type QueryProviderOutbound_SubscriptionQueryResponse 

type QueryProviderOutbound_SubscriptionQueryResponse struct {
	SubscriptionQueryResponse *SubscriptionQueryResponse `protobuf:"bytes,6,opt,name=subscription_query_response,json=subscriptionQueryResponse,proto3,oneof"`
}

type QueryProviderOutbound_Unsubscribe 

type QueryProviderOutbound_Unsubscribe struct {
	Unsubscribe *QuerySubscription `protobuf:"bytes,2,opt,name=unsubscribe,proto3,oneof"`
}

type QueryRequest 

type QueryRequest struct {
	// The message ID of the incoming Query
	MessageIdentifier string `protobuf:"bytes,1,opt,name=message_identifier,json=messageIdentifier,proto3" json:"message_identifier,omitempty"`
	// The name of the Query to execute
	Query string `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// The timestamp of the Query creation
	Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// A payload accompanying the Query
	Payload *SerializedObject `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
	// Meta Data providing contextual information of the Query
	MetaData map[string]*MetaDataValue `` /* 173-byte string literal not displayed */
	// An object describing the expectations of the Response Type
	ResponseType *SerializedObject `protobuf:"bytes,6,opt,name=response_type,json=responseType,proto3" json:"response_type,omitempty"`
	// Any instructions for components Routing or Handling the Query
	ProcessingInstructions []*ProcessingInstruction `` /* 127-byte string literal not displayed */
	// The unique identifier of the client instance dispatching the query
	ClientId string `protobuf:"bytes,8,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// The Name of the Component dispatching the query
	ComponentName        string   `protobuf:"bytes,9,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message representing an incoming Query

func (*QueryRequest) Descriptor 

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

func (*QueryRequest) GetClientId 

func (m *QueryRequest) GetClientId() string

func (*QueryRequest) GetComponentName 

func (m *QueryRequest) GetComponentName() string

func (*QueryRequest) GetMessageIdentifier 

func (m *QueryRequest) GetMessageIdentifier() string

func (*QueryRequest) GetMetaData 

func (m *QueryRequest) GetMetaData() map[string]*MetaDataValue

func (*QueryRequest) GetPayload 

func (m *QueryRequest) GetPayload() *SerializedObject

func (*QueryRequest) GetProcessingInstructions 

func (m *QueryRequest) GetProcessingInstructions() []*ProcessingInstruction

func (*QueryRequest) GetQuery 

func (m *QueryRequest) GetQuery() string

func (*QueryRequest) GetResponseType 

func (m *QueryRequest) GetResponseType() *SerializedObject

func (*QueryRequest) GetTimestamp 

func (m *QueryRequest) GetTimestamp() int64

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) Reset 

func (m *QueryRequest) Reset()

func (*QueryRequest) String 

func (m *QueryRequest) String() string

func (*QueryRequest) XXX_DiscardUnknown 

func (m *QueryRequest) XXX_DiscardUnknown()

func (*QueryRequest) XXX_Marshal 

func (m *QueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryRequest) XXX_Merge 

func (m *QueryRequest) XXX_Merge(src proto.Message)

func (*QueryRequest) XXX_Size 

func (m *QueryRequest) XXX_Size() int

func (*QueryRequest) XXX_Unmarshal 

func (m *QueryRequest) XXX_Unmarshal(b []byte) error

type QueryResponse 

type QueryResponse struct {
	// The unique identifier of the Response Message
	MessageIdentifier string `protobuf:"bytes,1,opt,name=message_identifier,json=messageIdentifier,proto3" json:"message_identifier,omitempty"`
	// An Error Code identifying the type of error, if any
	ErrorCode string `protobuf:"bytes,2,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"`
	// A detailed description of the error, if any
	ErrorMessage *ErrorMessage `protobuf:"bytes,3,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// The Payload of the Response Message
	Payload *SerializedObject `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
	// Any Meta Data describing the context of the Response Message
	MetaData map[string]*MetaDataValue `` /* 173-byte string literal not displayed */
	// Any instructions for components Routing or Handling the Response Message
	ProcessingInstructions []*ProcessingInstruction `` /* 127-byte string literal not displayed */
	// The unique identifier of the Query to which this is a response
	RequestIdentifier    string   `protobuf:"bytes,7,opt,name=request_identifier,json=requestIdentifier,proto3" json:"request_identifier,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message that represents the Response to a Query

func (*QueryResponse) Descriptor 

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

func (*QueryResponse) GetErrorCode 

func (m *QueryResponse) GetErrorCode() string

func (*QueryResponse) GetErrorMessage 

func (m *QueryResponse) GetErrorMessage() *ErrorMessage

func (*QueryResponse) GetMessageIdentifier 

func (m *QueryResponse) GetMessageIdentifier() string

func (*QueryResponse) GetMetaData 

func (m *QueryResponse) GetMetaData() map[string]*MetaDataValue

func (*QueryResponse) GetPayload 

func (m *QueryResponse) GetPayload() *SerializedObject

func (*QueryResponse) GetProcessingInstructions 

func (m *QueryResponse) GetProcessingInstructions() []*ProcessingInstruction

func (*QueryResponse) GetRequestIdentifier 

func (m *QueryResponse) GetRequestIdentifier() string

func (*QueryResponse) ProtoMessage 

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) Reset 

func (m *QueryResponse) Reset()

func (*QueryResponse) String 

func (m *QueryResponse) String() string

func (*QueryResponse) XXX_DiscardUnknown 

func (m *QueryResponse) XXX_DiscardUnknown()

func (*QueryResponse) XXX_Marshal 

func (m *QueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryResponse) XXX_Merge 

func (m *QueryResponse) XXX_Merge(src proto.Message)

func (*QueryResponse) XXX_Size 

func (m *QueryResponse) XXX_Size() int

func (*QueryResponse) XXX_Unmarshal 

func (m *QueryResponse) XXX_Unmarshal(b []byte) error

type QueryServiceClient 

type QueryServiceClient interface {
	// Opens a Query- and Instruction stream to AxonServer.
	OpenStream(ctx context.Context, opts ...grpc.CallOption) (QueryService_OpenStreamClient, error)
	// Sends a point-to-point or scatter-gather Query
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (QueryService_QueryClient, error)
	// Opens a Subscription Query
	Subscription(ctx context.Context, opts ...grpc.CallOption) (QueryService_SubscriptionClient, error)
}

QueryServiceClient is the client API for QueryService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQueryServiceClient 

func NewQueryServiceClient(cc grpc.ClientConnInterface) QueryServiceClient

type QueryServiceServer 

type QueryServiceServer interface {
	// Opens a Query- and Instruction stream to AxonServer.
	OpenStream(QueryService_OpenStreamServer) error
	// Sends a point-to-point or scatter-gather Query
	Query(*QueryRequest, QueryService_QueryServer) error
	// Opens a Subscription Query
	Subscription(QueryService_SubscriptionServer) error
}

QueryServiceServer is the server API for QueryService service.

type QueryService_OpenStreamClient 

type QueryService_OpenStreamClient interface {
	Send(*QueryProviderOutbound) error
	Recv() (*QueryProviderInbound, error)
	grpc.ClientStream
}

type QueryService_OpenStreamServer 

type QueryService_OpenStreamServer interface {
	Send(*QueryProviderInbound) error
	Recv() (*QueryProviderOutbound, error)
	grpc.ServerStream
}

type QueryService_QueryClient 

type QueryService_QueryClient interface {
	Recv() (*QueryResponse, error)
	grpc.ClientStream
}

type QueryService_QueryServer 

type QueryService_QueryServer interface {
	Send(*QueryResponse) error
	grpc.ServerStream
}

type QueryService_SubscriptionClient 

type QueryService_SubscriptionClient interface {
	Send(*SubscriptionQueryRequest) error
	Recv() (*SubscriptionQueryResponse, error)
	grpc.ClientStream
}

type QueryService_SubscriptionServer 

type QueryService_SubscriptionServer interface {
	Send(*SubscriptionQueryResponse) error
	Recv() (*SubscriptionQueryRequest, error)
	grpc.ServerStream
}

type QuerySubscription 

type QuerySubscription struct {
	// The unique identifier of this Message
	MessageId string `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// The name of the Query the Handler is subscribed to
	Query string `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// The type of Result this Handler produces
	ResultName string `protobuf:"bytes,3,opt,name=result_name,json=resultName,proto3" json:"result_name,omitempty"`
	// The name of the Component containing the Query Handler
	ComponentName string `protobuf:"bytes,4,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"`
	// The unique identifier of the Client Instance containing the Query Handler
	ClientId string `protobuf:"bytes,5,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// The number of Query Handlers registered within this Component with the same details. This number is used to
	//calculate the number of candidates for Scatter-Gather Queries.
	NrOfHandlers         int32    `protobuf:"varint,6,opt,name=nr_of_handlers,json=nrOfHandlers,proto3" json:"nr_of_handlers,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message containing details of a Registration of a Query Handler in a component

func (*QuerySubscription) Descriptor 

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

func (*QuerySubscription) GetClientId 

func (m *QuerySubscription) GetClientId() string

func (*QuerySubscription) GetComponentName 

func (m *QuerySubscription) GetComponentName() string

func (*QuerySubscription) GetMessageId 

func (m *QuerySubscription) GetMessageId() string

func (*QuerySubscription) GetNrOfHandlers 

func (m *QuerySubscription) GetNrOfHandlers() int32

func (*QuerySubscription) GetQuery 

func (m *QuerySubscription) GetQuery() string

func (*QuerySubscription) GetResultName 

func (m *QuerySubscription) GetResultName() string

func (*QuerySubscription) ProtoMessage 

func (*QuerySubscription) ProtoMessage()

func (*QuerySubscription) Reset 

func (m *QuerySubscription) Reset()

func (*QuerySubscription) String 

func (m *QuerySubscription) String() string

func (*QuerySubscription) XXX_DiscardUnknown 

func (m *QuerySubscription) XXX_DiscardUnknown()

func (*QuerySubscription) XXX_Marshal 

func (m *QuerySubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QuerySubscription) XXX_Merge 

func (m *QuerySubscription) XXX_Merge(src proto.Message)

func (*QuerySubscription) XXX_Size 

func (m *QuerySubscription) XXX_Size() int

func (*QuerySubscription) XXX_Unmarshal 

func (m *QuerySubscription) XXX_Unmarshal(b []byte) error

type QueryUpdate 

type QueryUpdate struct {
	// The unique identifier of this Update
	MessageIdentifier string `protobuf:"bytes,2,opt,name=message_identifier,json=messageIdentifier,proto3" json:"message_identifier,omitempty"`
	// The object representing the Update
	Payload *SerializedObject `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// Meta Data providing contextual information of the Update
	MetaData map[string]*MetaDataValue `` /* 173-byte string literal not displayed */
	// The identifier of the Client instance providing the Update
	ClientId string `protobuf:"bytes,5,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// The Component Name of the Client providing the Update
	ComponentName        string   `protobuf:"bytes,6,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A message containing an Update of a Query Subscription Response

func (*QueryUpdate) Descriptor 

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

func (*QueryUpdate) GetClientId 

func (m *QueryUpdate) GetClientId() string

func (*QueryUpdate) GetComponentName 

func (m *QueryUpdate) GetComponentName() string

func (*QueryUpdate) GetMessageIdentifier 

func (m *QueryUpdate) GetMessageIdentifier() string

func (*QueryUpdate) GetMetaData 

func (m *QueryUpdate) GetMetaData() map[string]*MetaDataValue

func (*QueryUpdate) GetPayload 

func (m *QueryUpdate) GetPayload() *SerializedObject

func (*QueryUpdate) ProtoMessage 

func (*QueryUpdate) ProtoMessage()

func (*QueryUpdate) Reset 

func (m *QueryUpdate) Reset()

func (*QueryUpdate) String 

func (m *QueryUpdate) String() string

func (*QueryUpdate) XXX_DiscardUnknown 

func (m *QueryUpdate) XXX_DiscardUnknown()

func (*QueryUpdate) XXX_Marshal 

func (m *QueryUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryUpdate) XXX_Merge 

func (m *QueryUpdate) XXX_Merge(src proto.Message)

func (*QueryUpdate) XXX_Size 

func (m *QueryUpdate) XXX_Size() int

func (*QueryUpdate) XXX_Unmarshal 

func (m *QueryUpdate) XXX_Unmarshal(b []byte) error

type QueryUpdateComplete 

type QueryUpdateComplete struct {
	// The identifier of the Client instance providing the Update
	ClientId string `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// The Component Name of the Client providing the Update
	ComponentName        string   `protobuf:"bytes,3,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message indicating that all relevant Updates have been sent for a Subscription Query, and that no further Updates are available

func (*QueryUpdateComplete) Descriptor 

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

func (*QueryUpdateComplete) GetClientId 

func (m *QueryUpdateComplete) GetClientId() string

func (*QueryUpdateComplete) GetComponentName 

func (m *QueryUpdateComplete) GetComponentName() string

func (*QueryUpdateComplete) ProtoMessage 

func (*QueryUpdateComplete) ProtoMessage()

func (*QueryUpdateComplete) Reset 

func (m *QueryUpdateComplete) Reset()

func (*QueryUpdateComplete) String 

func (m *QueryUpdateComplete) String() string

func (*QueryUpdateComplete) XXX_DiscardUnknown 

func (m *QueryUpdateComplete) XXX_DiscardUnknown()

func (*QueryUpdateComplete) XXX_Marshal 

func (m *QueryUpdateComplete) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryUpdateComplete) XXX_Merge 

func (m *QueryUpdateComplete) XXX_Merge(src proto.Message)

func (*QueryUpdateComplete) XXX_Size 

func (m *QueryUpdateComplete) XXX_Size() int

func (*QueryUpdateComplete) XXX_Unmarshal 

func (m *QueryUpdateComplete) XXX_Unmarshal(b []byte) error

type QueryUpdateCompleteExceptionally 

type QueryUpdateCompleteExceptionally struct {
	// The identifier of the Client instance providing the Update
	ClientId string `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// The Component Name of the Client providing the Update
	ComponentName string `protobuf:"bytes,3,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"`
	// The Code describing the type of Error that occurred
	ErrorCode string `protobuf:"bytes,5,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"`
	// A detailed description of the error, if available
	ErrorMessage         *ErrorMessage `protobuf:"bytes,6,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Message indicating that an Error occurred and that no Updates will be sent for a Subscription Query

func (*QueryUpdateCompleteExceptionally) Descriptor 

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

func (*QueryUpdateCompleteExceptionally) GetClientId 

func (m *QueryUpdateCompleteExceptionally) GetClientId() string

func (*QueryUpdateCompleteExceptionally) GetComponentName 

func (m *QueryUpdateCompleteExceptionally) GetComponentName() string

func (*QueryUpdateCompleteExceptionally) GetErrorCode 

func (m *QueryUpdateCompleteExceptionally) GetErrorCode() string

func (*QueryUpdateCompleteExceptionally) GetErrorMessage 

func (m *QueryUpdateCompleteExceptionally) GetErrorMessage() *ErrorMessage

func (*QueryUpdateCompleteExceptionally) ProtoMessage 

func (*QueryUpdateCompleteExceptionally) ProtoMessage()

func (*QueryUpdateCompleteExceptionally) Reset 

func (m *QueryUpdateCompleteExceptionally) Reset()

func (*QueryUpdateCompleteExceptionally) String 

func (m *QueryUpdateCompleteExceptionally) String() string

func (*QueryUpdateCompleteExceptionally) XXX_DiscardUnknown 

func (m *QueryUpdateCompleteExceptionally) XXX_DiscardUnknown()

func (*QueryUpdateCompleteExceptionally) XXX_Marshal 

func (m *QueryUpdateCompleteExceptionally) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryUpdateCompleteExceptionally) XXX_Merge 

func (m *QueryUpdateCompleteExceptionally) XXX_Merge(src proto.Message)

func (*QueryUpdateCompleteExceptionally) XXX_Size 

func (m *QueryUpdateCompleteExceptionally) XXX_Size() int

func (*QueryUpdateCompleteExceptionally) XXX_Unmarshal 

func (m *QueryUpdateCompleteExceptionally) XXX_Unmarshal(b []byte) error

type QueryValue 

type QueryValue struct {
	// The actual value, which can be one of string, 64 bit signed integer, boolean or 64 bits floating point
	//
	// Types that are valid to be assigned to Data:
	//	*QueryValue_TextValue
	//	*QueryValue_NumberValue
	//	*QueryValue_BooleanValue
	//	*QueryValue_DoubleValue
	Data                 isQueryValue_Data `protobuf_oneof:"data"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Value used in Query Responses to represent a value in its original type

func (*QueryValue) Descriptor 

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

func (*QueryValue) GetBooleanValue 

func (m *QueryValue) GetBooleanValue() bool

func (*QueryValue) GetData 

func (m *QueryValue) GetData() isQueryValue_Data

func (*QueryValue) GetDoubleValue 

func (m *QueryValue) GetDoubleValue() float64

func (*QueryValue) GetNumberValue 

func (m *QueryValue) GetNumberValue() int64

func (*QueryValue) GetTextValue 

func (m *QueryValue) GetTextValue() string

func (*QueryValue) ProtoMessage 

func (*QueryValue) ProtoMessage()

func (*QueryValue) Reset 

func (m *QueryValue) Reset()

func (*QueryValue) String 

func (m *QueryValue) String() string

func (*QueryValue) XXX_DiscardUnknown 

func (m *QueryValue) XXX_DiscardUnknown()

func (*QueryValue) XXX_Marshal 

func (m *QueryValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryValue) XXX_Merge 

func (m *QueryValue) XXX_Merge(src proto.Message)

func (*QueryValue) XXX_OneofWrappers 

func (*QueryValue) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*QueryValue) XXX_Size 

func (m *QueryValue) XXX_Size() int

func (*QueryValue) XXX_Unmarshal 

func (m *QueryValue) XXX_Unmarshal(b []byte) error

type QueryValue_BooleanValue 

type QueryValue_BooleanValue struct {
	BooleanValue bool `protobuf:"varint,3,opt,name=boolean_value,json=booleanValue,proto3,oneof"`
}

type QueryValue_DoubleValue 

type QueryValue_DoubleValue struct {
	DoubleValue float64 `protobuf:"fixed64,4,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

type QueryValue_NumberValue 

type QueryValue_NumberValue struct {
	NumberValue int64 `protobuf:"zigzag64,2,opt,name=number_value,json=numberValue,proto3,oneof"`
}

type QueryValue_TextValue 

type QueryValue_TextValue struct {
	TextValue string `protobuf:"bytes,1,opt,name=text_value,json=textValue,proto3,oneof"`
}

type ReadHighestSequenceNrRequest 

type ReadHighestSequenceNrRequest struct {
	// The Identifier of the Aggregate for which to load events
	AggregateId string `protobuf:"bytes,1,opt,name=aggregate_id,json=aggregateId,proto3" json:"aggregate_id,omitempty"`
	// The Sequence Number of the first event expected
	FromSequenceNr       int64    `protobuf:"varint,3,opt,name=from_sequence_nr,json=fromSequenceNr,proto3" json:"from_sequence_nr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Describes the combination of an Aggregate Identifier and first expected Sequence number when opening an Aggregate-specific Event Stream

func (*ReadHighestSequenceNrRequest) Descriptor 

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

func (*ReadHighestSequenceNrRequest) GetAggregateId 

func (m *ReadHighestSequenceNrRequest) GetAggregateId() string

func (*ReadHighestSequenceNrRequest) GetFromSequenceNr 

func (m *ReadHighestSequenceNrRequest) GetFromSequenceNr() int64

func (*ReadHighestSequenceNrRequest) ProtoMessage 

func (*ReadHighestSequenceNrRequest) ProtoMessage()

func (*ReadHighestSequenceNrRequest) Reset 

func (m *ReadHighestSequenceNrRequest) Reset()

func (*ReadHighestSequenceNrRequest) String 

func (m *ReadHighestSequenceNrRequest) String() string

func (*ReadHighestSequenceNrRequest) XXX_DiscardUnknown 

func (m *ReadHighestSequenceNrRequest) XXX_DiscardUnknown()

func (*ReadHighestSequenceNrRequest) XXX_Marshal 

func (m *ReadHighestSequenceNrRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadHighestSequenceNrRequest) XXX_Merge 

func (m *ReadHighestSequenceNrRequest) XXX_Merge(src proto.Message)

func (*ReadHighestSequenceNrRequest) XXX_Size 

func (m *ReadHighestSequenceNrRequest) XXX_Size() int

func (*ReadHighestSequenceNrRequest) XXX_Unmarshal 

func (m *ReadHighestSequenceNrRequest) XXX_Unmarshal(b []byte) error

type ReadHighestSequenceNrResponse 

type ReadHighestSequenceNrResponse struct {
	// The sequence number of the latest event
	ToSequenceNr         int64    `protobuf:"varint,1,opt,name=to_sequence_nr,json=toSequenceNr,proto3" json:"to_sequence_nr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The highest Sequence Number found for the provided request

func (*ReadHighestSequenceNrResponse) Descriptor 

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

func (*ReadHighestSequenceNrResponse) GetToSequenceNr 

func (m *ReadHighestSequenceNrResponse) GetToSequenceNr() int64

func (*ReadHighestSequenceNrResponse) ProtoMessage 

func (*ReadHighestSequenceNrResponse) ProtoMessage()

func (*ReadHighestSequenceNrResponse) Reset 

func (m *ReadHighestSequenceNrResponse) Reset()

func (*ReadHighestSequenceNrResponse) String 

func (m *ReadHighestSequenceNrResponse) String() string

func (*ReadHighestSequenceNrResponse) XXX_DiscardUnknown 

func (m *ReadHighestSequenceNrResponse) XXX_DiscardUnknown()

func (*ReadHighestSequenceNrResponse) XXX_Marshal 

func (m *ReadHighestSequenceNrResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadHighestSequenceNrResponse) XXX_Merge 

func (m *ReadHighestSequenceNrResponse) XXX_Merge(src proto.Message)

func (*ReadHighestSequenceNrResponse) XXX_Size 

func (m *ReadHighestSequenceNrResponse) XXX_Size() int

func (*ReadHighestSequenceNrResponse) XXX_Unmarshal 

func (m *ReadHighestSequenceNrResponse) XXX_Unmarshal(b []byte) error

type RequestReconnect 

type RequestReconnect struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message send when AxonServer requests the client to re-establish its connection with the Platform

func (*RequestReconnect) Descriptor 

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

func (*RequestReconnect) ProtoMessage 

func (*RequestReconnect) ProtoMessage()

func (*RequestReconnect) Reset 

func (m *RequestReconnect) Reset()

func (*RequestReconnect) String 

func (m *RequestReconnect) String() string

func (*RequestReconnect) XXX_DiscardUnknown 

func (m *RequestReconnect) XXX_DiscardUnknown()

func (*RequestReconnect) XXX_Marshal 

func (m *RequestReconnect) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RequestReconnect) XXX_Merge 

func (m *RequestReconnect) XXX_Merge(src proto.Message)

func (*RequestReconnect) XXX_Size 

func (m *RequestReconnect) XXX_Size() int

func (*RequestReconnect) XXX_Unmarshal 

func (m *RequestReconnect) XXX_Unmarshal(b []byte) error

type RowResponse 

type RowResponse struct {
	// The values which, when combined, uniquely update this row. Any previously received values with the same identifiers should be replaced with this value
	IdValues []*QueryValue `protobuf:"bytes,1,rep,name=id_values,json=idValues,proto3" json:"id_values,omitempty"`
	// The sorting values to use when sorting this response compared to the others.
	SortValues []*QueryValue `protobuf:"bytes,2,rep,name=sort_values,json=sortValues,proto3" json:"sort_values,omitempty"`
	// The actual data values for each of the columns, as a column name -> value mapping
	Values               map[string]*QueryValue `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

Message providing Query Result data

func (*RowResponse) Descriptor 

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

func (*RowResponse) GetIdValues 

func (m *RowResponse) GetIdValues() []*QueryValue

func (*RowResponse) GetSortValues 

func (m *RowResponse) GetSortValues() []*QueryValue

func (*RowResponse) GetValues 

func (m *RowResponse) GetValues() map[string]*QueryValue

func (*RowResponse) ProtoMessage 

func (*RowResponse) ProtoMessage()

func (*RowResponse) Reset 

func (m *RowResponse) Reset()

func (*RowResponse) String 

func (m *RowResponse) String() string

func (*RowResponse) XXX_DiscardUnknown 

func (m *RowResponse) XXX_DiscardUnknown()

func (*RowResponse) XXX_Marshal 

func (m *RowResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RowResponse) XXX_Merge 

func (m *RowResponse) XXX_Merge(src proto.Message)

func (*RowResponse) XXX_Size 

func (m *RowResponse) XXX_Size() int

func (*RowResponse) XXX_Unmarshal 

func (m *RowResponse) XXX_Unmarshal(b []byte) error

type SerializedObject 

type SerializedObject struct {
	// The type identifier of the serialized object.
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// The revision of the serialized form of the given type.
	Revision string `protobuf:"bytes,2,opt,name=revision,proto3" json:"revision,omitempty"`
	// The actual data representing the object in serialized form.
	Data                 []byte   `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Describes a serialized object

func (*SerializedObject) Descriptor 

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

func (*SerializedObject) GetData 

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

func (*SerializedObject) GetRevision 

func (m *SerializedObject) GetRevision() string

func (*SerializedObject) GetType 

func (m *SerializedObject) GetType() string

func (*SerializedObject) ProtoMessage 

func (*SerializedObject) ProtoMessage()

func (*SerializedObject) Reset 

func (m *SerializedObject) Reset()

func (*SerializedObject) String 

func (m *SerializedObject) String() string

func (*SerializedObject) XXX_DiscardUnknown 

func (m *SerializedObject) XXX_DiscardUnknown()

func (*SerializedObject) XXX_Marshal 

func (m *SerializedObject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SerializedObject) XXX_Merge 

func (m *SerializedObject) XXX_Merge(src proto.Message)

func (*SerializedObject) XXX_Size 

func (m *SerializedObject) XXX_Size() int

func (*SerializedObject) XXX_Unmarshal 

func (m *SerializedObject) XXX_Unmarshal(b []byte) error

type SubscriptionQuery 

type SubscriptionQuery struct {
	// A unique identifier for this subscription
	SubscriptionIdentifier string `` /* 127-byte string literal not displayed */
	// The number of messages the Server may send before needing to await additional permits
	NumberOfPermits int64 `protobuf:"varint,2,opt,name=number_of_permits,json=numberOfPermits,proto3" json:"number_of_permits,omitempty"`
	// The Query describing the desire for information
	QueryRequest *QueryRequest `protobuf:"bytes,3,opt,name=query_request,json=queryRequest,proto3" json:"query_request,omitempty"`
	// A description of the type of Object expected as Update Responses
	UpdateResponseType   *SerializedObject `protobuf:"bytes,4,opt,name=update_response_type,json=updateResponseType,proto3" json:"update_response_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Message that represents a Subscription Query

func (*SubscriptionQuery) Descriptor 

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

func (*SubscriptionQuery) GetNumberOfPermits 

func (m *SubscriptionQuery) GetNumberOfPermits() int64

func (*SubscriptionQuery) GetQueryRequest 

func (m *SubscriptionQuery) GetQueryRequest() *QueryRequest

func (*SubscriptionQuery) GetSubscriptionIdentifier 

func (m *SubscriptionQuery) GetSubscriptionIdentifier() string

func (*SubscriptionQuery) GetUpdateResponseType 

func (m *SubscriptionQuery) GetUpdateResponseType() *SerializedObject

func (*SubscriptionQuery) ProtoMessage 

func (*SubscriptionQuery) ProtoMessage()

func (*SubscriptionQuery) Reset 

func (m *SubscriptionQuery) Reset()

func (*SubscriptionQuery) String 

func (m *SubscriptionQuery) String() string

func (*SubscriptionQuery) XXX_DiscardUnknown 

func (m *SubscriptionQuery) XXX_DiscardUnknown()

func (*SubscriptionQuery) XXX_Marshal 

func (m *SubscriptionQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubscriptionQuery) XXX_Merge 

func (m *SubscriptionQuery) XXX_Merge(src proto.Message)

func (*SubscriptionQuery) XXX_Size 

func (m *SubscriptionQuery) XXX_Size() int

func (*SubscriptionQuery) XXX_Unmarshal 

func (m *SubscriptionQuery) XXX_Unmarshal(b []byte) error

type SubscriptionQueryRequest 

type SubscriptionQueryRequest struct {
	// The actual request. The Subscription Query is opened using a `subscribe`, which opens the flow of updates. Once
	//successful, the `get_initial_result` retrieves the initial result of the subscription. For the server to send
	//more updates than the initial number of permits, use the `flow_control` request to send more permits.
	//
	// Types that are valid to be assigned to Request:
	//	*SubscriptionQueryRequest_Subscribe
	//	*SubscriptionQueryRequest_Unsubscribe
	//	*SubscriptionQueryRequest_GetInitialResult
	//	*SubscriptionQueryRequest_FlowControl
	Request              isSubscriptionQueryRequest_Request `protobuf_oneof:"request"`
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

Message describing possible interactions for a Subscription Query

func (*SubscriptionQueryRequest) Descriptor 

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

func (*SubscriptionQueryRequest) GetFlowControl 

func (m *SubscriptionQueryRequest) GetFlowControl() *SubscriptionQuery

func (*SubscriptionQueryRequest) GetGetInitialResult 

func (m *SubscriptionQueryRequest) GetGetInitialResult() *SubscriptionQuery

func (*SubscriptionQueryRequest) GetRequest 

func (m *SubscriptionQueryRequest) GetRequest() isSubscriptionQueryRequest_Request

func (*SubscriptionQueryRequest) GetSubscribe 

func (m *SubscriptionQueryRequest) GetSubscribe() *SubscriptionQuery

func (*SubscriptionQueryRequest) GetUnsubscribe 

func (m *SubscriptionQueryRequest) GetUnsubscribe() *SubscriptionQuery

func (*SubscriptionQueryRequest) ProtoMessage 

func (*SubscriptionQueryRequest) ProtoMessage()

func (*SubscriptionQueryRequest) Reset 

func (m *SubscriptionQueryRequest) Reset()

func (*SubscriptionQueryRequest) String 

func (m *SubscriptionQueryRequest) String() string

func (*SubscriptionQueryRequest) XXX_DiscardUnknown 

func (m *SubscriptionQueryRequest) XXX_DiscardUnknown()

func (*SubscriptionQueryRequest) XXX_Marshal 

func (m *SubscriptionQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubscriptionQueryRequest) XXX_Merge 

func (m *SubscriptionQueryRequest) XXX_Merge(src proto.Message)

func (*SubscriptionQueryRequest) XXX_OneofWrappers 

func (*SubscriptionQueryRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*SubscriptionQueryRequest) XXX_Size 

func (m *SubscriptionQueryRequest) XXX_Size() int

func (*SubscriptionQueryRequest) XXX_Unmarshal 

func (m *SubscriptionQueryRequest) XXX_Unmarshal(b []byte) error

type SubscriptionQueryRequest_FlowControl 

type SubscriptionQueryRequest_FlowControl struct {
	FlowControl *SubscriptionQuery `protobuf:"bytes,4,opt,name=flow_control,json=flowControl,proto3,oneof"`
}

type SubscriptionQueryRequest_GetInitialResult 

type SubscriptionQueryRequest_GetInitialResult struct {
	GetInitialResult *SubscriptionQuery `protobuf:"bytes,3,opt,name=get_initial_result,json=getInitialResult,proto3,oneof"`
}

type SubscriptionQueryRequest_Subscribe 

type SubscriptionQueryRequest_Subscribe struct {
	Subscribe *SubscriptionQuery `protobuf:"bytes,1,opt,name=subscribe,proto3,oneof"`
}

type SubscriptionQueryRequest_Unsubscribe 

type SubscriptionQueryRequest_Unsubscribe struct {
	Unsubscribe *SubscriptionQuery `protobuf:"bytes,2,opt,name=unsubscribe,proto3,oneof"`
}

type SubscriptionQueryResponse 

type SubscriptionQueryResponse struct {
	// The unique identifier for this message
	MessageIdentifier string `protobuf:"bytes,1,opt,name=message_identifier,json=messageIdentifier,proto3" json:"message_identifier,omitempty"`
	// The identifier of the subscription query this is a response for
	SubscriptionIdentifier string `` /* 127-byte string literal not displayed */
	// The actual response. The `initial_result` message is sent as a response to `get_initial_result`. An `update`
	//messages is sent for each update available for the query, even before the Initial Result is supplied. The
	//`complete` or `complete_exceptionally` are sent when the publishing side completed the Subscription Query,
	//either regularly (`complete`) or because an error occurred (`complete_exceptionally`).
	//
	// Types that are valid to be assigned to Response:
	//	*SubscriptionQueryResponse_InitialResult
	//	*SubscriptionQueryResponse_Update
	//	*SubscriptionQueryResponse_Complete
	//	*SubscriptionQueryResponse_CompleteExceptionally
	Response             isSubscriptionQueryResponse_Response `protobuf_oneof:"response"`
	XXX_NoUnkeyedLiteral struct{}                             `json:"-"`
	XXX_unrecognized     []byte                               `json:"-"`
	XXX_sizecache        int32                                `json:"-"`
}

Represents a Response Message for a Subscription Query

func (*SubscriptionQueryResponse) Descriptor 

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

func (*SubscriptionQueryResponse) GetComplete 

func (m *SubscriptionQueryResponse) GetComplete() *QueryUpdateComplete

func (*SubscriptionQueryResponse) GetCompleteExceptionally 

func (m *SubscriptionQueryResponse) GetCompleteExceptionally() *QueryUpdateCompleteExceptionally

func (*SubscriptionQueryResponse) GetInitialResult 

func (m *SubscriptionQueryResponse) GetInitialResult() *QueryResponse

func (*SubscriptionQueryResponse) GetMessageIdentifier 

func (m *SubscriptionQueryResponse) GetMessageIdentifier() string

func (*SubscriptionQueryResponse) GetResponse 

func (m *SubscriptionQueryResponse) GetResponse() isSubscriptionQueryResponse_Response

func (*SubscriptionQueryResponse) GetSubscriptionIdentifier 

func (m *SubscriptionQueryResponse) GetSubscriptionIdentifier() string

func (*SubscriptionQueryResponse) GetUpdate 

func (m *SubscriptionQueryResponse) GetUpdate() *QueryUpdate

func (*SubscriptionQueryResponse) ProtoMessage 

func (*SubscriptionQueryResponse) ProtoMessage()

func (*SubscriptionQueryResponse) Reset 

func (m *SubscriptionQueryResponse) Reset()

func (*SubscriptionQueryResponse) String 

func (m *SubscriptionQueryResponse) String() string

func (*SubscriptionQueryResponse) XXX_DiscardUnknown 

func (m *SubscriptionQueryResponse) XXX_DiscardUnknown()

func (*SubscriptionQueryResponse) XXX_Marshal 

func (m *SubscriptionQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubscriptionQueryResponse) XXX_Merge 

func (m *SubscriptionQueryResponse) XXX_Merge(src proto.Message)

func (*SubscriptionQueryResponse) XXX_OneofWrappers 

func (*SubscriptionQueryResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*SubscriptionQueryResponse) XXX_Size 

func (m *SubscriptionQueryResponse) XXX_Size() int

func (*SubscriptionQueryResponse) XXX_Unmarshal 

func (m *SubscriptionQueryResponse) XXX_Unmarshal(b []byte) error

type SubscriptionQueryResponse_Complete 

type SubscriptionQueryResponse_Complete struct {
	Complete *QueryUpdateComplete `protobuf:"bytes,5,opt,name=complete,proto3,oneof"`
}

type SubscriptionQueryResponse_CompleteExceptionally 

type SubscriptionQueryResponse_CompleteExceptionally struct {
	CompleteExceptionally *QueryUpdateCompleteExceptionally `protobuf:"bytes,6,opt,name=complete_exceptionally,json=completeExceptionally,proto3,oneof"`
}

type SubscriptionQueryResponse_InitialResult 

type SubscriptionQueryResponse_InitialResult struct {
	InitialResult *QueryResponse `protobuf:"bytes,3,opt,name=initial_result,json=initialResult,proto3,oneof"`
}

type SubscriptionQueryResponse_Update 

type SubscriptionQueryResponse_Update struct {
	Update *QueryUpdate `protobuf:"bytes,4,opt,name=update,proto3,oneof"`
}

type TrackingToken 

type TrackingToken struct {
	// The value of the Token
	Token                int64    `protobuf:"varint,1,opt,name=token,proto3" json:"token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message containing the information necessary to track the position of events in the Event Stream

func (*TrackingToken) Descriptor 

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

func (*TrackingToken) GetToken 

func (m *TrackingToken) GetToken() int64

func (*TrackingToken) ProtoMessage 

func (*TrackingToken) ProtoMessage()

func (*TrackingToken) Reset 

func (m *TrackingToken) Reset()

func (*TrackingToken) String 

func (m *TrackingToken) String() string

func (*TrackingToken) XXX_DiscardUnknown 

func (m *TrackingToken) XXX_DiscardUnknown()

func (*TrackingToken) XXX_Marshal 

func (m *TrackingToken) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TrackingToken) XXX_Merge 

func (m *TrackingToken) XXX_Merge(src proto.Message)

func (*TrackingToken) XXX_Size 

func (m *TrackingToken) XXX_Size() int

func (*TrackingToken) XXX_Unmarshal 

func (m *TrackingToken) XXX_Unmarshal(b []byte) error

type UnimplementedCommandServiceServer 

type UnimplementedCommandServiceServer struct {
}

UnimplementedCommandServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedCommandServiceServer) Dispatch 

func (*UnimplementedCommandServiceServer) Dispatch(ctx context.Context, req *Command) (*CommandResponse, error)

func (*UnimplementedCommandServiceServer) OpenStream 

func (*UnimplementedCommandServiceServer) OpenStream(srv CommandService_OpenStreamServer) error

type UnimplementedEventStoreServer 

type UnimplementedEventStoreServer struct {
}

UnimplementedEventStoreServer can be embedded to have forward compatible implementations.

func (*UnimplementedEventStoreServer) AppendEvent 

func (*UnimplementedEventStoreServer) AppendEvent(srv EventStore_AppendEventServer) error

func (*UnimplementedEventStoreServer) AppendSnapshot 

func (*UnimplementedEventStoreServer) AppendSnapshot(ctx context.Context, req *Event) (*Confirmation, error)

func (*UnimplementedEventStoreServer) GetFirstToken 

func (*UnimplementedEventStoreServer) GetFirstToken(ctx context.Context, req *GetFirstTokenRequest) (*TrackingToken, error)

func (*UnimplementedEventStoreServer) GetLastToken 

func (*UnimplementedEventStoreServer) GetLastToken(ctx context.Context, req *GetLastTokenRequest) (*TrackingToken, error)

func (*UnimplementedEventStoreServer) GetTokenAt 

func (*UnimplementedEventStoreServer) GetTokenAt(ctx context.Context, req *GetTokenAtRequest) (*TrackingToken, error)

func (*UnimplementedEventStoreServer) ListAggregateEvents 

func (*UnimplementedEventStoreServer) ListAggregateEvents(req *GetAggregateEventsRequest, srv EventStore_ListAggregateEventsServer) error

func (*UnimplementedEventStoreServer) ListAggregateSnapshots 

func (*UnimplementedEventStoreServer) ListAggregateSnapshots(req *GetAggregateSnapshotsRequest, srv EventStore_ListAggregateSnapshotsServer) error

func (*UnimplementedEventStoreServer) ListEvents 

func (*UnimplementedEventStoreServer) ListEvents(srv EventStore_ListEventsServer) error

func (*UnimplementedEventStoreServer) QueryEvents 

func (*UnimplementedEventStoreServer) QueryEvents(srv EventStore_QueryEventsServer) error

func (*UnimplementedEventStoreServer) ReadHighestSequenceNr 

func (*UnimplementedEventStoreServer) ReadHighestSequenceNr(ctx context.Context, req *ReadHighestSequenceNrRequest) (*ReadHighestSequenceNrResponse, error)

type UnimplementedPlatformServiceServer 

type UnimplementedPlatformServiceServer struct {
}

UnimplementedPlatformServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPlatformServiceServer) GetPlatformServer 

func (*UnimplementedPlatformServiceServer) GetPlatformServer(ctx context.Context, req *ClientIdentification) (*PlatformInfo, error)

func (*UnimplementedPlatformServiceServer) OpenStream 

func (*UnimplementedPlatformServiceServer) OpenStream(srv PlatformService_OpenStreamServer) error

type UnimplementedQueryServiceServer 

type UnimplementedQueryServiceServer struct {
}

UnimplementedQueryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServiceServer) OpenStream 

func (*UnimplementedQueryServiceServer) OpenStream(srv QueryService_OpenStreamServer) error

func (*UnimplementedQueryServiceServer) Query 

func (*UnimplementedQueryServiceServer) Query(req *QueryRequest, srv QueryService_QueryServer) error

func (*UnimplementedQueryServiceServer) Subscription 

func (*UnimplementedQueryServiceServer) Subscription(srv QueryService_SubscriptionServer) error

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.