flipbookv1

package
v0.0.0-...-955c200 Latest Latest
Warning

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

 Go to latest Published: Feb 20, 2023 License: MIT Imports: 12 Imported by: 0

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 EventBus_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "flipbook.v1.EventBus",
	HandlerType: (*EventBusServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Open",
			Handler:    _EventBus_Open_Handler,
		},
		{
			MethodName: "Close",
			Handler:    _EventBus_Close_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/eventbus.proto",
}

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

View Source 
var EventHandler_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "flipbook.v1.EventHandler",
	HandlerType: (*EventHandlerServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Handle",
			Handler:       _EventHandler_Handle_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "api/v1/eventhandler.proto",
}

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

View Source 
var EventStore_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "flipbook.v1.EventStore",
	HandlerType: (*EventStoreServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Append",
			Handler:    _EventStore_Append_Handler,
		},
		{
			MethodName: "GetLatest",
			Handler:    _EventStore_GetLatest_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Iterate",
			Handler:       _EventStore_Iterate_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "api/v1/eventstore.proto",
}

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

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

func RegisterEventBusServer 

func RegisterEventBusServer(s grpc.ServiceRegistrar, srv EventBusServer)

func RegisterEventHandlerServer 

func RegisterEventHandlerServer(s grpc.ServiceRegistrar, srv EventHandlerServer)

func RegisterEventStoreServer 

func RegisterEventStoreServer(s grpc.ServiceRegistrar, srv EventStoreServer)

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) Descriptor deprecated 

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

Deprecated: Use Commit.ProtoReflect.Descriptor instead.

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) String 

func (x *Commit) String() string

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) Descriptor deprecated 

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

Deprecated: Use Endpoint.ProtoReflect.Descriptor instead.

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) 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) EnumDescriptor deprecated 

func (Endpoint_AddressFamily) EnumDescriptor() ([]byte, []int)

Deprecated: Use Endpoint_AddressFamily.Descriptor instead.

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 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) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

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) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

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

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type EventBusClient 

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

EventBusClient is the client API for EventBus 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 NewEventBusClient 

func NewEventBusClient(cc grpc.ClientConnInterface) EventBusClient

type EventBusServer 

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

EventBusServer is the server API for EventBus service. All implementations must embed UnimplementedEventBusServer for forward compatibility

type EventHandlerClient 

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

EventHandlerClient is the client API for EventHandler 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 NewEventHandlerClient 

func NewEventHandlerClient(cc grpc.ClientConnInterface) EventHandlerClient

type EventHandlerServer 

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

EventHandlerServer is the server API for EventHandler service. All implementations must embed UnimplementedEventHandlerServer for forward compatibility

type EventHandler_HandleClient 

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

type EventHandler_HandleServer 

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

type EventStoreClient 

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

EventStoreClient is the client API for EventStore 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 NewEventStoreClient 

func NewEventStoreClient(cc grpc.ClientConnInterface) EventStoreClient

type EventStoreServer 

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
}

EventStoreServer is the server API for EventStore service. All implementations must embed UnimplementedEventStoreServer for forward compatibility

type EventStore_IterateClient 

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

type EventStore_IterateServer 

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

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) Descriptor deprecated 

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

Deprecated: Use Event_AppendRequest.ProtoReflect.Descriptor instead.

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) String 

func (x *Event_AppendRequest) String() string

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) Descriptor deprecated 

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

Deprecated: Use Event_GetLatestRequest.ProtoReflect.Descriptor instead.

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) String 

func (x *Event_GetLatestRequest) String() string

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) Descriptor deprecated 

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

Deprecated: Use Event_IterateRequest.ProtoReflect.Descriptor instead.

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) 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) String 

func (x *Event_IterateRequest) String() string

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) Descriptor deprecated 

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

Deprecated: Use Query.ProtoReflect.Descriptor instead.

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) 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) EnumDescriptor deprecated 

func (QueryStop) EnumDescriptor() ([]byte, []int)

Deprecated: Use QueryStop.Descriptor instead.

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 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) EnumDescriptor deprecated 

func (SortingKeyType) EnumDescriptor() ([]byte, []int)

Deprecated: Use SortingKeyType.Descriptor instead.

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) Descriptor deprecated 

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

Deprecated: Use Subscription.ProtoReflect.Descriptor instead.

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) ProtoMessage 

func (*Subscription) ProtoMessage()

func (*Subscription) ProtoReflect 

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

func (*Subscription) Reset 

func (x *Subscription) Reset()

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) EnumDescriptor deprecated 

func (SubscriptionStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use SubscriptionStatus.Descriptor instead.

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) Descriptor deprecated 

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

Deprecated: Use Subscription_CloseRequest.ProtoReflect.Descriptor instead.

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) String 

func (x *Subscription_CloseRequest) String() string

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) Descriptor deprecated 

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

Deprecated: Use Subscription_OpenRequest.ProtoReflect.Descriptor instead.

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) 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) String 

func (x *Subscription_OpenRequest) String() string

type UnimplementedEventBusServer 

type UnimplementedEventBusServer struct {
}

UnimplementedEventBusServer must be embedded to have forward compatible implementations.

func (UnimplementedEventBusServer) Close 

func (UnimplementedEventBusServer) Close(context.Context, *Subscription_CloseRequest) (*Subscription, error)

func (UnimplementedEventBusServer) Open 

func (UnimplementedEventBusServer) Open(context.Context, *Subscription_OpenRequest) (*Subscription, error)

type UnimplementedEventHandlerServer 

type UnimplementedEventHandlerServer struct {
}

UnimplementedEventHandlerServer must be embedded to have forward compatible implementations.

func (UnimplementedEventHandlerServer) Handle 

func (UnimplementedEventHandlerServer) Handle(EventHandler_HandleServer) error

type UnimplementedEventStoreServer 

type UnimplementedEventStoreServer struct {
}

UnimplementedEventStoreServer must be embedded to have forward compatible implementations.

func (UnimplementedEventStoreServer) Append 

func (UnimplementedEventStoreServer) Append(context.Context, *Event_AppendRequest) (*emptypb.Empty, error)

func (UnimplementedEventStoreServer) GetLatest 

func (UnimplementedEventStoreServer) GetLatest(context.Context, *Event_GetLatestRequest) (*Event, error)

func (UnimplementedEventStoreServer) Iterate 

func (UnimplementedEventStoreServer) Iterate(EventStore_IterateServer) error

type UnsafeEventBusServer 

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

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

type UnsafeEventHandlerServer 

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

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

type UnsafeEventStoreServer 

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

UnsafeEventStoreServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EventStoreServer 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.