flipbookv1

package
v1.36.10-2023022015321... Latest Latest
Warning

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

 Go to latest Published: unknown License: MIT Imports: 8 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Endpoint_AddressFamily_name = map[int32]string{
		0: "ADDRESS_FAMILY_IPV4",
		1: "ADDRESS_FAMILY_IPV6",
	}
	Endpoint_AddressFamily_value = map[string]int32{
		"ADDRESS_FAMILY_IPV4": 0,
		"ADDRESS_FAMILY_IPV6": 1,
	}
)

Enum value maps for Endpoint_AddressFamily.

View Source 
var (
	SortingKeyType_name = map[int32]string{
		0: "SORTING_KEY_INCREASING_SEQUENCE",
		1: "SORTING_KEY_ARBITRARY_NUMBER",
	}
	SortingKeyType_value = map[string]int32{
		"SORTING_KEY_INCREASING_SEQUENCE": 0,
		"SORTING_KEY_ARBITRARY_NUMBER":    1,
	}
)

Enum value maps for SortingKeyType.

View Source 
var (
	QueryStop_name = map[int32]string{
		0: "QUERY_STOP_LATEST",
		1: "QUERY_STOP_EXACT",
	}
	QueryStop_value = map[string]int32{
		"QUERY_STOP_LATEST": 0,
		"QUERY_STOP_EXACT":  1,
	}
)

Enum value maps for QueryStop.

View Source 
var (
	SubscriptionStatus_name = map[int32]string{
		0: "SUBSCRIPTION_STATUS_IDLE",
		1: "SUBSCRIPTION_STATUS_ACTIVE",
	}
	SubscriptionStatus_value = map[string]int32{
		"SUBSCRIPTION_STATUS_IDLE":   0,
		"SUBSCRIPTION_STATUS_ACTIVE": 1,
	}
)

Enum value maps for SubscriptionStatus.

View Source 
var File_api_v1_endpoint_proto protoreflect.FileDescriptor
View Source 
var File_api_v1_event_proto protoreflect.FileDescriptor
View Source 
var File_api_v1_eventbus_proto protoreflect.FileDescriptor
View Source 
var File_api_v1_eventhandler_proto protoreflect.FileDescriptor
View Source 
var File_api_v1_eventstore_proto protoreflect.FileDescriptor
View Source 
var File_api_v1_query_proto protoreflect.FileDescriptor
View Source 
var File_api_v1_subscription_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Commit 

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
}

func (*Commit) GetPartitionKey 

func (x *Commit) GetPartitionKey() string

func (*Commit) GetSortingKey 

func (x *Commit) GetSortingKey() int64

func (*Commit) ProtoMessage 

func (*Commit) ProtoMessage()

func (*Commit) ProtoReflect 

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

func (*Commit) Reset 

func (x *Commit) Reset()

func (*Commit) SetPartitionKey 

func (x *Commit) SetPartitionKey(v string)

func (*Commit) SetSortingKey 

func (x *Commit) SetSortingKey(v int64)

func (*Commit) String 

func (x *Commit) String() string

type Commit_builder 

type Commit_builder struct {
	PartitionKey string
	SortingKey   int64
	// contains filtered or unexported fields
}

func (Commit_builder) Build 

func (b0 Commit_builder) Build() *Commit

type Endpoint 

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
}

func (*Endpoint) GetAddress 

func (x *Endpoint) GetAddress() string

func (*Endpoint) GetAddressFamily 

func (x *Endpoint) GetAddressFamily() Endpoint_AddressFamily

func (*Endpoint) GetPort 

func (x *Endpoint) GetPort() uint32

func (*Endpoint) ProtoMessage 

func (*Endpoint) ProtoMessage()

func (*Endpoint) ProtoReflect 

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

func (*Endpoint) Reset 

func (x *Endpoint) Reset()

func (*Endpoint) SetAddress 

func (x *Endpoint) SetAddress(v string)

func (*Endpoint) SetAddressFamily 

func (x *Endpoint) SetAddressFamily(v Endpoint_AddressFamily)

func (*Endpoint) SetPort 

func (x *Endpoint) SetPort(v uint32)

func (*Endpoint) String 

func (x *Endpoint) String() string

type Endpoint_AddressFamily 

type Endpoint_AddressFamily int32
const (
	Endpoint_ADDRESS_FAMILY_IPV4 Endpoint_AddressFamily = 0
	Endpoint_ADDRESS_FAMILY_IPV6 Endpoint_AddressFamily = 1
)

func (Endpoint_AddressFamily) Descriptor 

func (Endpoint_AddressFamily) Descriptor() protoreflect.EnumDescriptor

func (Endpoint_AddressFamily) Enum 

func (x Endpoint_AddressFamily) Enum() *Endpoint_AddressFamily

