Versions in this module Expand all Collapse all v0 v0.3.0 Jan 13, 2021 Changes in this version + var File_eventlogeventing_proto protoreflect.FileDescriptor + func RegisterEventLogSubscriberModelServer(s grpc.ServiceRegistrar, srv EventLogSubscriberModelServer) + func RegisterEventSourcedEntityOneServer(s grpc.ServiceRegistrar, srv EventSourcedEntityOneServer) + func RegisterEventSourcedEntityTwoServer(s grpc.ServiceRegistrar, srv EventSourcedEntityTwoServer) + type EffectRequest struct + Id string + Message string + func (*EffectRequest) Descriptor() ([]byte, []int) + func (*EffectRequest) ProtoMessage() + func (x *EffectRequest) GetId() string + func (x *EffectRequest) GetMessage() string + func (x *EffectRequest) ProtoReflect() protoreflect.Message + func (x *EffectRequest) Reset() + func (x *EffectRequest) String() string + type EmitEventRequest struct + Event isEmitEventRequest_Event + Id string + func (*EmitEventRequest) Descriptor() ([]byte, []int) + func (*EmitEventRequest) ProtoMessage() + func (m *EmitEventRequest) GetEvent() isEmitEventRequest_Event + func (x *EmitEventRequest) GetEventOne() *EventOne + func (x *EmitEventRequest) GetEventTwo() *EventTwo + func (x *EmitEventRequest) GetId() string + func (x *EmitEventRequest) ProtoReflect() protoreflect.Message + func (x *EmitEventRequest) Reset() + func (x *EmitEventRequest) String() string + type EmitEventRequest_EventOne struct + EventOne *EventOne + type EmitEventRequest_EventTwo struct + EventTwo *EventTwo + type EventLogSubscriberModel struct + func (e *EventLogSubscriberModel) HandleCommand(ctx *action.Context, name string, msg proto.Message) error + type EventLogSubscriberModelClient interface + Effect func(ctx context.Context, in *EffectRequest, opts ...grpc.CallOption) (*Response, error) + ProcessAnyEvent func(ctx context.Context, in *any.Any, opts ...grpc.CallOption) (*Response, error) + ProcessEventOne func(ctx context.Context, in *EventOne, opts ...grpc.CallOption) (*Response, error) + ProcessEventTwo func(ctx context.Context, in *EventTwo, opts ...grpc.CallOption) (EventLogSubscriberModel_ProcessEventTwoClient, error) + func NewEventLogSubscriberModelClient(cc grpc.ClientConnInterface) EventLogSubscriberModelClient + type EventLogSubscriberModelServer interface + Effect func(context.Context, *EffectRequest) (*Response, error) + ProcessAnyEvent func(context.Context, *any.Any) (*Response, error) + ProcessEventOne func(context.Context, *EventOne) (*Response, error) + ProcessEventTwo func(*EventTwo, EventLogSubscriberModel_ProcessEventTwoServer) error + type EventLogSubscriberModel_ProcessEventTwoClient interface + Recv func() (*Response, error) + type EventLogSubscriberModel_ProcessEventTwoServer interface + Send func(*Response) error + type EventOne struct + Step *ProcessStep + func (*EventOne) Descriptor() ([]byte, []int) + func (*EventOne) ProtoMessage() + func (x *EventOne) GetStep() *ProcessStep + func (x *EventOne) ProtoReflect() protoreflect.Message + func (x *EventOne) Reset() + func (x *EventOne) String() string + type EventSourcedEntityOne struct + func (EventSourcedEntityOne) HandleCommand(ctx *eventsourced.Context, name string, cmd proto.Message) (reply proto.Message, err error) + func (EventSourcedEntityOne) HandleEvent(ctx *eventsourced.Context, event interface{}) error + type EventSourcedEntityOneClient interface + EmitEvent func(ctx context.Context, in *EmitEventRequest, opts ...grpc.CallOption) (*empty.Empty, error) + func NewEventSourcedEntityOneClient(cc grpc.ClientConnInterface) EventSourcedEntityOneClient + type EventSourcedEntityOneServer interface + EmitEvent func(context.Context, *EmitEventRequest) (*empty.Empty, error) + type EventSourcedEntityTwo struct + func (EventSourcedEntityTwo) HandleCommand(ctx *eventsourced.Context, name string, cmd proto.Message) (reply proto.Message, err error) + func (EventSourcedEntityTwo) HandleEvent(ctx *eventsourced.Context, event interface{}) error + type EventSourcedEntityTwoClient interface + EmitJsonEvent func(ctx context.Context, in *JsonEvent, opts ...grpc.CallOption) (*empty.Empty, error) + func NewEventSourcedEntityTwoClient(cc grpc.ClientConnInterface) EventSourcedEntityTwoClient + type EventSourcedEntityTwoServer interface + EmitJsonEvent func(context.Context, *JsonEvent) (*empty.Empty, error) + type EventTwo struct + Step []*ProcessStep + func (*EventTwo) Descriptor() ([]byte, []int) + func (*EventTwo) ProtoMessage() + func (x *EventTwo) GetStep() []*ProcessStep + func (x *EventTwo) ProtoReflect() protoreflect.Message + func (x *EventTwo) Reset() + func (x *EventTwo) String() string + type Forward struct + Message string + func (*Forward) Descriptor() ([]byte, []int) + func (*Forward) ProtoMessage() + func (x *Forward) GetMessage() string + func (x *Forward) ProtoReflect() protoreflect.Message + func (x *Forward) Reset() + func (x *Forward) String() string + type JsonEvent struct + Id string + Message string + func (*JsonEvent) Descriptor() ([]byte, []int) + func (*JsonEvent) ProtoMessage() + func (x *JsonEvent) GetId() string + func (x *JsonEvent) GetMessage() string + func (x *JsonEvent) ProtoReflect() protoreflect.Message + func (x *JsonEvent) Reset() + func (x *JsonEvent) String() string + type JsonMessage struct + Message string + type ProcessStep struct + Step isProcessStep_Step + func (*ProcessStep) Descriptor() ([]byte, []int) + func (*ProcessStep) ProtoMessage() + func (m *ProcessStep) GetStep() isProcessStep_Step + func (x *ProcessStep) GetForward() *Forward + func (x *ProcessStep) GetReply() *Reply + func (x *ProcessStep) ProtoReflect() protoreflect.Message + func (x *ProcessStep) Reset() + func (x *ProcessStep) String() string + type ProcessStep_Forward struct + Forward *Forward + type ProcessStep_Reply struct + Reply *Reply + type Reply struct + Message string + func (*Reply) Descriptor() ([]byte, []int) + func (*Reply) ProtoMessage() + func (x *Reply) GetMessage() string + func (x *Reply) ProtoReflect() protoreflect.Message + func (x *Reply) Reset() + func (x *Reply) String() string + type Response struct + Id string + Message string + func (*Response) Descriptor() ([]byte, []int) + func (*Response) ProtoMessage() + func (x *Response) GetId() string + func (x *Response) GetMessage() string + func (x *Response) ProtoReflect() protoreflect.Message + func (x *Response) Reset() + func (x *Response) String() string + type UnimplementedEventLogSubscriberModelServer struct + func (UnimplementedEventLogSubscriberModelServer) Effect(context.Context, *EffectRequest) (*Response, error) + func (UnimplementedEventLogSubscriberModelServer) ProcessAnyEvent(context.Context, *any.Any) (*Response, error) + func (UnimplementedEventLogSubscriberModelServer) ProcessEventOne(context.Context, *EventOne) (*Response, error) + func (UnimplementedEventLogSubscriberModelServer) ProcessEventTwo(*EventTwo, EventLogSubscriberModel_ProcessEventTwoServer) error + type UnimplementedEventSourcedEntityOneServer struct + func (UnimplementedEventSourcedEntityOneServer) EmitEvent(context.Context, *EmitEventRequest) (*empty.Empty, error) + type UnimplementedEventSourcedEntityTwoServer struct + func (UnimplementedEventSourcedEntityTwoServer) EmitJsonEvent(context.Context, *JsonEvent) (*empty.Empty, error) + type UnsafeEventLogSubscriberModelServer interface + type UnsafeEventSourcedEntityOneServer interface + type UnsafeEventSourcedEntityTwoServer interface
Go to main page