Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterEventBusServer(s grpc.ServiceRegistrar, srv EventBusServer)
- func RegisterEventHandlerServer(s grpc.ServiceRegistrar, srv EventHandlerServer)
- func RegisterEventStoreServer(s grpc.ServiceRegistrar, srv EventStoreServer)
- type EventBusClient
- type EventBusServer
- type EventHandlerClient
- type EventHandlerServer
- type EventHandler_HandleClient
- type EventHandler_HandleServer
- type EventStoreClient
- type EventStoreServer
- type EventStore_IterateClient
- type EventStore_IterateServer
- type UnimplementedEventBusServer
- type UnimplementedEventHandlerServer
- type UnimplementedEventStoreServer
- type UnsafeEventBusServer
- type UnsafeEventHandlerServer
- type UnsafeEventStoreServer
Constants ¶
const ( EventBus_Open_FullMethodName = "/flipbook.v1.EventBus/Open" EventBus_Close_FullMethodName = "/flipbook.v1.EventBus/Close" )
const ( EventStore_Append_FullMethodName = "/flipbook.v1.EventStore/Append" EventStore_Iterate_FullMethodName = "/flipbook.v1.EventStore/Iterate" EventStore_GetLatest_FullMethodName = "/flipbook.v1.EventStore/GetLatest" )
const (
EventHandler_Handle_FullMethodName = "/flipbook.v1.EventHandler/Handle"
)
Variables ¶
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)
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)
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)
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 EventBusClient ¶
type EventBusClient interface { Open(ctx context.Context, in *v1.Subscription_OpenRequest, opts ...grpc.CallOption) (*v1.Subscription, error) Close(ctx context.Context, in *v1.Subscription_CloseRequest, opts ...grpc.CallOption) (*v1.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.golang.ir/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewEventBusClient ¶
func NewEventBusClient(cc grpc.ClientConnInterface) EventBusClient
type EventBusServer ¶
type EventBusServer interface { Open(context.Context, *v1.Subscription_OpenRequest) (*v1.Subscription, error) Close(context.Context, *v1.Subscription_CloseRequest) (*v1.Subscription, error) }
EventBusServer is the server API for EventBus service. All implementations should 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.golang.ir/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
}
EventHandlerServer is the server API for EventHandler service. All implementations should embed UnimplementedEventHandlerServer for forward compatibility
type EventHandler_HandleClient ¶
type EventHandler_HandleServer ¶
type EventStoreClient ¶
type EventStoreClient interface { Append(ctx context.Context, in *v1.Event_AppendRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) Iterate(ctx context.Context, opts ...grpc.CallOption) (EventStore_IterateClient, error) GetLatest(ctx context.Context, in *v1.Event_GetLatestRequest, opts ...grpc.CallOption) (*v1.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.golang.ir/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewEventStoreClient ¶
func NewEventStoreClient(cc grpc.ClientConnInterface) EventStoreClient
type EventStoreServer ¶
type EventStoreServer interface { Append(context.Context, *v1.Event_AppendRequest) (*emptypb.Empty, error) Iterate(EventStore_IterateServer) error GetLatest(context.Context, *v1.Event_GetLatestRequest) (*v1.Event, error) }
EventStoreServer is the server API for EventStore service. All implementations should embed UnimplementedEventStoreServer for forward compatibility
type EventStore_IterateClient ¶
type EventStore_IterateClient interface { Send(*v1.Event_IterateRequest) error Recv() (*v1.Event, error) grpc.ClientStream }
type EventStore_IterateServer ¶
type EventStore_IterateServer interface { Send(*v1.Event) error Recv() (*v1.Event_IterateRequest, error) grpc.ServerStream }
type UnimplementedEventBusServer ¶
type UnimplementedEventBusServer struct { }
UnimplementedEventBusServer should be embedded to have forward compatible implementations.
func (UnimplementedEventBusServer) Close ¶
func (UnimplementedEventBusServer) Close(context.Context, *v1.Subscription_CloseRequest) (*v1.Subscription, error)
func (UnimplementedEventBusServer) Open ¶
func (UnimplementedEventBusServer) Open(context.Context, *v1.Subscription_OpenRequest) (*v1.Subscription, error)
type UnimplementedEventHandlerServer ¶
type UnimplementedEventHandlerServer struct { }
UnimplementedEventHandlerServer should be embedded to have forward compatible implementations.
func (UnimplementedEventHandlerServer) Handle ¶
func (UnimplementedEventHandlerServer) Handle(EventHandler_HandleServer) error
type UnimplementedEventStoreServer ¶
type UnimplementedEventStoreServer struct { }
UnimplementedEventStoreServer should be embedded to have forward compatible implementations.
func (UnimplementedEventStoreServer) Append ¶
func (UnimplementedEventStoreServer) Append(context.Context, *v1.Event_AppendRequest) (*emptypb.Empty, error)
func (UnimplementedEventStoreServer) GetLatest ¶
func (UnimplementedEventStoreServer) GetLatest(context.Context, *v1.Event_GetLatestRequest) (*v1.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.