rangedbpb

package
v0.12.0 Latest Latest
Warning

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

 Go to latest Published: Jul 2, 2021 License: BSD-3-Clause Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_rangedb_proto protoreflect.FileDescriptor
View Source 
var RangeDB_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rangedbpb.RangeDB",
	HandlerType: (*RangeDBServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "OptimisticDeleteStream",
			Handler:    _RangeDB_OptimisticDeleteStream_Handler,
		},
		{
			MethodName: "OptimisticSave",
			Handler:    _RangeDB_OptimisticSave_Handler,
		},
		{
			MethodName: "Save",
			Handler:    _RangeDB_Save_Handler,
		},
		{
			MethodName: "TotalEventsInStream",
			Handler:    _RangeDB_TotalEventsInStream_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Events",
			Handler:       _RangeDB_Events_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "EventsByAggregateType",
			Handler:       _RangeDB_EventsByAggregateType_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "EventsByStream",
			Handler:       _RangeDB_EventsByStream_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeToLiveEvents",
			Handler:       _RangeDB_SubscribeToLiveEvents_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeToEvents",
			Handler:       _RangeDB_SubscribeToEvents_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeToEventsByAggregateType",
			Handler:       _RangeDB_SubscribeToEventsByAggregateType_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "rangedb.proto",
}

RangeDB_ServiceDesc is the grpc.ServiceDesc for RangeDB service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterRangeDBServer 

func RegisterRangeDBServer(s grpc.ServiceRegistrar, srv RangeDBServer)

func ToRecord 

func ToRecord(pbRecord *Record, eventTypeIdentifier rangedb.EventTypeIdentifier) (*rangedb.Record, error)

ToRecord translates a rangedbpb.Record into a rangedb.Record.

Types

type Event 

