rangedbpb

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Sep 3, 2020 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

Functions

func RegisterRangeDBServer 

func RegisterRangeDBServer(s *grpc.Server, srv RangeDBServer)

func ToRecord 

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

Types

type Event 

type Event struct {
	ID       string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Type     string `protobuf:"bytes,2,opt,name=Type,proto3" json:"Type,omitempty"`
	Data     string `protobuf:"bytes,3,opt,name=Data,proto3" json:"Data,omitempty"`
	Metadata string `protobuf:"bytes,4,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) GetID 

func (x *Event) GetID() 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"`
	StartingWithEventNumber uint64   `protobuf:"varint,2,opt,name=startingWithEventNumber,proto3" json:"startingWithEventNumber,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) GetStartingWithEventNumber 

func (x *EventsByAggregateTypeRequest) GetStartingWithEventNumber() 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"`
	StartingWithEventNumber uint64 `protobuf:"varint,2,opt,name=startingWithEventNumber,proto3" json:"startingWithEventNumber,omitempty"`
	// contains filtered or unexported fields
}

func (*EventsByStreamRequest) Descriptor deprecated 

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

Deprecated: Use EventsByStreamRequest.ProtoReflect.Descriptor instead.

func (*EventsByStreamRequest) GetStartingWithEventNumber 

func (x *EventsByStreamRequest) GetStartingWithEventNumber() uint64

func (*EventsByStreamRequest) GetStreamName 

func (x *EventsByStreamRequest) GetStreamName() string

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 {
	StartingWithEventNumber uint64 `protobuf:"varint,1,opt,name=startingWithEventNumber,proto3" json:"startingWithEventNumber,omitempty"`
	// contains filtered or unexported fields
}

func (*EventsRequest) Descriptor deprecated 

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

Deprecated: Use EventsRequest.ProtoReflect.Descriptor instead.

func (*EventsRequest) GetStartingWithEventNumber 

func (x *EventsRequest) GetStartingWithEventNumber() 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 RangeDBClient 

type RangeDBClient interface {
	Events(ctx context.Context, in *EventsRequest, opts ...grpc.CallOption) (RangeDB_EventsClient, error)
	EventsByStream(ctx context.Context, in *EventsByStreamRequest, opts ...grpc.CallOption) (RangeDB_EventsByStreamClient, error)
	EventsByAggregateType(ctx context.Context, in *EventsByAggregateTypeRequest, opts ...grpc.CallOption) (RangeDB_EventsByAggregateTypeClient, 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)
	SaveEvents(ctx context.Context, in *SaveEventsRequest, opts ...grpc.CallOption) (*SaveEventResponse, 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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewRangeDBClient 

func NewRangeDBClient(cc grpc.ClientConnInterface) RangeDBClient

type RangeDBServer 

type RangeDBServer interface {
	Events(*EventsRequest, RangeDB_EventsServer) error
	EventsByStream(*EventsByStreamRequest, RangeDB_EventsByStreamServer) error
	EventsByAggregateType(*EventsByAggregateTypeRequest, RangeDB_EventsByAggregateTypeServer) error
	SubscribeToLiveEvents(*SubscribeToLiveEventsRequest, RangeDB_SubscribeToLiveEventsServer) error
	SubscribeToEvents(*SubscribeToEventsRequest, RangeDB_SubscribeToEventsServer) error
	SubscribeToEventsByAggregateType(*SubscribeToEventsByAggregateTypeRequest, RangeDB_SubscribeToEventsByAggregateTypeServer) error
	SaveEvents(context.Context, *SaveEventsRequest) (*SaveEventResponse, error)
	TotalEventsInStream(context.Context, *TotalEventsInStreamRequest) (*TotalEventsInStreamResponse, error)
}

RangeDBServer is the server API for RangeDB service.

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)

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 SaveEventFailureResponse 

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

func (*SaveEventFailureResponse) Descriptor deprecated 

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

Deprecated: Use SaveEventFailureResponse.ProtoReflect.Descriptor instead.

func (*SaveEventFailureResponse) GetEventsSaved 

func (x *SaveEventFailureResponse) GetEventsSaved() uint32

func (*SaveEventFailureResponse) ProtoMessage 

func (*SaveEventFailureResponse) ProtoMessage()

func (*SaveEventFailureResponse) ProtoReflect added in v0.3.1 

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

func (*SaveEventFailureResponse) Reset 

func (x *SaveEventFailureResponse) Reset()

func (*SaveEventFailureResponse) String 

func (x *SaveEventFailureResponse) String() string

type SaveEventResponse 

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

func (*SaveEventResponse) Descriptor deprecated 

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

Deprecated: Use SaveEventResponse.ProtoReflect.Descriptor instead.

func (*SaveEventResponse) GetEventsSaved 

func (x *SaveEventResponse) GetEventsSaved() uint32

func (*SaveEventResponse) ProtoMessage 

func (*SaveEventResponse) ProtoMessage()

func (*SaveEventResponse) ProtoReflect added in v0.3.1 

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

func (*SaveEventResponse) Reset 

func (x *SaveEventResponse) Reset()

func (*SaveEventResponse) String 

func (x *SaveEventResponse) String() string

type SaveEventsRequest 

type SaveEventsRequest 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 (*SaveEventsRequest) Descriptor deprecated 

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

Deprecated: Use SaveEventsRequest.ProtoReflect.Descriptor instead.

func (*SaveEventsRequest) GetAggregateID 

func (x *SaveEventsRequest) GetAggregateID() string

func (*SaveEventsRequest) GetAggregateType 

func (x *SaveEventsRequest) GetAggregateType() string

func (*SaveEventsRequest) GetEvents 

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

func (*SaveEventsRequest) ProtoMessage 

func (*SaveEventsRequest) ProtoMessage()

func (*SaveEventsRequest) ProtoReflect added in v0.3.1 

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

func (*SaveEventsRequest) Reset 

func (x *SaveEventsRequest) Reset()

func (*SaveEventsRequest) String 

func (x *SaveEventsRequest) String() string

type SubscribeToEventsByAggregateTypeRequest 

type SubscribeToEventsByAggregateTypeRequest struct {
	AggregateTypes          []string `protobuf:"bytes,1,rep,name=aggregateTypes,proto3" json:"aggregateTypes,omitempty"`
	StartingWithEventNumber uint64   `protobuf:"varint,2,opt,name=startingWithEventNumber,proto3" json:"startingWithEventNumber,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) GetStartingWithEventNumber 

func (x *SubscribeToEventsByAggregateTypeRequest) GetStartingWithEventNumber() 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 {
	StartingWithEventNumber uint64 `protobuf:"varint,1,opt,name=startingWithEventNumber,proto3" json:"startingWithEventNumber,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeToEventsRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeToEventsRequest.ProtoReflect.Descriptor instead.

func (*SubscribeToEventsRequest) GetStartingWithEventNumber 

func (x *SubscribeToEventsRequest) GetStartingWithEventNumber() 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 can 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) SaveEvents 

func (*UnimplementedRangeDBServer) SaveEvents(context.Context, *SaveEventsRequest) (*SaveEventResponse, 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)

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.