Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var File_capabilities_internal_nodeaction_v1_node_action_proto protoreflect.FileDescriptor
Functions ¶
func PerformAction ¶ added in v0.5.0
func PerformAction[C, T any]( config C, runtime cre.Runtime, client *BasicAction, fn func(config C, logger *slog.Logger, performActioner *PerformActioner) (T, error), ca cre.ConsensusAggregation[T]) cre.Promise[T]
PerformAction Allows usage of `PerformActioner` with Byzantine fault tolerance.
Types ¶
type BasicAction ¶
type BasicAction struct {
}
func (*BasicAction) PerformAction ¶
func (c *BasicAction) PerformAction(runtime cre.NodeRuntime, input *NodeInputs) cre.Promise[*NodeOutputs]
type NodeInputs ¶
type NodeInputs struct {
InputThing bool `protobuf:"varint,1,opt,name=input_thing,json=inputThing,proto3" json:"input_thing,omitempty"`
// contains filtered or unexported fields
}
func (*NodeInputs) Descriptor
deprecated
func (*NodeInputs) Descriptor() ([]byte, []int)
Deprecated: Use NodeInputs.ProtoReflect.Descriptor instead.
func (*NodeInputs) GetInputThing ¶
func (x *NodeInputs) GetInputThing() bool
func (*NodeInputs) ProtoMessage ¶
func (*NodeInputs) ProtoMessage()
func (*NodeInputs) ProtoReflect ¶
func (x *NodeInputs) ProtoReflect() protoreflect.Message
func (*NodeInputs) Reset ¶
func (x *NodeInputs) Reset()
func (*NodeInputs) String ¶
func (x *NodeInputs) String() string
type NodeOutputs ¶
type NodeOutputs struct {
OutputThing int32 `protobuf:"varint,1,opt,name=output_thing,json=outputThing,proto3" json:"output_thing,omitempty"`
// contains filtered or unexported fields
}
func (*NodeOutputs) Descriptor
deprecated
func (*NodeOutputs) Descriptor() ([]byte, []int)
Deprecated: Use NodeOutputs.ProtoReflect.Descriptor instead.
func (*NodeOutputs) GetOutputThing ¶
func (x *NodeOutputs) GetOutputThing() int32
func (*NodeOutputs) ProtoMessage ¶
func (*NodeOutputs) ProtoMessage()
func (*NodeOutputs) ProtoReflect ¶
func (x *NodeOutputs) ProtoReflect() protoreflect.Message
func (*NodeOutputs) Reset ¶
func (x *NodeOutputs) Reset()
func (*NodeOutputs) String ¶
func (x *NodeOutputs) String() string
type PerformActioner ¶ added in v0.5.0
type PerformActioner struct {
// contains filtered or unexported fields
}
func (*PerformActioner) PerformAction ¶ added in v0.5.0
func (c *PerformActioner) PerformAction(input *NodeInputs) cre.Promise[*NodeOutputs]
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.