type Event struct {
	Type     string `protobuf:"bytes,1,opt,name=Type,proto3" json:"Type,omitempty"`
	Data     string `protobuf:"bytes,2,opt,name=Data,proto3" json:"Data,omitempty"`
	Metadata string `protobuf:"bytes,3,opt,name=Metadata,proto3" json:"Metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetData 

func (x *Event) GetData() string

func (*Event) GetMetadata 

func (x *Event) GetMetadata() string

func (*Event) GetType 

func (x *Event) GetType() string

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect added in v0.3.1 

func (x *Event) ProtoReflect() protoreflect.Message

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type EventsByAggregateTypeRequest 

type EventsByAggregateTypeRequest struct {
	AggregateTypes       []string `protobuf:"bytes,1,rep,name=aggregateTypes,proto3" json:"aggregateTypes,omitempty"`
	GlobalSequenceNumber uint64   `protobuf:"varint,2,opt,name=globalSequenceNumber,proto3" json:"globalSequenceNumber,omitempty"`
	// contains filtered or unexported fields
}

func (*EventsByAggregateTypeRequest) Descriptor deprecated 

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

Deprecated: Use EventsByAggregateTypeRequest.ProtoReflect.Descriptor instead.

func (*EventsByAggregateTypeRequest) GetAggregateTypes 

func (x *EventsByAggregateTypeRequest) GetAggregateTypes() []string

func (*EventsByAggregateTypeRequest) GetGlobalSequenceNumber added in v0.6.0 

func (x *EventsByAggregateTypeRequest) GetGlobalSequenceNumber() uint64

func (*EventsByAggregateTypeRequest) ProtoMessage 

func (*EventsByAggregateTypeRequest) ProtoMessage()

func (*EventsByAggregateTypeRequest) ProtoReflect added in v0.3.1 

func (x *EventsByAggregateTypeRequest) ProtoReflect() protoreflect.Message

func (*EventsByAggregateTypeRequest) Reset 

func (x *EventsByAggregateTypeRequest) Reset()

func (*EventsByAggregateTypeRequest) String 

func (x *EventsByAggregateTypeRequest) String() string

type EventsByStreamRequest 

type EventsByStreamRequest struct {
	StreamName           string `protobuf:"bytes,1,opt,name=streamName,proto3" json:"streamName,omitempty"`
	StreamSequenceNumber uint64 `protobuf:"varint,2,opt,name=streamSequenceNumber,proto3" json:"streamSequenceNumber,omitempty"`
	// contains filtered or unexported fields
}

func (*EventsByStreamRequest) Descriptor deprecated 

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

Deprecated: Use EventsByStreamRequest.ProtoReflect.Descriptor instead.

func (*EventsByStreamRequest) GetStreamName 

func (x *EventsByStreamRequest) GetStreamName() string

func (*EventsByStreamRequest) GetStreamSequenceNumber added in v0.6.0 

func (x *EventsByStreamRequest) GetStreamSequenceNumber() uint64

func (*EventsByStreamRequest) ProtoMessage 

func (*EventsByStreamRequest) ProtoMessage()

func (*EventsByStreamRequest) ProtoReflect added in v0.3.1 

func (x *EventsByStreamRequest) ProtoReflect() protoreflect.Message

func (*EventsByStreamRequest) Reset 

func (x *EventsByStreamRequest) Reset()

func (*EventsByStreamRequest) String 

func (x *EventsByStreamRequest) String() string

type EventsRequest 

type EventsRequest struct {
	GlobalSequenceNumber uint64 `protobuf:"varint,1,opt,name=globalSequenceNumber,proto3" json:"globalSequenceNumber,omitempty"`
	// contains filtered or unexported fields
}

func (*EventsRequest) Descriptor deprecated 

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

Deprecated: Use EventsRequest.ProtoReflect.Descriptor instead.

func (*EventsRequest) GetGlobalSequenceNumber added in v0.6.0 

func (x *EventsRequest) GetGlobalSequenceNumber() uint64

func (*EventsRequest) ProtoMessage 

func (*EventsRequest) ProtoMessage()

func (*EventsRequest) ProtoReflect added in v0.3.1 

func (x *EventsRequest) ProtoReflect() protoreflect.Message

func (*EventsRequest) Reset 

func (x *EventsRequest) Reset()

func (*EventsRequest) String 

func (x *EventsRequest) String() string

type OptimisticDeleteStreamRequest added in v0.12.0 

type OptimisticDeleteStreamRequest struct {
	ExpectedStreamSequenceNumber uint64 `protobuf:"varint,1,opt,name=ExpectedStreamSequenceNumber,proto3" json:"ExpectedStreamSequenceNumber,omitempty"`
	StreamName                   string `protobuf:"bytes,2,opt,name=StreamName,proto3" json:"StreamName,omitempty"`
	// contains filtered or unexported fields
}

func (*OptimisticDeleteStreamRequest) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use OptimisticDeleteStreamRequest.ProtoReflect.Descriptor instead.

func (*OptimisticDeleteStreamRequest) GetExpectedStreamSequenceNumber added in v0.12.0 

func (x *OptimisticDeleteStreamRequest) GetExpectedStreamSequenceNumber() uint64

func (*OptimisticDeleteStreamRequest) GetStreamName added in v0.12.0 

func (x *OptimisticDeleteStreamRequest) GetStreamName() string

func (*OptimisticDeleteStreamRequest) ProtoMessage added in v0.12.0 

func (*OptimisticDeleteStreamRequest) ProtoMessage()

func (*OptimisticDeleteStreamRequest) ProtoReflect added in v0.12.0 

func (x *OptimisticDeleteStreamRequest) ProtoReflect() protoreflect.Message

func (*OptimisticDeleteStreamRequest) Reset added in v0.12.0 

func (x *OptimisticDeleteStreamRequest) Reset()

func (*OptimisticDeleteStreamRequest) String added in v0.12.0 

func (x *OptimisticDeleteStreamRequest) String() string

type OptimisticDeleteStreamResponse added in v0.12.0 

type OptimisticDeleteStreamResponse struct {
	EventsDeleted uint32 `protobuf:"varint,1,opt,name=EventsDeleted,proto3" json:"EventsDeleted,omitempty"`
	// contains filtered or unexported fields
}

func (*OptimisticDeleteStreamResponse) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use OptimisticDeleteStreamResponse.ProtoReflect.Descriptor instead.

func (*OptimisticDeleteStreamResponse) GetEventsDeleted added in v0.12.0 

func (x *OptimisticDeleteStreamResponse) GetEventsDeleted() uint32

func (*OptimisticDeleteStreamResponse) ProtoMessage added in v0.12.0 

func (*OptimisticDeleteStreamResponse) ProtoMessage()

func (*OptimisticDeleteStreamResponse) ProtoReflect added in v0.12.0 

func (x *OptimisticDeleteStreamResponse) ProtoReflect() protoreflect.Message

func (*OptimisticDeleteStreamResponse) Reset added in v0.12.0 

func (x *OptimisticDeleteStreamResponse) Reset()

func (*OptimisticDeleteStreamResponse) String added in v0.12.0 

func (x *OptimisticDeleteStreamResponse) String() string

type OptimisticSaveRequest added in v0.5.0 

type OptimisticSaveRequest struct {
	ExpectedStreamSequenceNumber uint64   `protobuf:"varint,1,opt,name=ExpectedStreamSequenceNumber,proto3" json:"ExpectedStreamSequenceNumber,omitempty"`
	AggregateType                string   `protobuf:"bytes,2,opt,name=AggregateType,proto3" json:"AggregateType,omitempty"`
	AggregateID                  string   `protobuf:"bytes,3,opt,name=AggregateID,proto3" json:"AggregateID,omitempty"`
	Events                       []*Event `protobuf:"bytes,4,rep,name=Events,proto3" json:"Events,omitempty"`
	// contains filtered or unexported fields
}

func (*OptimisticSaveRequest) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use OptimisticSaveRequest.ProtoReflect.Descriptor instead.

func (*OptimisticSaveRequest) GetAggregateID added in v0.5.0 

func (x *OptimisticSaveRequest) GetAggregateID() string

func (*OptimisticSaveRequest) GetAggregateType added in v0.5.0 

func (x *OptimisticSaveRequest) GetAggregateType() string

func (*OptimisticSaveRequest) GetEvents added in v0.5.0 

func (x *OptimisticSaveRequest) GetEvents() []*Event

func (*OptimisticSaveRequest) GetExpectedStreamSequenceNumber added in v0.5.0 

func (x *OptimisticSaveRequest) GetExpectedStreamSequenceNumber() uint64

func (*OptimisticSaveRequest) ProtoMessage added in v0.5.0 

func (*OptimisticSaveRequest) ProtoMessage()

func (*OptimisticSaveRequest) ProtoReflect added in v0.5.0 

func (x *OptimisticSaveRequest) ProtoReflect() protoreflect.Message

func (*OptimisticSaveRequest) Reset added in v0.5.0 

func (x *OptimisticSaveRequest) Reset()

func (*OptimisticSaveRequest) String added in v0.5.0 

func (x *OptimisticSaveRequest) String() string

type RangeDBClient 

type RangeDBClient interface {
	Events(ctx context.Context, in *EventsRequest, opts ...grpc.CallOption) (RangeDB_EventsClient, error)
	EventsByAggregateType(ctx context.Context, in *EventsByAggregateTypeRequest, opts ...grpc.CallOption) (RangeDB_EventsByAggregateTypeClient, error)
	EventsByStream(ctx context.Context, in *EventsByStreamRequest, opts ...grpc.CallOption) (RangeDB_EventsByStreamClient, error)
	OptimisticDeleteStream(ctx context.Context, in *OptimisticDeleteStreamRequest, opts ...grpc.CallOption) (*OptimisticDeleteStreamResponse, error)
	OptimisticSave(ctx context.Context, in *OptimisticSaveRequest, opts ...grpc.CallOption) (*SaveResponse, error)
	Save(ctx context.Context, in *SaveRequest, opts ...grpc.CallOption) (*SaveResponse, error)
	SubscribeToLiveEvents(ctx context.Context, in *SubscribeToLiveEventsRequest, opts ...grpc.CallOption) (RangeDB_SubscribeToLiveEventsClient, error)
	SubscribeToEvents(ctx context.Context, in *SubscribeToEventsRequest, opts ...grpc.CallOption) (RangeDB_SubscribeToEventsClient, error)
	SubscribeToEventsByAggregateType(ctx context.Context, in *SubscribeToEventsByAggregateTypeRequest, opts ...grpc.CallOption) (RangeDB_SubscribeToEventsByAggregateTypeClient, error)
	TotalEventsInStream(ctx context.Context, in *TotalEventsInStreamRequest, opts ...grpc.CallOption) (*TotalEventsInStreamResponse, error)
}

RangeDBClient is the client API for RangeDB service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewRangeDBClient 

func NewRangeDBClient(cc grpc.ClientConnInterface) RangeDBClient

type RangeDBServer 

type RangeDBServer interface {
	Events(*EventsRequest, RangeDB_EventsServer) error
	EventsByAggregateType(*EventsByAggregateTypeRequest, RangeDB_EventsByAggregateTypeServer) error
	EventsByStream(*EventsByStreamRequest, RangeDB_EventsByStreamServer) error
	OptimisticDeleteStream(context.Context, *OptimisticDeleteStreamRequest) (*OptimisticDeleteStreamResponse, error)
	OptimisticSave(context.Context, *OptimisticSaveRequest) (*SaveResponse, error)
	Save(context.Context, *SaveRequest) (*SaveResponse, error)
	SubscribeToLiveEvents(*SubscribeToLiveEventsRequest, RangeDB_SubscribeToLiveEventsServer) error
	SubscribeToEvents(*SubscribeToEventsRequest, RangeDB_SubscribeToEventsServer) error
	SubscribeToEventsByAggregateType(*SubscribeToEventsByAggregateTypeRequest, RangeDB_SubscribeToEventsByAggregateTypeServer) error
	TotalEventsInStream(context.Context, *TotalEventsInStreamRequest) (*TotalEventsInStreamResponse, error)
	// contains filtered or unexported methods
}

RangeDBServer is the server API for RangeDB service. All implementations must embed UnimplementedRangeDBServer for forward compatibility

type RangeDB_EventsByAggregateTypeClient 

type RangeDB_EventsByAggregateTypeClient interface {
	Recv() (*Record, error)
	grpc.ClientStream
}

type RangeDB_EventsByAggregateTypeServer 

type RangeDB_EventsByAggregateTypeServer interface {
	Send(*Record) error
	grpc.ServerStream
}

type RangeDB_EventsByStreamClient 

type RangeDB_EventsByStreamClient interface {
	Recv() (*Record, error)
	grpc.ClientStream
}

type RangeDB_EventsByStreamServer 

type RangeDB_EventsByStreamServer interface {
	Send(*Record) error
	grpc.ServerStream
}

type RangeDB_EventsClient 

type RangeDB_EventsClient interface {
	Recv() (*Record, error)
	grpc.ClientStream
}

type RangeDB_EventsServer 

type RangeDB_EventsServer interface {
	Send(*Record) error
	grpc.ServerStream
}

type RangeDB_SubscribeToEventsByAggregateTypeClient 

type RangeDB_SubscribeToEventsByAggregateTypeClient interface {
	Recv() (*Record, error)
	grpc.ClientStream
}

type RangeDB_SubscribeToEventsByAggregateTypeServer 

type RangeDB_SubscribeToEventsByAggregateTypeServer interface {
	Send(*Record) error
	grpc.ServerStream
}

type RangeDB_SubscribeToEventsClient 

type RangeDB_SubscribeToEventsClient interface {
	Recv() (*Record, error)
	grpc.ClientStream
}

type RangeDB_SubscribeToEventsServer 

type RangeDB_SubscribeToEventsServer interface {
	Send(*Record) error
	grpc.ServerStream
}

type RangeDB_SubscribeToLiveEventsClient 

type RangeDB_SubscribeToLiveEventsClient interface {
	Recv() (*Record, error)
	grpc.ClientStream
}

type RangeDB_SubscribeToLiveEventsServer 

type RangeDB_SubscribeToLiveEventsServer interface {
	Send(*Record) error
	grpc.ServerStream
}

type Record 

type Record struct {
	AggregateType        string `protobuf:"bytes,1,opt,name=AggregateType,proto3" json:"AggregateType,omitempty"`
	AggregateID          string `protobuf:"bytes,2,opt,name=AggregateID,proto3" json:"AggregateID,omitempty"`
	GlobalSequenceNumber uint64 `protobuf:"varint,3,opt,name=GlobalSequenceNumber,proto3" json:"GlobalSequenceNumber,omitempty"`
	StreamSequenceNumber uint64 `protobuf:"varint,4,opt,name=StreamSequenceNumber,proto3" json:"StreamSequenceNumber,omitempty"`
	InsertTimestamp      uint64 `protobuf:"varint,5,opt,name=InsertTimestamp,proto3" json:"InsertTimestamp,omitempty"`
	EventID              string `protobuf:"bytes,6,opt,name=EventID,proto3" json:"EventID,omitempty"`
	EventType            string `protobuf:"bytes,7,opt,name=EventType,proto3" json:"EventType,omitempty"`
	Data                 string `protobuf:"bytes,8,opt,name=Data,proto3" json:"Data,omitempty"`
	Metadata             string `protobuf:"bytes,9,opt,name=Metadata,proto3" json:"Metadata,omitempty"`
	// contains filtered or unexported fields
}

func ToPbRecord 

func ToPbRecord(record *rangedb.Record) (*Record, error)

ToPbRecord translates a rangedb.Record into a rangedbpb.Record.

func (*Record) Descriptor deprecated 

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

Deprecated: Use Record.ProtoReflect.Descriptor instead.

func (*Record) GetAggregateID 

func (x *Record) GetAggregateID() string

func (*Record) GetAggregateType 

func (x *Record) GetAggregateType() string

func (*Record) GetData 

func (x *Record) GetData() string

func (*Record) GetEventID 

func (x *Record) GetEventID() string

func (*Record) GetEventType 

func (x *Record) GetEventType() string

func (*Record) GetGlobalSequenceNumber 

func (x *Record) GetGlobalSequenceNumber() uint64

func (*Record) GetInsertTimestamp 

func (x *Record) GetInsertTimestamp() uint64

func (*Record) GetMetadata 

func (x *Record) GetMetadata() string

func (*Record) GetStreamSequenceNumber 

func (x *Record) GetStreamSequenceNumber() uint64

func (*Record) ProtoMessage 

func (*Record) ProtoMessage()

func (*Record) ProtoReflect added in v0.3.1 

func (x *Record) ProtoReflect() protoreflect.Message

func (*Record) Reset 

func (x *Record) Reset()

func (*Record) String 

func (x *Record) String() string

type SaveFailureResponse added in v0.5.0 

type SaveFailureResponse struct {
	Message string `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"`
	// contains filtered or unexported fields
}