func (Endpoint_AddressFamily) Number 

func (x Endpoint_AddressFamily) Number() protoreflect.EnumNumber

func (Endpoint_AddressFamily) String 

func (x Endpoint_AddressFamily) String() string

func (Endpoint_AddressFamily) Type 

func (Endpoint_AddressFamily) Type() protoreflect.EnumType

type Endpoint_builder 

type Endpoint_builder struct {
	Address       string
	Port          uint32
	AddressFamily Endpoint_AddressFamily
	// contains filtered or unexported fields
}

func (Endpoint_builder) Build 

func (b0 Endpoint_builder) Build() *Endpoint

type Event 

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
}

func (*Event) ClearEventPayload 

func (x *Event) ClearEventPayload()

func (*Event) GetEventPayload 

func (x *Event) GetEventPayload() *anypb.Any

func (*Event) GetPartitionKey 

func (x *Event) GetPartitionKey() string

func (*Event) GetSortingKey 

func (x *Event) GetSortingKey() int64

func (*Event) GetSortingKeyType 

func (x *Event) GetSortingKeyType() SortingKeyType

func (*Event) HasEventPayload 

func (x *Event) HasEventPayload() bool

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

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

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) SetEventPayload 

func (x *Event) SetEventPayload(v *anypb.Any)

func (*Event) SetPartitionKey 

func (x *Event) SetPartitionKey(v string)

func (*Event) SetSortingKey 

func (x *Event) SetSortingKey(v int64)

func (*Event) SetSortingKeyType 

func (x *Event) SetSortingKeyType(v SortingKeyType)

func (*Event) String 

func (x *Event) String() string

type Event_AppendRequest 

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

func (*Event_AppendRequest) GetEvents 

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

func (*Event_AppendRequest) ProtoMessage 

func (*Event_AppendRequest) ProtoMessage()

func (*Event_AppendRequest) ProtoReflect 

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

func (*Event_AppendRequest) Reset 

func (x *Event_AppendRequest) Reset()

func (*Event_AppendRequest) SetEvents 

func (x *Event_AppendRequest) SetEvents(v []*Event)

func (*Event_AppendRequest) String 

func (x *Event_AppendRequest) String() string

type Event_AppendRequest_builder 

type Event_AppendRequest_builder struct {
	Events []*Event
	// contains filtered or unexported fields
}

func (Event_AppendRequest_builder) Build 

func (b0 Event_AppendRequest_builder) Build() *Event_AppendRequest

type Event_GetLatestRequest 

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
}

func (*Event_GetLatestRequest) GetPartitionKey 

func (x *Event_GetLatestRequest) GetPartitionKey() string

func (*Event_GetLatestRequest) ProtoMessage 

func (*Event_GetLatestRequest) ProtoMessage()

func (*Event_GetLatestRequest) ProtoReflect 

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

func (*Event_GetLatestRequest) Reset 

func (x *Event_GetLatestRequest) Reset()

func (*Event_GetLatestRequest) SetPartitionKey 

func (x *Event_GetLatestRequest) SetPartitionKey(v string)

func (*Event_GetLatestRequest) String 

func (x *Event_GetLatestRequest) String() string

type Event_GetLatestRequest_builder 

type Event_GetLatestRequest_builder struct {
	PartitionKey string
	// contains filtered or unexported fields
}

func (Event_GetLatestRequest_builder) Build 

func (b0 Event_GetLatestRequest_builder) Build() *Event_GetLatestRequest

type Event_IterateRequest 

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
}

func (*Event_IterateRequest) ClearQuery 

func (x *Event_IterateRequest) ClearQuery()

func (*Event_IterateRequest) GetBatchSize 

func (x *Event_IterateRequest) GetBatchSize() int64

func (*Event_IterateRequest) GetPartitionKey 

func (x *Event_IterateRequest) GetPartitionKey() string

func (*Event_IterateRequest) GetQuery 

func (x *Event_IterateRequest) GetQuery() *Query

func (*Event_IterateRequest) HasQuery 

func (x *Event_IterateRequest) HasQuery() bool

func (*Event_IterateRequest) ProtoMessage 

func (*Event_IterateRequest) ProtoMessage()

func (*Event_IterateRequest) ProtoReflect 

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

func (*Event_IterateRequest) Reset 

func (x *Event_IterateRequest) Reset()

func (*Event_IterateRequest) SetBatchSize 

func (x *Event_IterateRequest) SetBatchSize(v int64)

func (*Event_IterateRequest) SetPartitionKey 

func (x *Event_IterateRequest) SetPartitionKey(v string)

func (*Event_IterateRequest) SetQuery 

func (x *Event_IterateRequest) SetQuery(v *Query)

