hsmtest

package

v1.26.2 Latest Latest Go to latest Published: Dec 23, 2024 License: MIT Imports: 12 Imported by: 0

Details

View Source

const TaskType = "test-task-type-name"

This section is empty.

This section is empty.

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

func NewData(
	state State,
) *Data

func (d *Data) RegenerateTasks(node *hsm.Node) ([]hsm.Task, error)

func (d *Data) SetState(s State)

func (d *Data) State() State

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

func NewDefinition(typeName string) Definition

func (d Definition) CompareState(s1 any, s2 any) (int, error)

func (d Definition) Deserialize(b []byte) (any, error)

func (d Definition) Serialize(s any) ([]byte, error)

Serialize implements hsm.StateMachineDefinition.

func (d Definition) Type() string

Type implements hsm.StateMachineDefinition.

type NodeBackend struct {
	Events []*historypb.HistoryEvent
}

func (n *NodeBackend) AddHistoryEvent(t enumspb.EventType, setAttributes func(*historypb.HistoryEvent)) *historypb.HistoryEvent

func (n *NodeBackend) GenerateEventLoadToken(event *historypb.HistoryEvent) ([]byte, error)

func (n *NodeBackend) GetCurrentVersion() int64

func (n *NodeBackend) LoadHistoryEvent(ctx context.Context, tokenBytes []byte) (*historypb.HistoryEvent, error)

func (n *NodeBackend) NextTransitionCount() int64

type State string

const (
	State1 State = "state1"
	State2 State = "state2"
	State3 State = "state3"
	State4 State = "state4"
)

type Task struct {
	IsConcurrent bool
	// contains filtered or unexported fields
}

func NewTask(
	attrs hsm.TaskAttributes,
	concurrent bool,
) *Task

func (t *Task) Deadline() time.Time

func (t *Task) Destination() string

func (t *Task) Type() string

func (t *Task) Validate(ref *persistencespb.StateMachineRef, node *hsm.Node) error

type TaskSerializer struct{}

func (s TaskSerializer) Deserialize(b []byte, attrs hsm.TaskAttributes) (hsm.Task, error)

func (s TaskSerializer) Serialize(t hsm.Task) ([]byte, error)