func (*SaveFailureResponse) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use SaveFailureResponse.ProtoReflect.Descriptor instead.

func (*SaveFailureResponse) GetMessage added in v0.5.0 

func (x *SaveFailureResponse) GetMessage() string

func (*SaveFailureResponse) ProtoMessage added in v0.5.0 

func (*SaveFailureResponse) ProtoMessage()

func (*SaveFailureResponse) ProtoReflect added in v0.5.0 

func (x *SaveFailureResponse) ProtoReflect() protoreflect.Message

func (*SaveFailureResponse) Reset added in v0.5.0 

func (x *SaveFailureResponse) Reset()

func (*SaveFailureResponse) String added in v0.5.0 

func (x *SaveFailureResponse) String() string

type SaveRequest added in v0.5.0 

type SaveRequest struct {
	AggregateType string   `protobuf:"bytes,1,opt,name=AggregateType,proto3" json:"AggregateType,omitempty"`
	AggregateID   string   `protobuf:"bytes,2,opt,name=AggregateID,proto3" json:"AggregateID,omitempty"`
	Events        []*Event `protobuf:"bytes,3,rep,name=Events,proto3" json:"Events,omitempty"`
	// contains filtered or unexported fields
}

func (*SaveRequest) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use SaveRequest.ProtoReflect.Descriptor instead.