func (*Event_IterateRequest) String 

func (x *Event_IterateRequest) String() string

type Event_IterateRequest_builder 

type Event_IterateRequest_builder struct {
	PartitionKey string
	Query        *Query
	BatchSize    int64
	// contains filtered or unexported fields
}

func (Event_IterateRequest_builder) Build 

func (b0 Event_IterateRequest_builder) Build() *Event_IterateRequest

type Event_builder 

type Event_builder 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
	// 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
	EventPayload   *anypb.Any
	SortingKeyType SortingKeyType
	// contains filtered or unexported fields
}

func (Event_builder) Build 

func (b0 Event_builder) Build() *Event

type Query 

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
}

func (*Query) GetStartSortingKey 

func (x *Query) GetStartSortingKey() int64

func (*Query) GetStop 

func (x *Query) GetStop() QueryStop

func (*Query) GetStopSortingKey 

func (x *Query) GetStopSortingKey() int64

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) ProtoReflect 

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

func (*Query) Reset 

func (x *Query) Reset()

func (*Query) SetStartSortingKey 

func (x *Query) SetStartSortingKey(v int64)

func (*Query) SetStop 

func (x *Query) SetStop(v QueryStop)

func (*Query) SetStopSortingKey 

func (x *Query) SetStopSortingKey(v int64)

func (*Query) String 

func (x *Query) String() string

type QueryStop 

type QueryStop int32
const (
	QueryStop_QUERY_STOP_LATEST QueryStop = 0
	QueryStop_QUERY_STOP_EXACT  QueryStop = 1
)

func (QueryStop) Descriptor 

func (QueryStop) Descriptor() protoreflect.EnumDescriptor

func (QueryStop) Enum 

func (x QueryStop) Enum() *QueryStop

func (QueryStop) Number 

func (x QueryStop) Number() protoreflect.EnumNumber

func (QueryStop) String 

func (x QueryStop) String() string

func (QueryStop) Type 

func (QueryStop) Type() protoreflect.EnumType

type Query_builder 

type Query_builder struct {
	StartSortingKey int64
	StopSortingKey  int64
	Stop            QueryStop
	// contains filtered or unexported fields
}

func (Query_builder) Build 

func (b0 Query_builder) Build() *Query

type SortingKeyType 

type SortingKeyType int32
const (
	SortingKeyType_SORTING_KEY_INCREASING_SEQUENCE SortingKeyType = 0
	SortingKeyType_SORTING_KEY_ARBITRARY_NUMBER    SortingKeyType = 1
)

func (SortingKeyType) Descriptor 

func (SortingKeyType) Descriptor() protoreflect.EnumDescriptor

func (SortingKeyType) Enum 

func (x SortingKeyType) Enum() *SortingKeyType

func (SortingKeyType) Number 

func (x SortingKeyType) Number() protoreflect.EnumNumber

func (SortingKeyType) String 

func (x SortingKeyType) String() string

func (SortingKeyType) Type 

func (SortingKeyType) Type() protoreflect.EnumType

type Subscription 

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
}

func (*Subscription) ClearEventHandler 

func (x *Subscription) ClearEventHandler()

func (*Subscription) ClearUpdatedAt 

func (x *Subscription) ClearUpdatedAt()

func (*Subscription) GetEstimatedConsistencyLevel 

func (x *Subscription) GetEstimatedConsistencyLevel() float64

func (*Subscription) GetEventHandler 

func (x *Subscription) GetEventHandler() *Endpoint

func (*Subscription) GetStatus 

func (x *Subscription) GetStatus() SubscriptionStatus

func (*Subscription) GetSubscriptionId 

func (x *Subscription) GetSubscriptionId() string

func (*Subscription) GetUpdatedAt 

func (x *Subscription) GetUpdatedAt() *timestamppb.Timestamp

func (*Subscription) HasEventHandler 

func (x *Subscription) HasEventHandler() bool

func (*Subscription) HasUpdatedAt 

func (x *Subscription) HasUpdatedAt() bool

func (*Subscription) ProtoMessage 

func (*Subscription) ProtoMessage()

func (*Subscription) ProtoReflect 

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

func (*Subscription) Reset 

func (x *Subscription) Reset()

func (*Subscription) SetEstimatedConsistencyLevel 

func (x *Subscription) SetEstimatedConsistencyLevel(v float64)

func (*Subscription) SetEventHandler 

func (x *Subscription) SetEventHandler(v *Endpoint)

func (*Subscription) SetStatus 

func (x *Subscription) SetStatus(v SubscriptionStatus)

func (*Subscription) SetSubscriptionId 

func (x *Subscription) SetSubscriptionId(v string)

func (*Subscription) SetUpdatedAt 

func (x *Subscription) SetUpdatedAt(v *timestamppb.Timestamp)

