actions

type ActionsServiceClient ¶

type ActionsServiceClient interface {
	ApplyAction(ctx context.Context, in *ApplyActionRequest, opts ...grpc.CallOption) (*ApplyActionResponse, error)
}

ActionsServiceClient is the client API for ActionsService 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 NewActionsServiceClient(cc grpc.ClientConnInterface) ActionsServiceClient

type ActionsServiceServer ¶

type ActionsServiceServer interface {
	ApplyAction(context.Context, *ApplyActionRequest) (*ApplyActionResponse, error)
	// contains filtered or unexported methods
}

ActionsServiceServer is the server API for ActionsService service. All implementations must embed UnimplementedActionsServiceServer for forward compatibility.

type ApplyActionRequest ¶

type ApplyActionRequest struct {
	// contains filtered or unexported fields
}

func (x *ApplyActionRequest) ClearItem()

func (x *ApplyActionRequest) GetItem() *anypb.Any

func (x *ApplyActionRequest) HasItem() bool

func (*ApplyActionRequest) ProtoMessage()

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

func (x *ApplyActionRequest) Reset()

func (x *ApplyActionRequest) SetItem(v *anypb.Any)

func (x *ApplyActionRequest) String() string

type ApplyActionRequest_builder ¶

type ApplyActionRequest_builder struct {
	Item *anypb.Any
	// contains filtered or unexported fields
}

func (b0 ApplyActionRequest_builder) Build() *ApplyActionRequest

type ApplyActionResponse ¶

type ApplyActionResponse struct {
	// contains filtered or unexported fields
}

func (x *ApplyActionResponse) ClearItem()

func (x *ApplyActionResponse) GetItem() *anypb.Any

func (x *ApplyActionResponse) HasItem() bool

func (*ApplyActionResponse) ProtoMessage()

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

func (x *ApplyActionResponse) Reset()

func (x *ApplyActionResponse) SetItem(v *anypb.Any)

func (x *ApplyActionResponse) String() string

type ApplyActionResponse_builder ¶

type ApplyActionResponse_builder struct {
	Item *anypb.Any
	// contains filtered or unexported fields
}

func (b0 ApplyActionResponse_builder) Build() *ApplyActionResponse

type Hub ¶

type Hub struct {
	Servers map[string]Server

	UnimplementedActionsServiceServer
}

Hub is the central registry for all actions. It forwards the ApplyAction request to the corresponding server based on the action type.

func NewHub() *Hub

func (h *Hub) ApplyAction(
	ctx context.Context,
	req *ApplyActionRequest,
) (*ApplyActionResponse, error)

func (h *Hub) MustRegister(newServer func() (Server, error), msg proto.Message)

type Server ¶

type Server interface {
	ApplyAction(context.Context, *ApplyActionRequest) (*ApplyActionResponse, error)
}

Server is ActionsServiceServer without UnimplementedActionsServiceServer

type UnimplementedActionsServiceServer ¶

type UnimplementedActionsServiceServer struct{}

UnimplementedActionsServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedActionsServiceServer) ApplyAction(context.Context, *ApplyActionRequest) (*ApplyActionResponse, error)

type UnsafeActionsServiceServer ¶

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

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