func (*SaveRequest) GetAggregateID added in v0.5.0 

func (x *SaveRequest) GetAggregateID() string

func (*SaveRequest) GetAggregateType added in v0.5.0 

func (x *SaveRequest) GetAggregateType() string

func (*SaveRequest) GetEvents added in v0.5.0 

func (x *SaveRequest) GetEvents() []*Event

func (*SaveRequest) ProtoMessage added in v0.5.0 

func (*SaveRequest) ProtoMessage()

func (*SaveRequest) ProtoReflect added in v0.5.0 

func (x *SaveRequest) ProtoReflect() protoreflect.Message

func (*SaveRequest) Reset added in v0.5.0 

func (x *SaveRequest) Reset()

func (*SaveRequest) String added in v0.5.0 

func (x *SaveRequest) String() string

type SaveResponse added in v0.5.0 

type SaveResponse struct {
	EventsSaved              uint32 `protobuf:"varint,1,opt,name=EventsSaved,proto3" json:"EventsSaved,omitempty"`
	LastStreamSequenceNumber uint64 `protobuf:"varint,2,opt,name=LastStreamSequenceNumber,proto3" json:"LastStreamSequenceNumber,omitempty"`
	// contains filtered or unexported fields
}

func (*SaveResponse) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use SaveResponse.ProtoReflect.Descriptor instead.

