flipbookv1

type Commit struct {
	PartitionKey string `protobuf:"bytes,1,opt,name=partition_key,json=partitionKey,proto3" json:"partition_key,omitempty"`
	SortingKey   int64  `protobuf:"varint,2,opt,name=sorting_key,json=sortingKey,proto3" json:"sorting_key,omitempty"`
	// contains filtered or unexported fields
}

type Endpoint struct {
	Address       string                 `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Port          uint32                 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	AddressFamily Endpoint_AddressFamily `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Endpoint_AddressFamily int32

type Event struct {

	// This key is used to route events to partitions. It must be unique for the
	// source generating it. We recommend using any well known standard like UUIDs
	// with a meaningful representation for business domainds
	PartitionKey string `protobuf:"bytes,1,opt,name=partition_key,json=partitionKey,proto3" json:"partition_key,omitempty"`
	// This key is used to control two things:
	// 1. The payload stored in this exact sorting key (a sorting key can only have 1 payload)
	// 2. The sorting order for EventStore.Iterate()
	//
	// An event "id" is the combination of the partition_key+sorting_key
	SortingKey     int64          `protobuf:"varint,2,opt,name=sorting_key,json=sortingKey,proto3" json:"sorting_key,omitempty"`
	EventPayload   *anypb.Any     `protobuf:"bytes,3,opt,name=event_payload,json=eventPayload,proto3" json:"event_payload,omitempty"`
	SortingKeyType SortingKeyType `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

type EventBusClient interface {
	Open(ctx context.Context, in *Subscription_OpenRequest, opts ...grpc.CallOption) (*Subscription, error)
	Close(ctx context.Context, in *Subscription_CloseRequest, opts ...grpc.CallOption) (*Subscription, error)
}

type EventBusServer interface {
	Open(context.Context, *Subscription_OpenRequest) (*Subscription, error)
	Close(context.Context, *Subscription_CloseRequest) (*Subscription, error)
	// contains filtered or unexported methods
}

type EventHandlerClient interface {
	Handle(ctx context.Context, opts ...grpc.CallOption) (EventHandler_HandleClient, error)
}

type EventHandlerServer interface {
	Handle(EventHandler_HandleServer) error
	// contains filtered or unexported methods
}

type EventHandler_HandleClient interface {
	Send(*Event) error
	Recv() (*Commit, error)
	grpc.ClientStream
}

type EventHandler_HandleServer interface {
	Send(*Commit) error
	Recv() (*Event, error)
	grpc.ServerStream
}

type EventStoreClient interface {
	Append(ctx context.Context, in *Event_AppendRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Iterate(ctx context.Context, opts ...grpc.CallOption) (EventStore_IterateClient, error)
	GetLatest(ctx context.Context, in *Event_GetLatestRequest, opts ...grpc.CallOption) (*Event, error)
}

type EventStoreServer interface {
	Append(context.Context, *Event_AppendRequest) (*emptypb.Empty, error)
	Iterate(EventStore_IterateServer) error
	GetLatest(context.Context, *Event_GetLatestRequest) (*Event, error)
	// contains filtered or unexported methods
}

type EventStore_IterateClient interface {
	Send(*Event_IterateRequest) error
	Recv() (*Event, error)
	grpc.ClientStream
}

type EventStore_IterateServer interface {
	Send(*Event) error
	Recv() (*Event_IterateRequest, error)
	grpc.ServerStream
}

type Event_AppendRequest struct {
	Events []*Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

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

type Event_IterateRequest struct {
	PartitionKey string `protobuf:"bytes,1,opt,name=partition_key,json=partitionKey,proto3" json:"partition_key,omitempty"`
	Query        *Query `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	BatchSize    int64  `protobuf:"varint,3,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	// contains filtered or unexported fields
}

type Query struct {
	StartSortingKey int64     `protobuf:"varint,1,opt,name=start_sorting_key,json=startSortingKey,proto3" json:"start_sorting_key,omitempty"`
	StopSortingKey  int64     `protobuf:"varint,2,opt,name=stop_sorting_key,json=stopSortingKey,proto3" json:"stop_sorting_key,omitempty"`
	Stop            QueryStop `protobuf:"varint,3,opt,name=stop,proto3,enum=flipbook.v1.QueryStop" json:"stop,omitempty"`
	// contains filtered or unexported fields
}

type QueryStop int32

type SortingKeyType int32

type Subscription struct {
	SubscriptionId            string                 `protobuf:"bytes,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	EventHandler              *Endpoint              `protobuf:"bytes,2,opt,name=event_handler,json=eventHandler,proto3" json:"event_handler,omitempty"`
	EstimatedConsistencyLevel float64                `` /* 140-byte string literal not displayed */
	Status                    SubscriptionStatus     `protobuf:"varint,4,opt,name=status,proto3,enum=flipbook.v1.SubscriptionStatus" json:"status,omitempty"`
	UpdatedAt                 *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

type SubscriptionStatus int32

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

type Subscription_OpenRequest struct {
	SubscriptionId string               `protobuf:"bytes,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	EventHandler   *Endpoint            `protobuf:"bytes,2,opt,name=event_handler,json=eventHandler,proto3" json:"event_handler,omitempty"`
	PushInterval   *durationpb.Duration `protobuf:"bytes,3,opt,name=push_interval,json=pushInterval,proto3" json:"push_interval,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedEventBusServer struct {
}

type UnimplementedEventHandlerServer struct {
}

type UnimplementedEventStoreServer struct {
}

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

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

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