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 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
}