func (*SaveResponse) GetEventsSaved added in v0.5.0 

func (x *SaveResponse) GetEventsSaved() uint32

func (*SaveResponse) GetLastStreamSequenceNumber added in v0.6.0 

func (x *SaveResponse) GetLastStreamSequenceNumber() uint64

func (*SaveResponse) ProtoMessage added in v0.5.0 

func (*SaveResponse) ProtoMessage()

func (*SaveResponse) ProtoReflect added in v0.5.0 

func (x *SaveResponse) ProtoReflect() protoreflect.Message

func (*SaveResponse) Reset added in v0.5.0 

func (x *SaveResponse) Reset()

func (*SaveResponse) String added in v0.5.0 

func (x *SaveResponse) String() string

type SubscribeToEventsByAggregateTypeRequest 

type SubscribeToEventsByAggregateTypeRequest struct {
	AggregateTypes       []string `protobuf:"bytes,1,rep,name=aggregateTypes,proto3" json:"aggregateTypes,omitempty"`
	GlobalSequenceNumber uint64   `protobuf:"varint,2,opt,name=globalSequenceNumber,proto3" json:"globalSequenceNumber,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeToEventsByAggregateTypeRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeToEventsByAggregateTypeRequest.ProtoReflect.Descriptor instead.

func (*SubscribeToEventsByAggregateTypeRequest) GetAggregateTypes 

func (x *SubscribeToEventsByAggregateTypeRequest) GetAggregateTypes() []string

func (*SubscribeToEventsByAggregateTypeRequest) GetGlobalSequenceNumber added in v0.6.0 

func (x *SubscribeToEventsByAggregateTypeRequest) GetGlobalSequenceNumber() uint64

func (*SubscribeToEventsByAggregateTypeRequest) ProtoMessage 

func (*SubscribeToEventsByAggregateTypeRequest) ProtoMessage()

func (*SubscribeToEventsByAggregateTypeRequest) ProtoReflect added in v0.3.1 

func (x *SubscribeToEventsByAggregateTypeRequest) ProtoReflect() protoreflect.Message

func (*SubscribeToEventsByAggregateTypeRequest) Reset 

func (x *SubscribeToEventsByAggregateTypeRequest) Reset()

func (*SubscribeToEventsByAggregateTypeRequest) String 

func (x *SubscribeToEventsByAggregateTypeRequest) String() string

type SubscribeToEventsRequest 

type SubscribeToEventsRequest struct {
	GlobalSequenceNumber uint64 `protobuf:"varint,1,opt,name=globalSequenceNumber,proto3" json:"globalSequenceNumber,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeToEventsRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeToEventsRequest.ProtoReflect.Descriptor instead.

func (*SubscribeToEventsRequest) GetGlobalSequenceNumber added in v0.6.0 

func (x *SubscribeToEventsRequest) GetGlobalSequenceNumber() uint64

func (*SubscribeToEventsRequest) ProtoMessage 

func (*SubscribeToEventsRequest) ProtoMessage()

func (*SubscribeToEventsRequest) ProtoReflect added in v0.3.1 

func (x *SubscribeToEventsRequest) ProtoReflect() protoreflect.Message

func (*SubscribeToEventsRequest) Reset 

func (x *SubscribeToEventsRequest) Reset()

func (*SubscribeToEventsRequest) String 

func (x *SubscribeToEventsRequest) String() string

type SubscribeToLiveEventsRequest 

type SubscribeToLiveEventsRequest struct {
	// contains filtered or unexported fields
}

func (*SubscribeToLiveEventsRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeToLiveEventsRequest.ProtoReflect.Descriptor instead.

func (*SubscribeToLiveEventsRequest) ProtoMessage 

func (*SubscribeToLiveEventsRequest) ProtoMessage()

func (*SubscribeToLiveEventsRequest) ProtoReflect added in v0.3.1 

func (x *SubscribeToLiveEventsRequest) ProtoReflect() protoreflect.Message

func (*SubscribeToLiveEventsRequest) Reset 

func (x *SubscribeToLiveEventsRequest) Reset()

func (*SubscribeToLiveEventsRequest) String 

func (x *SubscribeToLiveEventsRequest) String() string

type TotalEventsInStreamRequest 

type TotalEventsInStreamRequest struct {
	StreamName string `protobuf:"bytes,1,opt,name=StreamName,proto3" json:"StreamName,omitempty"`
	// contains filtered or unexported fields
}

func (*TotalEventsInStreamRequest) Descriptor deprecated 

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

Deprecated: Use TotalEventsInStreamRequest.ProtoReflect.Descriptor instead.

func (*TotalEventsInStreamRequest) GetStreamName 

func (x *TotalEventsInStreamRequest) GetStreamName() string

func (*TotalEventsInStreamRequest) ProtoMessage 

func (*TotalEventsInStreamRequest) ProtoMessage()

func (*TotalEventsInStreamRequest) ProtoReflect added in v0.3.1 

func (x *TotalEventsInStreamRequest) ProtoReflect() protoreflect.Message

func (*TotalEventsInStreamRequest) Reset 

func (x *TotalEventsInStreamRequest) Reset()

func (*TotalEventsInStreamRequest) String 

func (x *TotalEventsInStreamRequest) String() string

type TotalEventsInStreamResponse 

type TotalEventsInStreamResponse struct {
	TotalEvents uint64 `protobuf:"varint,1,opt,name=TotalEvents,proto3" json:"TotalEvents,omitempty"`
	// contains filtered or unexported fields
}

func (*TotalEventsInStreamResponse) Descriptor deprecated 

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

Deprecated: Use TotalEventsInStreamResponse.ProtoReflect.Descriptor instead.

func (*TotalEventsInStreamResponse) GetTotalEvents 

func (x *TotalEventsInStreamResponse) GetTotalEvents() uint64

func (*TotalEventsInStreamResponse) ProtoMessage 

func (*TotalEventsInStreamResponse) ProtoMessage()

func (*TotalEventsInStreamResponse) ProtoReflect added in v0.3.1 

func (x *TotalEventsInStreamResponse) ProtoReflect() protoreflect.Message

func (*TotalEventsInStreamResponse) Reset 

func (x *TotalEventsInStreamResponse) Reset()

func (*TotalEventsInStreamResponse) String 

func (x *TotalEventsInStreamResponse) String() string

type UnimplementedRangeDBServer 

type UnimplementedRangeDBServer struct {
}

UnimplementedRangeDBServer must be embedded to have forward compatible implementations.

func (UnimplementedRangeDBServer) Events 

func (UnimplementedRangeDBServer) Events(*EventsRequest, RangeDB_EventsServer) error

func (UnimplementedRangeDBServer) EventsByAggregateType 

func (UnimplementedRangeDBServer) EventsByAggregateType(*EventsByAggregateTypeRequest, RangeDB_EventsByAggregateTypeServer) error

func (UnimplementedRangeDBServer) EventsByStream 

func (UnimplementedRangeDBServer) EventsByStream(*EventsByStreamRequest, RangeDB_EventsByStreamServer) error

func (UnimplementedRangeDBServer) OptimisticDeleteStream added in v0.12.0 

func (UnimplementedRangeDBServer) OptimisticDeleteStream(context.Context, *OptimisticDeleteStreamRequest) (*OptimisticDeleteStreamResponse, error)

func (UnimplementedRangeDBServer) OptimisticSave added in v0.5.0 

func (UnimplementedRangeDBServer) OptimisticSave(context.Context, *OptimisticSaveRequest) (*SaveResponse, error)

func (UnimplementedRangeDBServer) Save added in v0.5.0 

func (UnimplementedRangeDBServer) Save(context.Context, *SaveRequest) (*SaveResponse, error)

func (UnimplementedRangeDBServer) SubscribeToEvents 

func (UnimplementedRangeDBServer) SubscribeToEvents(*SubscribeToEventsRequest, RangeDB_SubscribeToEventsServer) error

func (UnimplementedRangeDBServer) SubscribeToEventsByAggregateType 

func (UnimplementedRangeDBServer) SubscribeToEventsByAggregateType(*SubscribeToEventsByAggregateTypeRequest, RangeDB_SubscribeToEventsByAggregateTypeServer) error

func (UnimplementedRangeDBServer) SubscribeToLiveEvents 

func (UnimplementedRangeDBServer) SubscribeToLiveEvents(*SubscribeToLiveEventsRequest, RangeDB_SubscribeToLiveEventsServer) error

func (UnimplementedRangeDBServer) TotalEventsInStream 

func (UnimplementedRangeDBServer) TotalEventsInStream(context.Context, *TotalEventsInStreamRequest) (*TotalEventsInStreamResponse, error)

type UnsafeRangeDBServer added in v0.5.0 

type UnsafeRangeDBServer interface {
	// contains filtered or unexported methods
}

UnsafeRangeDBServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RangeDBServer will result in compilation errors.

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.