func (*Subscription) String 

func (x *Subscription) String() string

type SubscriptionStatus 

type SubscriptionStatus int32
const (
	SubscriptionStatus_SUBSCRIPTION_STATUS_IDLE   SubscriptionStatus = 0
	SubscriptionStatus_SUBSCRIPTION_STATUS_ACTIVE SubscriptionStatus = 1
)

func (SubscriptionStatus) Descriptor 

func (SubscriptionStatus) Descriptor() protoreflect.EnumDescriptor

func (SubscriptionStatus) Enum 

func (x SubscriptionStatus) Enum() *SubscriptionStatus

func (SubscriptionStatus) Number 

func (x SubscriptionStatus) Number() protoreflect.EnumNumber

func (SubscriptionStatus) String 

func (x SubscriptionStatus) String() string

func (SubscriptionStatus) Type 

func (SubscriptionStatus) Type() protoreflect.EnumType

type Subscription_CloseRequest 

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
}

func (*Subscription_CloseRequest) GetSubscriptionId 

func (x *Subscription_CloseRequest) GetSubscriptionId() string

func (*Subscription_CloseRequest) ProtoMessage 

func (*Subscription_CloseRequest) ProtoMessage()

func (*Subscription_CloseRequest) ProtoReflect 

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

func (*Subscription_CloseRequest) Reset 

func (x *Subscription_CloseRequest) Reset()

func (*Subscription_CloseRequest) SetSubscriptionId 

func (x *Subscription_CloseRequest) SetSubscriptionId(v string)

func (*Subscription_CloseRequest) String 

func (x *Subscription_CloseRequest) String() string

type Subscription_CloseRequest_builder 

type Subscription_CloseRequest_builder struct {
	SubscriptionId string
	// contains filtered or unexported fields
}

func (Subscription_CloseRequest_builder) Build 

func (b0 Subscription_CloseRequest_builder) Build() *Subscription_CloseRequest

type Subscription_OpenRequest 

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
}

func (*Subscription_OpenRequest) ClearEventHandler 

func (x *Subscription_OpenRequest) ClearEventHandler()

func (*Subscription_OpenRequest) ClearPushInterval 

func (x *Subscription_OpenRequest) ClearPushInterval()

func (*Subscription_OpenRequest) GetEventHandler 

func (x *Subscription_OpenRequest) GetEventHandler() *Endpoint

func (*Subscription_OpenRequest) GetPushInterval 

func (x *Subscription_OpenRequest) GetPushInterval() *durationpb.Duration

func (*Subscription_OpenRequest) GetSubscriptionId 

func (x *Subscription_OpenRequest) GetSubscriptionId() string

func (*Subscription_OpenRequest) HasEventHandler 

func (x *Subscription_OpenRequest) HasEventHandler() bool

func (*Subscription_OpenRequest) HasPushInterval 

func (x *Subscription_OpenRequest) HasPushInterval() bool

func (*Subscription_OpenRequest) ProtoMessage 

func (*Subscription_OpenRequest) ProtoMessage()

func (*Subscription_OpenRequest) ProtoReflect 

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

func (*Subscription_OpenRequest) Reset 

func (x *Subscription_OpenRequest) Reset()

func (*Subscription_OpenRequest) SetEventHandler 

func (x *Subscription_OpenRequest) SetEventHandler(v *Endpoint)

func (*Subscription_OpenRequest) SetPushInterval 

func (x *Subscription_OpenRequest) SetPushInterval(v *durationpb.Duration)

func (*Subscription_OpenRequest) SetSubscriptionId 

func (x *Subscription_OpenRequest) SetSubscriptionId(v string)

func (*Subscription_OpenRequest) String 

func (x *Subscription_OpenRequest) String() string

type Subscription_OpenRequest_builder 

type Subscription_OpenRequest_builder struct {
	SubscriptionId string
	EventHandler   *Endpoint
	PushInterval   *durationpb.Duration
	// contains filtered or unexported fields
}

func (Subscription_OpenRequest_builder) Build 

func (b0 Subscription_OpenRequest_builder) Build() *Subscription_OpenRequest

type Subscription_builder 

type Subscription_builder struct {
	SubscriptionId            string
	EventHandler              *Endpoint
	EstimatedConsistencyLevel float64
	Status                    SubscriptionStatus
	UpdatedAt                 *timestamppb.Timestamp
	// contains filtered or unexported fields
}

func (Subscription_builder) Build 

func (b0 Subscription_builder) Build() *Subscription

Source Files

  • endpoint.pb.go
  • event.pb.go
  • eventbus.pb.go
  • eventhandler.pb.go
  • eventstore.pb.go
  • query.pb.go
  • subscription.pb.go

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.