model

package module
v0.0.0-...-9972e98 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 7, 2023 License: Apache-2.0 Imports: 9 Imported by: 4

Documentation

Index

Constants

View Source 
const (
	LHPublicApi_PutTaskDef_FullMethodName             = "/littlehorse.LHPublicApi/PutTaskDef"
	LHPublicApi_GetTaskDef_FullMethodName             = "/littlehorse.LHPublicApi/GetTaskDef"
	LHPublicApi_PutExternalEventDef_FullMethodName    = "/littlehorse.LHPublicApi/PutExternalEventDef"
	LHPublicApi_GetExternalEventDef_FullMethodName    = "/littlehorse.LHPublicApi/GetExternalEventDef"
	LHPublicApi_PutWfSpec_FullMethodName              = "/littlehorse.LHPublicApi/PutWfSpec"
	LHPublicApi_GetWfSpec_FullMethodName              = "/littlehorse.LHPublicApi/GetWfSpec"
	LHPublicApi_GetLatestWfSpec_FullMethodName        = "/littlehorse.LHPublicApi/GetLatestWfSpec"
	LHPublicApi_RunWf_FullMethodName                  = "/littlehorse.LHPublicApi/RunWf"
	LHPublicApi_GetWfRun_FullMethodName               = "/littlehorse.LHPublicApi/GetWfRun"
	LHPublicApi_GetNodeRun_FullMethodName             = "/littlehorse.LHPublicApi/GetNodeRun"
	LHPublicApi_ListNodeRuns_FullMethodName           = "/littlehorse.LHPublicApi/ListNodeRuns"
	LHPublicApi_GetVariable_FullMethodName            = "/littlehorse.LHPublicApi/GetVariable"
	LHPublicApi_ListVariables_FullMethodName          = "/littlehorse.LHPublicApi/ListVariables"
	LHPublicApi_PutExternalEvent_FullMethodName       = "/littlehorse.LHPublicApi/PutExternalEvent"
	LHPublicApi_GetExternalEvent_FullMethodName       = "/littlehorse.LHPublicApi/GetExternalEvent"
	LHPublicApi_ListExternalEvents_FullMethodName     = "/littlehorse.LHPublicApi/ListExternalEvents"
	LHPublicApi_SearchWfRun_FullMethodName            = "/littlehorse.LHPublicApi/SearchWfRun"
	LHPublicApi_SearchNodeRun_FullMethodName          = "/littlehorse.LHPublicApi/SearchNodeRun"
	LHPublicApi_SearchVariable_FullMethodName         = "/littlehorse.LHPublicApi/SearchVariable"
	LHPublicApi_SearchTaskDef_FullMethodName          = "/littlehorse.LHPublicApi/SearchTaskDef"
	LHPublicApi_SearchWfSpec_FullMethodName           = "/littlehorse.LHPublicApi/SearchWfSpec"
	LHPublicApi_SearchExternalEventDef_FullMethodName = "/littlehorse.LHPublicApi/SearchExternalEventDef"
	LHPublicApi_SearchExternalEvent_FullMethodName    = "/littlehorse.LHPublicApi/SearchExternalEvent"
	LHPublicApi_RegisterTaskWorker_FullMethodName     = "/littlehorse.LHPublicApi/RegisterTaskWorker"
	LHPublicApi_PollTask_FullMethodName               = "/littlehorse.LHPublicApi/PollTask"
	LHPublicApi_ReportTask_FullMethodName             = "/littlehorse.LHPublicApi/ReportTask"
	LHPublicApi_StopWfRun_FullMethodName              = "/littlehorse.LHPublicApi/StopWfRun"
	LHPublicApi_ResumeWfRun_FullMethodName            = "/littlehorse.LHPublicApi/ResumeWfRun"
	LHPublicApi_DeleteWfRun_FullMethodName            = "/littlehorse.LHPublicApi/DeleteWfRun"
	LHPublicApi_DeleteTaskDef_FullMethodName          = "/littlehorse.LHPublicApi/DeleteTaskDef"
	LHPublicApi_DeleteWfSpec_FullMethodName           = "/littlehorse.LHPublicApi/DeleteWfSpec"
	LHPublicApi_DeleteExternalEventDef_FullMethodName = "/littlehorse.LHPublicApi/DeleteExternalEventDef"
	LHPublicApi_HealthCheck_FullMethodName            = "/littlehorse.LHPublicApi/HealthCheck"
	LHPublicApi_TaskDefMetrics_FullMethodName         = "/littlehorse.LHPublicApi/TaskDefMetrics"
	LHPublicApi_WfSpecMetrics_FullMethodName          = "/littlehorse.LHPublicApi/WfSpecMetrics"
	LHPublicApi_ListTaskDefMetrics_FullMethodName     = "/littlehorse.LHPublicApi/ListTaskDefMetrics"
	LHPublicApi_ListWfSpecMetrics_FullMethodName      = "/littlehorse.LHPublicApi/ListWfSpecMetrics"
)

Variables

View Source 
var (
	LHResponseCodePb_name = map[int32]string{
		0: "OK",
		1: "CONNECTION_ERROR",
		2: "NOT_FOUND_ERROR",
		3: "BAD_REQUEST_ERROR",
		4: "VALIDATION_ERROR",
		5: "ALREADY_EXISTS_ERROR",
		6: "REPORTED_BUT_NOT_PROCESSED",
	}
	LHResponseCodePb_value = map[string]int32{
		"OK":                         0,
		"CONNECTION_ERROR":           1,
		"NOT_FOUND_ERROR":            2,
		"BAD_REQUEST_ERROR":          3,
		"VALIDATION_ERROR":           4,
		"ALREADY_EXISTS_ERROR":       5,
		"REPORTED_BUT_NOT_PROCESSED": 6,
	}
)

Enum value maps for LHResponseCodePb.

View Source 
var (
	LHStatusPb_name = map[int32]string{
		0: "STARTING",
		1: "RUNNING",
		2: "COMPLETED",
		3: "HALTING",
		4: "HALTED",
		5: "ERROR",
	}
	LHStatusPb_value = map[string]int32{
		"STARTING":  0,
		"RUNNING":   1,
		"COMPLETED": 2,
		"HALTING":   3,
		"HALTED":    4,
		"ERROR":     5,
	}
)

Enum value maps for LHStatusPb.

View Source 
var (
	TaskResultCodePb_name = map[int32]string{
		0: "SUCCESS",
		1: "TIMEOUT",
		2: "FAILED",
		3: "VAR_SUB_ERROR",
		4: "VAR_MUTATION_ERROR",
		5: "CHILD_FALIED",
		6: "INTERRUPT_HANDLER_FAILED",
		7: "EXCEPTION_HANDLER_FAILED",
		8: "INTERNAL_ERROR",
	}
	TaskResultCodePb_value = map[string]int32{
		"SUCCESS":                  0,
		"TIMEOUT":                  1,
		"FAILED":                   2,
		"VAR_SUB_ERROR":            3,
		"VAR_MUTATION_ERROR":       4,
		"CHILD_FALIED":             5,
		"INTERRUPT_HANDLER_FAILED": 6,
		"EXCEPTION_HANDLER_FAILED": 7,
		"INTERNAL_ERROR":           8,
	}
)

Enum value maps for TaskResultCodePb.

View Source 
var (
	LHHealthResultPb_name = map[int32]string{
		0: "LH_HEALTH_RUNNING",
		1: "LH_HEALTH_REBALANCING",
		2: "LH_HEALTH_ERROR",
	}
	LHHealthResultPb_value = map[string]int32{
		"LH_HEALTH_RUNNING":     0,
		"LH_HEALTH_REBALANCING": 1,
		"LH_HEALTH_ERROR":       2,
	}
)

Enum value maps for LHHealthResultPb.

View Source 
var (
	VariableTypePb_name = map[int32]string{
		0: "JSON_OBJ",
		1: "JSON_ARR",
		2: "DOUBLE",
		3: "BOOL",
		4: "STR",
		5: "INT",
		6: "BYTES",
		7: "NULL",
	}
	VariableTypePb_value = map[string]int32{
		"JSON_OBJ": 0,
		"JSON_ARR": 1,
		"DOUBLE":   2,
		"BOOL":     3,
		"STR":      4,
		"INT":      5,
		"BYTES":    6,
		"NULL":     7,
	}
)

Enum value maps for VariableTypePb.

View Source 
var (
	ThreadTypePb_name = map[int32]string{
		0: "ENTRYPOINT",
		1: "CHILD",
		2: "INTERRUPT",
		3: "FAILURE_HANDLER",
	}
	ThreadTypePb_value = map[string]int32{
		"ENTRYPOINT":      0,
		"CHILD":           1,
		"INTERRUPT":       2,
		"FAILURE_HANDLER": 3,
	}
)

Enum value maps for ThreadTypePb.

View Source 
var (
	ComparatorPb_name = map[int32]string{
		0: "LESS_THAN",
		1: "GREATER_THAN",
		2: "LESS_THAN_EQ",
		3: "GREATER_THAN_EQ",
		4: "EQUALS",
		5: "NOT_EQUALS",
		6: "IN",
		7: "NOT_IN",
	}
	ComparatorPb_value = map[string]int32{
		"LESS_THAN":       0,
		"GREATER_THAN":    1,
		"LESS_THAN_EQ":    2,
		"GREATER_THAN_EQ": 3,
		"EQUALS":          4,
		"NOT_EQUALS":      5,
		"IN":              6,
		"NOT_IN":          7,
	}
)

Enum value maps for ComparatorPb.

View Source 
var (
	VariableMutationTypePb_name = map[int32]string{
		0: "ASSIGN",
		1: "ADD",
		2: "EXTEND",
		3: "SUBTRACT",
		4: "MULTIPLY",
		5: "DIVIDE",
		6: "REMOVE_IF_PRESENT",
		7: "REMOVE_INDEX",
		8: "REMOVE_KEY",
	}
	VariableMutationTypePb_value = map[string]int32{
		"ASSIGN":            0,
		"ADD":               1,
		"EXTEND":            2,
		"SUBTRACT":          3,
		"MULTIPLY":          4,
		"DIVIDE":            5,
		"REMOVE_IF_PRESENT": 6,
		"REMOVE_INDEX":      7,
		"REMOVE_KEY":        8,
	}
)

Enum value maps for VariableMutationTypePb.

View Source 
var (
	MetricsWindowLengthPb_name = map[int32]string{
		0: "MINUTES_5",
		1: "HOURS_2",
		2: "DAYS_1",
	}
	MetricsWindowLengthPb_value = map[string]int32{
		"MINUTES_5": 0,
		"HOURS_2":   1,
		"DAYS_1":    2,
	}
)

Enum value maps for MetricsWindowLengthPb.

View Source 
var File_service_proto protoreflect.FileDescriptor
View Source 
var LHPublicApi_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "littlehorse.LHPublicApi",
	HandlerType: (*LHPublicApiServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PutTaskDef",
			Handler:    _LHPublicApi_PutTaskDef_Handler,
		},
		{
			MethodName: "GetTaskDef",
			Handler:    _LHPublicApi_GetTaskDef_Handler,
		},
		{
			MethodName: "PutExternalEventDef",
			Handler:    _LHPublicApi_PutExternalEventDef_Handler,
		},
		{
			MethodName: "GetExternalEventDef",
			Handler:    _LHPublicApi_GetExternalEventDef_Handler,
		},
		{
			MethodName: "PutWfSpec",
			Handler:    _LHPublicApi_PutWfSpec_Handler,
		},
		{
			MethodName: "GetWfSpec",
			Handler:    _LHPublicApi_GetWfSpec_Handler,
		},
		{
			MethodName: "GetLatestWfSpec",
			Handler:    _LHPublicApi_GetLatestWfSpec_Handler,
		},
		{
			MethodName: "RunWf",
			Handler:    _LHPublicApi_RunWf_Handler,
		},
		{
			MethodName: "GetWfRun",
			Handler:    _LHPublicApi_GetWfRun_Handler,
		},
		{
			MethodName: "GetNodeRun",
			Handler:    _LHPublicApi_GetNodeRun_Handler,
		},
		{
			MethodName: "ListNodeRuns",
			Handler:    _LHPublicApi_ListNodeRuns_Handler,
		},
		{
			MethodName: "GetVariable",
			Handler:    _LHPublicApi_GetVariable_Handler,
		},
		{
			MethodName: "ListVariables",
			Handler:    _LHPublicApi_ListVariables_Handler,
		},
		{
			MethodName: "PutExternalEvent",
			Handler:    _LHPublicApi_PutExternalEvent_Handler,
		},
		{
			MethodName: "GetExternalEvent",
			Handler:    _LHPublicApi_GetExternalEvent_Handler,
		},
		{
			MethodName: "ListExternalEvents",
			Handler:    _LHPublicApi_ListExternalEvents_Handler,
		},
		{
			MethodName: "SearchWfRun",
			Handler:    _LHPublicApi_SearchWfRun_Handler,
		},
		{
			MethodName: "SearchNodeRun",
			Handler:    _LHPublicApi_SearchNodeRun_Handler,
		},
		{
			MethodName: "SearchVariable",
			Handler:    _LHPublicApi_SearchVariable_Handler,
		},
		{
			MethodName: "SearchTaskDef",
			Handler:    _LHPublicApi_SearchTaskDef_Handler,
		},
		{
			MethodName: "SearchWfSpec",
			Handler:    _LHPublicApi_SearchWfSpec_Handler,
		},
		{
			MethodName: "SearchExternalEventDef",
			Handler:    _LHPublicApi_SearchExternalEventDef_Handler,
		},
		{
			MethodName: "SearchExternalEvent",
			Handler:    _LHPublicApi_SearchExternalEvent_Handler,
		},
		{
			MethodName: "RegisterTaskWorker",
			Handler:    _LHPublicApi_RegisterTaskWorker_Handler,
		},
		{
			MethodName: "ReportTask",
			Handler:    _LHPublicApi_ReportTask_Handler,
		},
		{
			MethodName: "StopWfRun",
			Handler:    _LHPublicApi_StopWfRun_Handler,
		},
		{
			MethodName: "ResumeWfRun",
			Handler:    _LHPublicApi_ResumeWfRun_Handler,
		},
		{
			MethodName: "DeleteWfRun",
			Handler:    _LHPublicApi_DeleteWfRun_Handler,
		},
		{
			MethodName: "DeleteTaskDef",
			Handler:    _LHPublicApi_DeleteTaskDef_Handler,
		},
		{
			MethodName: "DeleteWfSpec",
			Handler:    _LHPublicApi_DeleteWfSpec_Handler,
		},
		{
			MethodName: "DeleteExternalEventDef",
			Handler:    _LHPublicApi_DeleteExternalEventDef_Handler,
		},
		{
			MethodName: "HealthCheck",
			Handler:    _LHPublicApi_HealthCheck_Handler,
		},
		{
			MethodName: "TaskDefMetrics",
			Handler:    _LHPublicApi_TaskDefMetrics_Handler,
		},
		{
			MethodName: "WfSpecMetrics",
			Handler:    _LHPublicApi_WfSpecMetrics_Handler,
		},
		{
			MethodName: "ListTaskDefMetrics",
			Handler:    _LHPublicApi_ListTaskDefMetrics_Handler,
		},
		{
			MethodName: "ListWfSpecMetrics",
			Handler:    _LHPublicApi_ListWfSpecMetrics_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "PollTask",
			Handler:       _LHPublicApi_PollTask_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "service.proto",
}

LHPublicApi_ServiceDesc is the grpc.ServiceDesc for LHPublicApi service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterLHPublicApiServer 

func RegisterLHPublicApiServer(s grpc.ServiceRegistrar, srv LHPublicApiServer)

Types

type ComparatorPb 

type ComparatorPb int32
const (
	ComparatorPb_LESS_THAN       ComparatorPb = 0
	ComparatorPb_GREATER_THAN    ComparatorPb = 1
	ComparatorPb_LESS_THAN_EQ    ComparatorPb = 2
	ComparatorPb_GREATER_THAN_EQ ComparatorPb = 3
	ComparatorPb_EQUALS          ComparatorPb = 4
	ComparatorPb_NOT_EQUALS      ComparatorPb = 5
	ComparatorPb_IN              ComparatorPb = 6
	ComparatorPb_NOT_IN          ComparatorPb = 7
)

func (ComparatorPb) Descriptor 

func (ComparatorPb) Descriptor() protoreflect.EnumDescriptor

func (ComparatorPb) Enum 

func (x ComparatorPb) Enum() *ComparatorPb

func (ComparatorPb) EnumDescriptor deprecated 

func (ComparatorPb) EnumDescriptor() ([]byte, []int)

Deprecated: Use ComparatorPb.Descriptor instead.

func (ComparatorPb) Number 

func (x ComparatorPb) Number() protoreflect.EnumNumber

func (ComparatorPb) String 

func (x ComparatorPb) String() string

func (ComparatorPb) Type 

func (ComparatorPb) Type() protoreflect.EnumType

type DeleteExternalEventDefPb 

type DeleteExternalEventDefPb struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteExternalEventDefPb) Descriptor deprecated 

func (*DeleteExternalEventDefPb) Descriptor() ([]byte, []int)

Deprecated: Use DeleteExternalEventDefPb.ProtoReflect.Descriptor instead.

func (*DeleteExternalEventDefPb) GetName 

func (x *DeleteExternalEventDefPb) GetName() string

func (*DeleteExternalEventDefPb) ProtoMessage 

func (*DeleteExternalEventDefPb) ProtoMessage()

func (*DeleteExternalEventDefPb) ProtoReflect 

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

func (*DeleteExternalEventDefPb) Reset 

func (x *DeleteExternalEventDefPb) Reset()

func (*DeleteExternalEventDefPb) String 

func (x *DeleteExternalEventDefPb) String() string

type DeleteObjectReplyPb 

type DeleteObjectReplyPb struct {
	Code    LHResponseCodePb `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message *string          `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteObjectReplyPb) Descriptor deprecated 

func (*DeleteObjectReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use DeleteObjectReplyPb.ProtoReflect.Descriptor instead.

func (*DeleteObjectReplyPb) GetCode 

func (x *DeleteObjectReplyPb) GetCode() LHResponseCodePb

func (*DeleteObjectReplyPb) GetMessage 

func (x *DeleteObjectReplyPb) GetMessage() string

func (*DeleteObjectReplyPb) ProtoMessage 

func (*DeleteObjectReplyPb) ProtoMessage()

func (*DeleteObjectReplyPb) ProtoReflect 

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

func (*DeleteObjectReplyPb) Reset 

func (x *DeleteObjectReplyPb) Reset()

func (*DeleteObjectReplyPb) String 

func (x *DeleteObjectReplyPb) String() string

type DeleteTaskDefPb 

type DeleteTaskDefPb struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTaskDefPb) Descriptor deprecated 

func (*DeleteTaskDefPb) Descriptor() ([]byte, []int)

Deprecated: Use DeleteTaskDefPb.ProtoReflect.Descriptor instead.

func (*DeleteTaskDefPb) GetName 

func (x *DeleteTaskDefPb) GetName() string

func (*DeleteTaskDefPb) ProtoMessage 

func (*DeleteTaskDefPb) ProtoMessage()

func (*DeleteTaskDefPb) ProtoReflect 

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

func (*DeleteTaskDefPb) Reset 

func (x *DeleteTaskDefPb) Reset()

func (*DeleteTaskDefPb) String 

func (x *DeleteTaskDefPb) String() string

type DeleteWfRunPb 

type DeleteWfRunPb struct {
	WfRunId string `protobuf:"bytes,1,opt,name=wf_run_id,json=wfRunId,proto3" json:"wf_run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteWfRunPb) Descriptor deprecated 

func (*DeleteWfRunPb) Descriptor() ([]byte, []int)

Deprecated: Use DeleteWfRunPb.ProtoReflect.Descriptor instead.

func (*DeleteWfRunPb) GetWfRunId 

func (x *DeleteWfRunPb) GetWfRunId() string

func (*DeleteWfRunPb) ProtoMessage 

func (*DeleteWfRunPb) ProtoMessage()

func (*DeleteWfRunPb) ProtoReflect 

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

func (*DeleteWfRunPb) Reset 

func (x *DeleteWfRunPb) Reset()

func (*DeleteWfRunPb) String 

func (x *DeleteWfRunPb) String() string

type DeleteWfSpecPb 

type DeleteWfSpecPb struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version int32  `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteWfSpecPb) Descriptor deprecated 

func (*DeleteWfSpecPb) Descriptor() ([]byte, []int)

Deprecated: Use DeleteWfSpecPb.ProtoReflect.Descriptor instead.

func (*DeleteWfSpecPb) GetName 

func (x *DeleteWfSpecPb) GetName() string

func (*DeleteWfSpecPb) GetVersion 

func (x *DeleteWfSpecPb) GetVersion() int32

func (*DeleteWfSpecPb) ProtoMessage 

func (*DeleteWfSpecPb) ProtoMessage()

func (*DeleteWfSpecPb) ProtoReflect 

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

func (*DeleteWfSpecPb) Reset 

func (x *DeleteWfSpecPb) Reset()

func (*DeleteWfSpecPb) String 

func (x *DeleteWfSpecPb) String() string

type EdgeConditionPb 

type EdgeConditionPb struct {
	Comparator ComparatorPb          `protobuf:"varint,1,opt,name=comparator,proto3,enum=littlehorse.ComparatorPb" json:"comparator,omitempty"`
	Left       *VariableAssignmentPb `protobuf:"bytes,2,opt,name=left,proto3" json:"left,omitempty"`
	Right      *VariableAssignmentPb `protobuf:"bytes,3,opt,name=right,proto3" json:"right,omitempty"`
	// contains filtered or unexported fields
}

func (*EdgeConditionPb) Descriptor deprecated 

func (*EdgeConditionPb) Descriptor() ([]byte, []int)

Deprecated: Use EdgeConditionPb.ProtoReflect.Descriptor instead.

func (*EdgeConditionPb) GetComparator 

func (x *EdgeConditionPb) GetComparator() ComparatorPb

func (*EdgeConditionPb) GetLeft 

func (x *EdgeConditionPb) GetLeft() *VariableAssignmentPb

func (*EdgeConditionPb) GetRight 

func (x *EdgeConditionPb) GetRight() *VariableAssignmentPb

func (*EdgeConditionPb) ProtoMessage 

func (*EdgeConditionPb) ProtoMessage()

func (*EdgeConditionPb) ProtoReflect 

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

func (*EdgeConditionPb) Reset 

func (x *EdgeConditionPb) Reset()

func (*EdgeConditionPb) String 

func (x *EdgeConditionPb) String() string

type EdgePb 

type EdgePb struct {
	SinkNodeName string           `protobuf:"bytes,1,opt,name=sink_node_name,json=sinkNodeName,proto3" json:"sink_node_name,omitempty"`
	Condition    *EdgeConditionPb `protobuf:"bytes,2,opt,name=condition,proto3,oneof" json:"condition,omitempty"`
	// contains filtered or unexported fields
}

func (*EdgePb) Descriptor deprecated 

func (*EdgePb) Descriptor() ([]byte, []int)

Deprecated: Use EdgePb.ProtoReflect.Descriptor instead.

func (*EdgePb) GetCondition 

func (x *EdgePb) GetCondition() *EdgeConditionPb

func (*EdgePb) GetSinkNodeName 

func (x *EdgePb) GetSinkNodeName() string

func (*EdgePb) ProtoMessage 

func (*EdgePb) ProtoMessage()

func (*EdgePb) ProtoReflect 

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

func (*EdgePb) Reset 

func (x *EdgePb) Reset()

func (*EdgePb) String 

func (x *EdgePb) String() string

type EntrypointNodePb 

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

func (*EntrypointNodePb) Descriptor deprecated 

func (*EntrypointNodePb) Descriptor() ([]byte, []int)

Deprecated: Use EntrypointNodePb.ProtoReflect.Descriptor instead.

func (*EntrypointNodePb) ProtoMessage 

func (*EntrypointNodePb) ProtoMessage()

func (*EntrypointNodePb) ProtoReflect 

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

func (*EntrypointNodePb) Reset 

func (x *EntrypointNodePb) Reset()

func (*EntrypointNodePb) String 

func (x *EntrypointNodePb) String() string

type EntrypointRunPb 

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

func (*EntrypointRunPb) Descriptor deprecated 

func (*EntrypointRunPb) Descriptor() ([]byte, []int)

Deprecated: Use EntrypointRunPb.ProtoReflect.Descriptor instead.

func (*EntrypointRunPb) ProtoMessage 

func (*EntrypointRunPb) ProtoMessage()

func (*EntrypointRunPb) ProtoReflect 

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

func (*EntrypointRunPb) Reset 

func (x *EntrypointRunPb) Reset()

func (*EntrypointRunPb) String 

func (x *EntrypointRunPb) String() string

type ExitNodePb 

type ExitNodePb struct {
	FailureDef *FailureDefPb `protobuf:"bytes,1,opt,name=failure_def,json=failureDef,proto3,oneof" json:"failure_def,omitempty"`
	// contains filtered or unexported fields
}

func (*ExitNodePb) Descriptor deprecated 

func (*ExitNodePb) Descriptor() ([]byte, []int)

Deprecated: Use ExitNodePb.ProtoReflect.Descriptor instead.

func (*ExitNodePb) GetFailureDef 

func (x *ExitNodePb) GetFailureDef() *FailureDefPb

func (*ExitNodePb) ProtoMessage 

func (*ExitNodePb) ProtoMessage()

func (*ExitNodePb) ProtoReflect 

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

func (*ExitNodePb) Reset 

func (x *ExitNodePb) Reset()

func (*ExitNodePb) String 

func (x *ExitNodePb) String() string

type ExitRunPb 

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

func (*ExitRunPb) Descriptor deprecated 

func (*ExitRunPb) Descriptor() ([]byte, []int)

Deprecated: Use ExitRunPb.ProtoReflect.Descriptor instead.

func (*ExitRunPb) ProtoMessage 

func (*ExitRunPb) ProtoMessage()

func (*ExitRunPb) ProtoReflect 

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

func (*ExitRunPb) Reset 

func (x *ExitRunPb) Reset()

func (*ExitRunPb) String 

func (x *ExitRunPb) String() string

type ExtEvtMatchedOePb 

type ExtEvtMatchedOePb struct {
	ThreadRunNumber int32  `protobuf:"varint,1,opt,name=thread_run_number,json=threadRunNumber,proto3" json:"thread_run_number,omitempty"`
	NodeRunPosition int32  `protobuf:"varint,2,opt,name=node_run_position,json=nodeRunPosition,proto3" json:"node_run_position,omitempty"`
	ExtEvtDefName   string `protobuf:"bytes,3,opt,name=ext_evt_def_name,json=extEvtDefName,proto3" json:"ext_evt_def_name,omitempty"`
	ExtEvtGuid      string `protobuf:"bytes,4,opt,name=ext_evt_guid,json=extEvtGuid,proto3" json:"ext_evt_guid,omitempty"`
	// contains filtered or unexported fields
}

func (*ExtEvtMatchedOePb) Descriptor deprecated 

func (*ExtEvtMatchedOePb) Descriptor() ([]byte, []int)

Deprecated: Use ExtEvtMatchedOePb.ProtoReflect.Descriptor instead.

func (*ExtEvtMatchedOePb) GetExtEvtDefName 

func (x *ExtEvtMatchedOePb) GetExtEvtDefName() string

func (*ExtEvtMatchedOePb) GetExtEvtGuid 

func (x *ExtEvtMatchedOePb) GetExtEvtGuid() string

func (*ExtEvtMatchedOePb) GetNodeRunPosition 

func (x *ExtEvtMatchedOePb) GetNodeRunPosition() int32

func (*ExtEvtMatchedOePb) GetThreadRunNumber 

func (x *ExtEvtMatchedOePb) GetThreadRunNumber() int32

func (*ExtEvtMatchedOePb) ProtoMessage 

func (*ExtEvtMatchedOePb) ProtoMessage()

func (*ExtEvtMatchedOePb) ProtoReflect 

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

func (*ExtEvtMatchedOePb) Reset 

func (x *ExtEvtMatchedOePb) Reset()

func (*ExtEvtMatchedOePb) String 

func (x *ExtEvtMatchedOePb) String() string

type ExtEvtRegisteredOePb 

type ExtEvtRegisteredOePb struct {
	ExtEvtDefName   string           `protobuf:"bytes,1,opt,name=ext_evt_def_name,json=extEvtDefName,proto3" json:"ext_evt_def_name,omitempty"`
	Guid            string           `protobuf:"bytes,2,opt,name=guid,proto3" json:"guid,omitempty"`
	Content         *VariableValuePb `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	ThreadRunNumber *int32           `protobuf:"varint,4,opt,name=thread_run_number,json=threadRunNumber,proto3,oneof" json:"thread_run_number,omitempty"`
	NodeRunPosition *int32           `protobuf:"varint,5,opt,name=node_run_position,json=nodeRunPosition,proto3,oneof" json:"node_run_position,omitempty"`
	// contains filtered or unexported fields
}

func (*ExtEvtRegisteredOePb) Descriptor deprecated 

func (*ExtEvtRegisteredOePb) Descriptor() ([]byte, []int)

Deprecated: Use ExtEvtRegisteredOePb.ProtoReflect.Descriptor instead.

func (*ExtEvtRegisteredOePb) GetContent 

func (x *ExtEvtRegisteredOePb) GetContent() *VariableValuePb

func (*ExtEvtRegisteredOePb) GetExtEvtDefName 

func (x *ExtEvtRegisteredOePb) GetExtEvtDefName() string

func (*ExtEvtRegisteredOePb) GetGuid 

func (x *ExtEvtRegisteredOePb) GetGuid() string

func (*ExtEvtRegisteredOePb) GetNodeRunPosition 

func (x *ExtEvtRegisteredOePb) GetNodeRunPosition() int32

func (*ExtEvtRegisteredOePb) GetThreadRunNumber 

func (x *ExtEvtRegisteredOePb) GetThreadRunNumber() int32

func (*ExtEvtRegisteredOePb) ProtoMessage 

func (*ExtEvtRegisteredOePb) ProtoMessage()

func (*ExtEvtRegisteredOePb) ProtoReflect 

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

func (*ExtEvtRegisteredOePb) Reset 

func (x *ExtEvtRegisteredOePb) Reset()

func (*ExtEvtRegisteredOePb) String 

func (x *ExtEvtRegisteredOePb) String() string

type ExternalEventDefIdPb 

type ExternalEventDefIdPb struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*ExternalEventDefIdPb) Descriptor deprecated 

func (*ExternalEventDefIdPb) Descriptor() ([]byte, []int)

Deprecated: Use ExternalEventDefIdPb.ProtoReflect.Descriptor instead.

func (*ExternalEventDefIdPb) GetName 

func (x *ExternalEventDefIdPb) GetName() string

func (*ExternalEventDefIdPb) ProtoMessage 

func (*ExternalEventDefIdPb) ProtoMessage()

func (*ExternalEventDefIdPb) ProtoReflect 

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

func (*ExternalEventDefIdPb) Reset 

func (x *ExternalEventDefIdPb) Reset()

func (*ExternalEventDefIdPb) String 

func (x *ExternalEventDefIdPb) String() string

type ExternalEventDefPb 

type ExternalEventDefPb struct {
	Name      string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

ExternalEventDef

func (*ExternalEventDefPb) Descriptor deprecated 

func (*ExternalEventDefPb) Descriptor() ([]byte, []int)

Deprecated: Use ExternalEventDefPb.ProtoReflect.Descriptor instead.

func (*ExternalEventDefPb) GetCreatedAt 

func (x *ExternalEventDefPb) GetCreatedAt() *timestamppb.Timestamp

func (*ExternalEventDefPb) GetName 

func (x *ExternalEventDefPb) GetName() string

func (*ExternalEventDefPb) ProtoMessage 

func (*ExternalEventDefPb) ProtoMessage()

func (*ExternalEventDefPb) ProtoReflect 

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

func (*ExternalEventDefPb) Reset 

func (x *ExternalEventDefPb) Reset()

func (*ExternalEventDefPb) String 

func (x *ExternalEventDefPb) String() string

type ExternalEventIdPb 

type ExternalEventIdPb struct {
	WfRunId              string `protobuf:"bytes,1,opt,name=wf_run_id,json=wfRunId,proto3" json:"wf_run_id,omitempty"`
	ExternalEventDefName string `protobuf:"bytes,2,opt,name=external_event_def_name,json=externalEventDefName,proto3" json:"external_event_def_name,omitempty"`
	Guid                 string `protobuf:"bytes,3,opt,name=guid,proto3" json:"guid,omitempty"`
	// contains filtered or unexported fields
}

External Event

func (*ExternalEventIdPb) Descriptor deprecated 

func (*ExternalEventIdPb) Descriptor() ([]byte, []int)

Deprecated: Use ExternalEventIdPb.ProtoReflect.Descriptor instead.

func (*ExternalEventIdPb) GetExternalEventDefName 

func (x *ExternalEventIdPb) GetExternalEventDefName() string

func (*ExternalEventIdPb) GetGuid 

func (x *ExternalEventIdPb) GetGuid() string

func (*ExternalEventIdPb) GetWfRunId 

func (x *ExternalEventIdPb) GetWfRunId() string

func (*ExternalEventIdPb) ProtoMessage 

func (*ExternalEventIdPb) ProtoMessage()

func (*ExternalEventIdPb) ProtoReflect 

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

func (*ExternalEventIdPb) Reset 

func (x *ExternalEventIdPb) Reset()

func (*ExternalEventIdPb) String 

func (x *ExternalEventIdPb) String() string

type ExternalEventNodePb 

type ExternalEventNodePb struct {
	ExternalEventDefName string                `protobuf:"bytes,1,opt,name=external_event_def_name,json=externalEventDefName,proto3" json:"external_event_def_name,omitempty"`
	TimeoutSeconds       *VariableAssignmentPb `protobuf:"bytes,2,opt,name=timeout_seconds,json=timeoutSeconds,proto3" json:"timeout_seconds,omitempty"`
	// contains filtered or unexported fields
}

func (*ExternalEventNodePb) Descriptor deprecated 

func (*ExternalEventNodePb) Descriptor() ([]byte, []int)

Deprecated: Use ExternalEventNodePb.ProtoReflect.Descriptor instead.

func (*ExternalEventNodePb) GetExternalEventDefName 

func (x *ExternalEventNodePb) GetExternalEventDefName() string

func (*ExternalEventNodePb) GetTimeoutSeconds 

func (x *ExternalEventNodePb) GetTimeoutSeconds() *VariableAssignmentPb

func (*ExternalEventNodePb) ProtoMessage 

func (*ExternalEventNodePb) ProtoMessage()

func (*ExternalEventNodePb) ProtoReflect 

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

func (*ExternalEventNodePb) Reset 

func (x *ExternalEventNodePb) Reset()

func (*ExternalEventNodePb) String 

func (x *ExternalEventNodePb) String() string

type ExternalEventPb 

type ExternalEventPb struct {
	WfRunId              string                 `protobuf:"bytes,1,opt,name=wf_run_id,json=wfRunId,proto3" json:"wf_run_id,omitempty"`
	ExternalEventDefName string                 `protobuf:"bytes,2,opt,name=external_event_def_name,json=externalEventDefName,proto3" json:"external_event_def_name,omitempty"`
	Guid                 string                 `protobuf:"bytes,3,opt,name=guid,proto3" json:"guid,omitempty"`
	CreatedAt            *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	Content              *VariableValuePb       `protobuf:"bytes,5,opt,name=content,proto3" json:"content,omitempty"`
	ThreadRunNumber      *int32                 `protobuf:"varint,6,opt,name=thread_run_number,json=threadRunNumber,proto3,oneof" json:"thread_run_number,omitempty"`
	NodeRunPosition      *int32                 `protobuf:"varint,7,opt,name=node_run_position,json=nodeRunPosition,proto3,oneof" json:"node_run_position,omitempty"`
	Claimed              bool                   `protobuf:"varint,8,opt,name=claimed,proto3" json:"claimed,omitempty"`
	// contains filtered or unexported fields
}

func (*ExternalEventPb) Descriptor deprecated 

func (*ExternalEventPb) Descriptor() ([]byte, []int)

Deprecated: Use ExternalEventPb.ProtoReflect.Descriptor instead.

func (*ExternalEventPb) GetClaimed 

func (x *ExternalEventPb) GetClaimed() bool

func (*ExternalEventPb) GetContent 

func (x *ExternalEventPb) GetContent() *VariableValuePb

func (*ExternalEventPb) GetCreatedAt 

func (x *ExternalEventPb) GetCreatedAt() *timestamppb.Timestamp

func (*ExternalEventPb) GetExternalEventDefName 

func (x *ExternalEventPb) GetExternalEventDefName() string

func (*ExternalEventPb) GetGuid 

func (x *ExternalEventPb) GetGuid() string

func (*ExternalEventPb) GetNodeRunPosition 

func (x *ExternalEventPb) GetNodeRunPosition() int32

func (*ExternalEventPb) GetThreadRunNumber 

func (x *ExternalEventPb) GetThreadRunNumber() int32

func (*ExternalEventPb) GetWfRunId 

func (x *ExternalEventPb) GetWfRunId() string

func (*ExternalEventPb) ProtoMessage 

func (*ExternalEventPb) ProtoMessage()

func (*ExternalEventPb) ProtoReflect 

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

func (*ExternalEventPb) Reset 

func (x *ExternalEventPb) Reset()

func (*ExternalEventPb) String 

func (x *ExternalEventPb) String() string

type ExternalEventRunPb 

type ExternalEventRunPb struct {
	ExternalEventDefName string                 `protobuf:"bytes,1,opt,name=external_event_def_name,json=externalEventDefName,proto3" json:"external_event_def_name,omitempty"`
	EventTime            *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=event_time,json=eventTime,proto3,oneof" json:"event_time,omitempty"`
	ExternalEventId      *ExternalEventIdPb     `protobuf:"bytes,3,opt,name=external_event_id,json=externalEventId,proto3,oneof" json:"external_event_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ExternalEventRunPb) Descriptor deprecated 

func (*ExternalEventRunPb) Descriptor() ([]byte, []int)

Deprecated: Use ExternalEventRunPb.ProtoReflect.Descriptor instead.

func (*ExternalEventRunPb) GetEventTime 

func (x *ExternalEventRunPb) GetEventTime() *timestamppb.Timestamp

func (*ExternalEventRunPb) GetExternalEventDefName 

func (x *ExternalEventRunPb) GetExternalEventDefName() string

func (*ExternalEventRunPb) GetExternalEventId 

func (x *ExternalEventRunPb) GetExternalEventId() *ExternalEventIdPb

func (*ExternalEventRunPb) ProtoMessage 

func (*ExternalEventRunPb) ProtoMessage()

func (*ExternalEventRunPb) ProtoReflect 

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

func (*ExternalEventRunPb) Reset 

func (x *ExternalEventRunPb) Reset()

func (*ExternalEventRunPb) String 

func (x *ExternalEventRunPb) String() string

type FailureBeingHandledPb 

type FailureBeingHandledPb struct {
	ThreadRunNumber int32 `protobuf:"varint,1,opt,name=thread_run_number,json=threadRunNumber,proto3" json:"thread_run_number,omitempty"`
	NodeRunPosition int32 `protobuf:"varint,2,opt,name=node_run_position,json=nodeRunPosition,proto3" json:"node_run_position,omitempty"`
	FailureNumber   int32 `protobuf:"varint,3,opt,name=failure_number,json=failureNumber,proto3" json:"failure_number,omitempty"`
	// contains filtered or unexported fields
}

func (*FailureBeingHandledPb) Descriptor deprecated 

func (*FailureBeingHandledPb) Descriptor() ([]byte, []int)

Deprecated: Use FailureBeingHandledPb.ProtoReflect.Descriptor instead.

func (*FailureBeingHandledPb) GetFailureNumber 

func (x *FailureBeingHandledPb) GetFailureNumber() int32

func (*FailureBeingHandledPb) GetNodeRunPosition 

func (x *FailureBeingHandledPb) GetNodeRunPosition() int32

func (*FailureBeingHandledPb) GetThreadRunNumber 

func (x *FailureBeingHandledPb) GetThreadRunNumber() int32

func (*FailureBeingHandledPb) ProtoMessage 

func (*FailureBeingHandledPb) ProtoMessage()

func (*FailureBeingHandledPb) ProtoReflect 

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

func (*FailureBeingHandledPb) Reset 

func (x *FailureBeingHandledPb) Reset()

func (*FailureBeingHandledPb) String 

func (x *FailureBeingHandledPb) String() string

type FailureDefPb 

type FailureDefPb struct {
	FailureName string                `protobuf:"bytes,1,opt,name=failure_name,json=failureName,proto3" json:"failure_name,omitempty"`
	FailureCode TaskResultCodePb      `` /* 129-byte string literal not displayed */
	Message     string                `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Content     *VariableAssignmentPb `protobuf:"bytes,4,opt,name=content,proto3,oneof" json:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*FailureDefPb) Descriptor deprecated 

func (*FailureDefPb) Descriptor() ([]byte, []int)

Deprecated: Use FailureDefPb.ProtoReflect.Descriptor instead.

func (*FailureDefPb) GetContent 

func (x *FailureDefPb) GetContent() *VariableAssignmentPb

func (*FailureDefPb) GetFailureCode 

func (x *FailureDefPb) GetFailureCode() TaskResultCodePb

func (*FailureDefPb) GetFailureName 

func (x *FailureDefPb) GetFailureName() string

func (*FailureDefPb) GetMessage 

func (x *FailureDefPb) GetMessage() string

func (*FailureDefPb) ProtoMessage 

func (*FailureDefPb) ProtoMessage()

func (*FailureDefPb) ProtoReflect 

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

func (*FailureDefPb) Reset 

func (x *FailureDefPb) Reset()

func (*FailureDefPb) String 

func (x *FailureDefPb) String() string

type FailureHandlerDefPb 

type FailureHandlerDefPb struct {
	SpecificFailure *string `protobuf:"bytes,1,opt,name=specific_failure,json=specificFailure,proto3,oneof" json:"specific_failure,omitempty"`
	HandlerSpecName string  `protobuf:"bytes,2,opt,name=handler_spec_name,json=handlerSpecName,proto3" json:"handler_spec_name,omitempty"`
	// contains filtered or unexported fields
}

func (*FailureHandlerDefPb) Descriptor deprecated 

func (*FailureHandlerDefPb) Descriptor() ([]byte, []int)

Deprecated: Use FailureHandlerDefPb.ProtoReflect.Descriptor instead.

func (*FailureHandlerDefPb) GetHandlerSpecName 

func (x *FailureHandlerDefPb) GetHandlerSpecName() string

func (*FailureHandlerDefPb) GetSpecificFailure 

func (x *FailureHandlerDefPb) GetSpecificFailure() string

func (*FailureHandlerDefPb) ProtoMessage 

func (*FailureHandlerDefPb) ProtoMessage()

func (*FailureHandlerDefPb) ProtoReflect 

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

func (*FailureHandlerDefPb) Reset 

func (x *FailureHandlerDefPb) Reset()

func (*FailureHandlerDefPb) String 

func (x *FailureHandlerDefPb) String() string

type FailurePb 

type FailurePb struct {
	FailureName string           `protobuf:"bytes,1,opt,name=failure_name,json=failureName,proto3" json:"failure_name,omitempty"`
	FailureCode TaskResultCodePb `` /* 129-byte string literal not displayed */
	Message     string           `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Content     *VariableValuePb `protobuf:"bytes,4,opt,name=content,proto3,oneof" json:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*FailurePb) Descriptor deprecated 

func (*FailurePb) Descriptor() ([]byte, []int)

Deprecated: Use FailurePb.ProtoReflect.Descriptor instead.

func (*FailurePb) GetContent 

func (x *FailurePb) GetContent() *VariableValuePb

func (*FailurePb) GetFailureCode 

func (x *FailurePb) GetFailureCode() TaskResultCodePb

func (*FailurePb) GetFailureName 

func (x *FailurePb) GetFailureName() string

func (*FailurePb) GetMessage 

func (x *FailurePb) GetMessage() string

func (*FailurePb) ProtoMessage 

func (*FailurePb) ProtoMessage()

func (*FailurePb) ProtoReflect 

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

func (*FailurePb) Reset 

func (x *FailurePb) Reset()

func (*FailurePb) String 

func (x *FailurePb) String() string

type GetExternalEventDefReplyPb 

type GetExternalEventDefReplyPb struct {
	Code    LHResponseCodePb    `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message *string             `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	Result  *ExternalEventDefPb `protobuf:"bytes,3,opt,name=result,proto3,oneof" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*GetExternalEventDefReplyPb) Descriptor deprecated 

func (*GetExternalEventDefReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use GetExternalEventDefReplyPb.ProtoReflect.Descriptor instead.

func (*GetExternalEventDefReplyPb) GetCode 

func (x *GetExternalEventDefReplyPb) GetCode() LHResponseCodePb

func (*GetExternalEventDefReplyPb) GetMessage 

func (x *GetExternalEventDefReplyPb) GetMessage() string

func (*GetExternalEventDefReplyPb) GetResult 

func (x *GetExternalEventDefReplyPb) GetResult() *ExternalEventDefPb

func (*GetExternalEventDefReplyPb) ProtoMessage 

func (*GetExternalEventDefReplyPb) ProtoMessage()

func (*GetExternalEventDefReplyPb) ProtoReflect 

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

func (*GetExternalEventDefReplyPb) Reset 

func (x *GetExternalEventDefReplyPb) Reset()

func (*GetExternalEventDefReplyPb) String 

func (x *GetExternalEventDefReplyPb) String() string

type GetExternalEventReplyPb 

type GetExternalEventReplyPb struct {
	Code    LHResponseCodePb `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message *string          `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	Result  *ExternalEventPb `protobuf:"bytes,3,opt,name=result,proto3,oneof" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*GetExternalEventReplyPb) Descriptor deprecated 

func (*GetExternalEventReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use GetExternalEventReplyPb.ProtoReflect.Descriptor instead.

func (*GetExternalEventReplyPb) GetCode 

func (x *GetExternalEventReplyPb) GetCode() LHResponseCodePb

func (*GetExternalEventReplyPb) GetMessage 

func (x *GetExternalEventReplyPb) GetMessage() string

func (*GetExternalEventReplyPb) GetResult 

func (x *GetExternalEventReplyPb) GetResult() *ExternalEventPb

func (*GetExternalEventReplyPb) ProtoMessage 

func (*GetExternalEventReplyPb) ProtoMessage()

func (*GetExternalEventReplyPb) ProtoReflect 

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

func (*GetExternalEventReplyPb) Reset 

func (x *GetExternalEventReplyPb) Reset()

func (*GetExternalEventReplyPb) String 

func (x *GetExternalEventReplyPb) String() string

type GetLatestWfSpecPb 

type GetLatestWfSpecPb struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLatestWfSpecPb) Descriptor deprecated 

func (*GetLatestWfSpecPb) Descriptor() ([]byte, []int)

Deprecated: Use GetLatestWfSpecPb.ProtoReflect.Descriptor instead.

func (*GetLatestWfSpecPb) GetName 

func (x *GetLatestWfSpecPb) GetName() string

func (*GetLatestWfSpecPb) ProtoMessage 

func (*GetLatestWfSpecPb) ProtoMessage()

func (*GetLatestWfSpecPb) ProtoReflect 

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

func (*GetLatestWfSpecPb) Reset 

func (x *GetLatestWfSpecPb) Reset()

func (*GetLatestWfSpecPb) String 

func (x *GetLatestWfSpecPb) String() string

type GetNodeRunReplyPb 

type GetNodeRunReplyPb struct {
	Code    LHResponseCodePb `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message *string          `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	Result  *NodeRunPb       `protobuf:"bytes,3,opt,name=result,proto3,oneof" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNodeRunReplyPb) Descriptor deprecated 

func (*GetNodeRunReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use GetNodeRunReplyPb.ProtoReflect.Descriptor instead.

func (*GetNodeRunReplyPb) GetCode 

func (x *GetNodeRunReplyPb) GetCode() LHResponseCodePb

func (*GetNodeRunReplyPb) GetMessage 

func (x *GetNodeRunReplyPb) GetMessage() string

func (*GetNodeRunReplyPb) GetResult 

func (x *GetNodeRunReplyPb) GetResult() *NodeRunPb

func (*GetNodeRunReplyPb) ProtoMessage 

func (*GetNodeRunReplyPb) ProtoMessage()

func (*GetNodeRunReplyPb) ProtoReflect 

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

func (*GetNodeRunReplyPb) Reset 

func (x *GetNodeRunReplyPb) Reset()

func (*GetNodeRunReplyPb) String 

func (x *GetNodeRunReplyPb) String() string

type GetTaskDefReplyPb 

type GetTaskDefReplyPb struct {
	Code    LHResponseCodePb `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message *string          `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	Result  *TaskDefPb       `protobuf:"bytes,3,opt,name=result,proto3,oneof" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTaskDefReplyPb) Descriptor deprecated 

func (*GetTaskDefReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use GetTaskDefReplyPb.ProtoReflect.Descriptor instead.

func (*GetTaskDefReplyPb) GetCode 

func (x *GetTaskDefReplyPb) GetCode() LHResponseCodePb

func (*GetTaskDefReplyPb) GetMessage 

func (x *GetTaskDefReplyPb) GetMessage() string

func (*GetTaskDefReplyPb) GetResult 

func (x *GetTaskDefReplyPb) GetResult() *TaskDefPb

func (*GetTaskDefReplyPb) ProtoMessage 

func (*GetTaskDefReplyPb) ProtoMessage()

func (*GetTaskDefReplyPb) ProtoReflect 

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

func (*GetTaskDefReplyPb) Reset 

func (x *GetTaskDefReplyPb) Reset()

func (*GetTaskDefReplyPb) String 

func (x *GetTaskDefReplyPb) String() string

type GetVariableReplyPb 

type GetVariableReplyPb struct {
	Code    LHResponseCodePb `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message *string          `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	Result  *VariablePb      `protobuf:"bytes,3,opt,name=result,proto3,oneof" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVariableReplyPb) Descriptor deprecated 

func (*GetVariableReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use GetVariableReplyPb.ProtoReflect.Descriptor instead.

func (*GetVariableReplyPb) GetCode 

func (x *GetVariableReplyPb) GetCode() LHResponseCodePb

func (*GetVariableReplyPb) GetMessage 

func (x *GetVariableReplyPb) GetMessage() string

func (*GetVariableReplyPb) GetResult 

func (x *GetVariableReplyPb) GetResult() *VariablePb

func (*GetVariableReplyPb) ProtoMessage 

func (*GetVariableReplyPb) ProtoMessage()

func (*GetVariableReplyPb) ProtoReflect 

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

func (*GetVariableReplyPb) Reset 

func (x *GetVariableReplyPb) Reset()

func (*GetVariableReplyPb) String 

func (x *GetVariableReplyPb) String() string

type GetWfRunReplyPb 

type GetWfRunReplyPb struct {
	Code    LHResponseCodePb `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message *string          `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	Result  *WfRunPb         `protobuf:"bytes,3,opt,name=result,proto3,oneof" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWfRunReplyPb) Descriptor deprecated 

func (*GetWfRunReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use GetWfRunReplyPb.ProtoReflect.Descriptor instead.

func (*GetWfRunReplyPb) GetCode 

func (x *GetWfRunReplyPb) GetCode() LHResponseCodePb

func (*GetWfRunReplyPb) GetMessage 

func (x *GetWfRunReplyPb) GetMessage() string

func (*GetWfRunReplyPb) GetResult 

func (x *GetWfRunReplyPb) GetResult() *WfRunPb

func (*GetWfRunReplyPb) ProtoMessage 

func (*GetWfRunReplyPb) ProtoMessage()

func (*GetWfRunReplyPb) ProtoReflect 

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

func (*GetWfRunReplyPb) Reset 

func (x *GetWfRunReplyPb) Reset()

func (*GetWfRunReplyPb) String 

func (x *GetWfRunReplyPb) String() string

type GetWfSpecReplyPb 

type GetWfSpecReplyPb struct {
	Code    LHResponseCodePb `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message *string          `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	Result  *WfSpecPb        `protobuf:"bytes,3,opt,name=result,proto3,oneof" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWfSpecReplyPb) Descriptor deprecated 

func (*GetWfSpecReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use GetWfSpecReplyPb.ProtoReflect.Descriptor instead.

func (*GetWfSpecReplyPb) GetCode 

func (x *GetWfSpecReplyPb) GetCode() LHResponseCodePb

func (*GetWfSpecReplyPb) GetMessage 

func (x *GetWfSpecReplyPb) GetMessage() string

func (*GetWfSpecReplyPb) GetResult 

func (x *GetWfSpecReplyPb) GetResult() *WfSpecPb

func (*GetWfSpecReplyPb) ProtoMessage 

func (*GetWfSpecReplyPb) ProtoMessage()

func (*GetWfSpecReplyPb) ProtoReflect 

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

func (*GetWfSpecReplyPb) Reset 

func (x *GetWfSpecReplyPb) Reset()

func (*GetWfSpecReplyPb) String 

func (x *GetWfSpecReplyPb) String() string

type HandlingFailureHaltReasonPb 

type HandlingFailureHaltReasonPb struct {
	HandlerThreadId int32 `protobuf:"varint,1,opt,name=handler_thread_id,json=handlerThreadId,proto3" json:"handler_thread_id,omitempty"`
	// contains filtered or unexported fields
}

func (*HandlingFailureHaltReasonPb) Descriptor deprecated 

func (*HandlingFailureHaltReasonPb) Descriptor() ([]byte, []int)

Deprecated: Use HandlingFailureHaltReasonPb.ProtoReflect.Descriptor instead.

func (*HandlingFailureHaltReasonPb) GetHandlerThreadId 

func (x *HandlingFailureHaltReasonPb) GetHandlerThreadId() int32

func (*HandlingFailureHaltReasonPb) ProtoMessage 

func (*HandlingFailureHaltReasonPb) ProtoMessage()

func (*HandlingFailureHaltReasonPb) ProtoReflect 

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

func (*HandlingFailureHaltReasonPb) Reset 

func (x *HandlingFailureHaltReasonPb) Reset()

func (*HandlingFailureHaltReasonPb) String 

func (x *HandlingFailureHaltReasonPb) String() string

type HealthCheckPb 

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

func (*HealthCheckPb) Descriptor deprecated 

func (*HealthCheckPb) Descriptor() ([]byte, []int)

Deprecated: Use HealthCheckPb.ProtoReflect.Descriptor instead.

func (*HealthCheckPb) ProtoMessage 

func (*HealthCheckPb) ProtoMessage()

func (*HealthCheckPb) ProtoReflect 

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

func (*HealthCheckPb) Reset 

func (x *HealthCheckPb) Reset()

func (*HealthCheckPb) String 

func (x *HealthCheckPb) String() string

type HealthCheckReplyPb 

type HealthCheckReplyPb struct {
	CoreState  LHHealthResultPb `protobuf:"varint,1,opt,name=core_state,json=coreState,proto3,enum=littlehorse.LHHealthResultPb" json:"core_state,omitempty"`
	TimerState LHHealthResultPb `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*HealthCheckReplyPb) Descriptor deprecated 

func (*HealthCheckReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use HealthCheckReplyPb.ProtoReflect.Descriptor instead.

func (*HealthCheckReplyPb) GetCoreState 

func (x *HealthCheckReplyPb) GetCoreState() LHHealthResultPb

func (*HealthCheckReplyPb) GetTimerState 

func (x *HealthCheckReplyPb) GetTimerState() LHHealthResultPb

func (*HealthCheckReplyPb) ProtoMessage 

func (*HealthCheckReplyPb) ProtoMessage()

func (*HealthCheckReplyPb) ProtoReflect 

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

func (*HealthCheckReplyPb) Reset 

func (x *HealthCheckReplyPb) Reset()

func (*HealthCheckReplyPb) String 

func (x *HealthCheckReplyPb) String() string

type HostInfoPb 

type HostInfoPb struct {
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Port int32  `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*HostInfoPb) Descriptor deprecated 

func (*HostInfoPb) Descriptor() ([]byte, []int)

Deprecated: Use HostInfoPb.ProtoReflect.Descriptor instead.

func (*HostInfoPb) GetHost 

func (x *HostInfoPb) GetHost() string

func (*HostInfoPb) GetPort 

func (x *HostInfoPb) GetPort() int32

func (*HostInfoPb) ProtoMessage 

func (*HostInfoPb) ProtoMessage()

func (*HostInfoPb) ProtoReflect 

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

func (*HostInfoPb) Reset 

func (x *HostInfoPb) Reset()

func (*HostInfoPb) String 

func (x *HostInfoPb) String() string

type InterruptDefPb 

type InterruptDefPb struct {
	ExternalEventDefName string `protobuf:"bytes,1,opt,name=external_event_def_name,json=externalEventDefName,proto3" json:"external_event_def_name,omitempty"`
	HandlerSpecName      string `protobuf:"bytes,2,opt,name=handler_spec_name,json=handlerSpecName,proto3" json:"handler_spec_name,omitempty"`
	// contains filtered or unexported fields
}

func (*InterruptDefPb) Descriptor deprecated 

func (*InterruptDefPb) Descriptor() ([]byte, []int)

Deprecated: Use InterruptDefPb.ProtoReflect.Descriptor instead.

func (*InterruptDefPb) GetExternalEventDefName 

func (x *InterruptDefPb) GetExternalEventDefName() string

func (*InterruptDefPb) GetHandlerSpecName 

func (x *InterruptDefPb) GetHandlerSpecName() string

func (*InterruptDefPb) ProtoMessage 

func (*InterruptDefPb) ProtoMessage()

func (*InterruptDefPb) ProtoReflect 

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

func (*InterruptDefPb) Reset 

func (x *InterruptDefPb) Reset()

func (*InterruptDefPb) String 

func (x *InterruptDefPb) String() string

type InterruptedOePb 

type InterruptedOePb struct {
	ExtEvtDefName     string `protobuf:"bytes,1,opt,name=ext_evt_def_name,json=extEvtDefName,proto3" json:"ext_evt_def_name,omitempty"`
	ExtEvtGuid        string `protobuf:"bytes,2,opt,name=ext_evt_guid,json=extEvtGuid,proto3" json:"ext_evt_guid,omitempty"`
	InterruptedThread int32  `protobuf:"varint,3,opt,name=interrupted_thread,json=interruptedThread,proto3" json:"interrupted_thread,omitempty"`
	// contains filtered or unexported fields
}

func (*InterruptedOePb) Descriptor deprecated 

func (*InterruptedOePb) Descriptor() ([]byte, []int)

Deprecated: Use InterruptedOePb.ProtoReflect.Descriptor instead.

func (*InterruptedOePb) GetExtEvtDefName 

func (x *InterruptedOePb) GetExtEvtDefName() string

func (*InterruptedOePb) GetExtEvtGuid 

func (x *InterruptedOePb) GetExtEvtGuid() string

func (*InterruptedOePb) GetInterruptedThread 

func (x *InterruptedOePb) GetInterruptedThread() int32

func (*InterruptedOePb) ProtoMessage 

func (*InterruptedOePb) ProtoMessage()

func (*InterruptedOePb) ProtoReflect 

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

func (*InterruptedOePb) Reset 

func (x *InterruptedOePb) Reset()

func (*InterruptedOePb) String 

func (x *InterruptedOePb) String() string

type InterruptedPb 

type InterruptedPb struct {
	InterruptThreadId int32 `protobuf:"varint,1,opt,name=interrupt_thread_id,json=interruptThreadId,proto3" json:"interrupt_thread_id,omitempty"`
	// contains filtered or unexported fields
}

func (*InterruptedPb) Descriptor deprecated 

func (*InterruptedPb) Descriptor() ([]byte, []int)

Deprecated: Use InterruptedPb.ProtoReflect.Descriptor instead.

func (*InterruptedPb) GetInterruptThreadId 

func (x *InterruptedPb) GetInterruptThreadId() int32

func (*InterruptedPb) ProtoMessage 

func (*InterruptedPb) ProtoMessage()

func (*InterruptedPb) ProtoReflect 

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

func (*InterruptedPb) Reset 

func (x *InterruptedPb) Reset()

func (*InterruptedPb) String 

func (x *InterruptedPb) String() string

type LHHealthResultPb 

type LHHealthResultPb int32
const (
	LHHealthResultPb_LH_HEALTH_RUNNING     LHHealthResultPb = 0
	LHHealthResultPb_LH_HEALTH_REBALANCING LHHealthResultPb = 1
	LHHealthResultPb_LH_HEALTH_ERROR       LHHealthResultPb = 2
)

func (LHHealthResultPb) Descriptor 

func (LHHealthResultPb) Descriptor() protoreflect.EnumDescriptor

func (LHHealthResultPb) Enum 

func (x LHHealthResultPb) Enum() *LHHealthResultPb

func (LHHealthResultPb) EnumDescriptor deprecated 

func (LHHealthResultPb) EnumDescriptor() ([]byte, []int)

Deprecated: Use LHHealthResultPb.Descriptor instead.

func (LHHealthResultPb) Number 

func (x LHHealthResultPb) Number() protoreflect.EnumNumber

func (LHHealthResultPb) String 

func (x LHHealthResultPb) String() string

func (LHHealthResultPb) Type 

func (LHHealthResultPb) Type() protoreflect.EnumType

type LHPublicApiClient 

type LHPublicApiClient interface {
	PutTaskDef(ctx context.Context, in *PutTaskDefPb, opts ...grpc.CallOption) (*PutTaskDefReplyPb, error)
	GetTaskDef(ctx context.Context, in *TaskDefIdPb, opts ...grpc.CallOption) (*GetTaskDefReplyPb, error)
	PutExternalEventDef(ctx context.Context, in *PutExternalEventDefPb, opts ...grpc.CallOption) (*PutExternalEventDefReplyPb, error)
	GetExternalEventDef(ctx context.Context, in *ExternalEventDefIdPb, opts ...grpc.CallOption) (*GetExternalEventDefReplyPb, error)
	PutWfSpec(ctx context.Context, in *PutWfSpecPb, opts ...grpc.CallOption) (*PutWfSpecReplyPb, error)
	GetWfSpec(ctx context.Context, in *WfSpecIdPb, opts ...grpc.CallOption) (*GetWfSpecReplyPb, error)
	GetLatestWfSpec(ctx context.Context, in *GetLatestWfSpecPb, opts ...grpc.CallOption) (*GetWfSpecReplyPb, error)
	RunWf(ctx context.Context, in *RunWfPb, opts ...grpc.CallOption) (*RunWfReplyPb, error)
	GetWfRun(ctx context.Context, in *WfRunIdPb, opts ...grpc.CallOption) (*GetWfRunReplyPb, error)
	GetNodeRun(ctx context.Context, in *NodeRunIdPb, opts ...grpc.CallOption) (*GetNodeRunReplyPb, error)
	ListNodeRuns(ctx context.Context, in *ListNodeRunsPb, opts ...grpc.CallOption) (*ListNodeRunsReplyPb, error)
	GetVariable(ctx context.Context, in *VariableIdPb, opts ...grpc.CallOption) (*GetVariableReplyPb, error)
	ListVariables(ctx context.Context, in *ListVariablesPb, opts ...grpc.CallOption) (*ListVariablesReplyPb, error)
	PutExternalEvent(ctx context.Context, in *PutExternalEventPb, opts ...grpc.CallOption) (*PutExternalEventReplyPb, error)
	GetExternalEvent(ctx context.Context, in *ExternalEventIdPb, opts ...grpc.CallOption) (*GetExternalEventReplyPb, error)
	ListExternalEvents(ctx context.Context, in *ListExternalEventsPb, opts ...grpc.CallOption) (*ListExternalEventsReplyPb, error)
	SearchWfRun(ctx context.Context, in *SearchWfRunPb, opts ...grpc.CallOption) (*SearchWfRunReplyPb, error)
	SearchNodeRun(ctx context.Context, in *SearchNodeRunPb, opts ...grpc.CallOption) (*SearchNodeRunReplyPb, error)
	SearchVariable(ctx context.Context, in *SearchVariablePb, opts ...grpc.CallOption) (*SearchVariableReplyPb, error)
	SearchTaskDef(ctx context.Context, in *SearchTaskDefPb, opts ...grpc.CallOption) (*SearchTaskDefReplyPb, error)
	SearchWfSpec(ctx context.Context, in *SearchWfSpecPb, opts ...grpc.CallOption) (*SearchWfSpecReplyPb, error)
	SearchExternalEventDef(ctx context.Context, in *SearchExternalEventDefPb, opts ...grpc.CallOption) (*SearchExternalEventDefReplyPb, error)
	SearchExternalEvent(ctx context.Context, in *SearchExternalEventPb, opts ...grpc.CallOption) (*SearchExternalEventReplyPb, error)
	RegisterTaskWorker(ctx context.Context, in *RegisterTaskWorkerPb, opts ...grpc.CallOption) (*RegisterTaskWorkerReplyPb, error)
	PollTask(ctx context.Context, opts ...grpc.CallOption) (LHPublicApi_PollTaskClient, error)
	ReportTask(ctx context.Context, in *TaskResultEventPb, opts ...grpc.CallOption) (*ReportTaskReplyPb, error)
	StopWfRun(ctx context.Context, in *StopWfRunPb, opts ...grpc.CallOption) (*StopWfRunReplyPb, error)
	ResumeWfRun(ctx context.Context, in *ResumeWfRunPb, opts ...grpc.CallOption) (*ResumeWfRunReplyPb, error)
	DeleteWfRun(ctx context.Context, in *DeleteWfRunPb, opts ...grpc.CallOption) (*DeleteObjectReplyPb, error)
	DeleteTaskDef(ctx context.Context, in *DeleteTaskDefPb, opts ...grpc.CallOption) (*DeleteObjectReplyPb, error)
	DeleteWfSpec(ctx context.Context, in *DeleteWfSpecPb, opts ...grpc.CallOption) (*DeleteObjectReplyPb, error)
	DeleteExternalEventDef(ctx context.Context, in *DeleteExternalEventDefPb, opts ...grpc.CallOption) (*DeleteObjectReplyPb, error)
	HealthCheck(ctx context.Context, in *HealthCheckPb, opts ...grpc.CallOption) (*HealthCheckReplyPb, error)
	TaskDefMetrics(ctx context.Context, in *TaskDefMetricsQueryPb, opts ...grpc.CallOption) (*TaskDefMetricsReplyPb, error)
	WfSpecMetrics(ctx context.Context, in *WfSpecMetricsQueryPb, opts ...grpc.CallOption) (*WfSpecMetricsReplyPb, error)
	ListTaskDefMetrics(ctx context.Context, in *ListTaskMetricsPb, opts ...grpc.CallOption) (*ListTaskMetricsReplyPb, error)
	ListWfSpecMetrics(ctx context.Context, in *ListWfMetricsPb, opts ...grpc.CallOption) (*ListWfMetricsReplyPb, error)
}

LHPublicApiClient is the client API for LHPublicApi 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 NewLHPublicApiClient 

func NewLHPublicApiClient(cc grpc.ClientConnInterface) LHPublicApiClient

type LHPublicApiServer 

type LHPublicApiServer interface {
	PutTaskDef(context.Context, *PutTaskDefPb) (*PutTaskDefReplyPb, error)
	GetTaskDef(context.Context, *TaskDefIdPb) (*GetTaskDefReplyPb, error)
	PutExternalEventDef(context.Context, *PutExternalEventDefPb) (*PutExternalEventDefReplyPb, error)
	GetExternalEventDef(context.Context, *ExternalEventDefIdPb) (*GetExternalEventDefReplyPb, error)
	PutWfSpec(context.Context, *PutWfSpecPb) (*PutWfSpecReplyPb, error)
	GetWfSpec(context.Context, *WfSpecIdPb) (*GetWfSpecReplyPb, error)
	GetLatestWfSpec(context.Context, *GetLatestWfSpecPb) (*GetWfSpecReplyPb, error)
	RunWf(context.Context, *RunWfPb) (*RunWfReplyPb, error)
	GetWfRun(context.Context, *WfRunIdPb) (*GetWfRunReplyPb, error)
	GetNodeRun(context.Context, *NodeRunIdPb) (*GetNodeRunReplyPb, error)
	ListNodeRuns(context.Context, *ListNodeRunsPb) (*ListNodeRunsReplyPb, error)
	GetVariable(context.Context, *VariableIdPb) (*GetVariableReplyPb, error)
	ListVariables(context.Context, *ListVariablesPb) (*ListVariablesReplyPb, error)
	PutExternalEvent(context.Context, *PutExternalEventPb) (*PutExternalEventReplyPb, error)
	GetExternalEvent(context.Context, *ExternalEventIdPb) (*GetExternalEventReplyPb, error)
	ListExternalEvents(context.Context, *ListExternalEventsPb) (*ListExternalEventsReplyPb, error)
	SearchWfRun(context.Context, *SearchWfRunPb) (*SearchWfRunReplyPb, error)
	SearchNodeRun(context.Context, *SearchNodeRunPb) (*SearchNodeRunReplyPb, error)
	SearchVariable(context.Context, *SearchVariablePb) (*SearchVariableReplyPb, error)
	SearchTaskDef(context.Context, *SearchTaskDefPb) (*SearchTaskDefReplyPb, error)
	SearchWfSpec(context.Context, *SearchWfSpecPb) (*SearchWfSpecReplyPb, error)
	SearchExternalEventDef(context.Context, *SearchExternalEventDefPb) (*SearchExternalEventDefReplyPb, error)
	SearchExternalEvent(context.Context, *SearchExternalEventPb) (*SearchExternalEventReplyPb, error)
	RegisterTaskWorker(context.Context, *RegisterTaskWorkerPb) (*RegisterTaskWorkerReplyPb, error)
	PollTask(LHPublicApi_PollTaskServer) error
	ReportTask(context.Context, *TaskResultEventPb) (*ReportTaskReplyPb, error)
	StopWfRun(context.Context, *StopWfRunPb) (*StopWfRunReplyPb, error)
	ResumeWfRun(context.Context, *ResumeWfRunPb) (*ResumeWfRunReplyPb, error)
	DeleteWfRun(context.Context, *DeleteWfRunPb) (*DeleteObjectReplyPb, error)
	DeleteTaskDef(context.Context, *DeleteTaskDefPb) (*DeleteObjectReplyPb, error)
	DeleteWfSpec(context.Context, *DeleteWfSpecPb) (*DeleteObjectReplyPb, error)
	DeleteExternalEventDef(context.Context, *DeleteExternalEventDefPb) (*DeleteObjectReplyPb, error)
	HealthCheck(context.Context, *HealthCheckPb) (*HealthCheckReplyPb, error)
	TaskDefMetrics(context.Context, *TaskDefMetricsQueryPb) (*TaskDefMetricsReplyPb, error)
	WfSpecMetrics(context.Context, *WfSpecMetricsQueryPb) (*WfSpecMetricsReplyPb, error)
	ListTaskDefMetrics(context.Context, *ListTaskMetricsPb) (*ListTaskMetricsReplyPb, error)
	ListWfSpecMetrics(context.Context, *ListWfMetricsPb) (*ListWfMetricsReplyPb, error)
	// contains filtered or unexported methods
}

LHPublicApiServer is the server API for LHPublicApi service. All implementations must embed UnimplementedLHPublicApiServer for forward compatibility

type LHPublicApi_PollTaskClient 

type LHPublicApi_PollTaskClient interface {
	Send(*PollTaskPb) error
	Recv() (*PollTaskReplyPb, error)
	grpc.ClientStream
}

type LHPublicApi_PollTaskServer 

type LHPublicApi_PollTaskServer interface {
	Send(*PollTaskReplyPb) error
	Recv() (*PollTaskPb, error)
	grpc.ServerStream
}

type LHResponseCodePb 

type LHResponseCodePb int32
const (
	LHResponseCodePb_OK                         LHResponseCodePb = 0
	LHResponseCodePb_CONNECTION_ERROR           LHResponseCodePb = 1
	LHResponseCodePb_NOT_FOUND_ERROR            LHResponseCodePb = 2
	LHResponseCodePb_BAD_REQUEST_ERROR          LHResponseCodePb = 3
	LHResponseCodePb_VALIDATION_ERROR           LHResponseCodePb = 4
	LHResponseCodePb_ALREADY_EXISTS_ERROR       LHResponseCodePb = 5
	LHResponseCodePb_REPORTED_BUT_NOT_PROCESSED LHResponseCodePb = 6
)

func (LHResponseCodePb) Descriptor 

func (LHResponseCodePb) Descriptor() protoreflect.EnumDescriptor

func (LHResponseCodePb) Enum 

func (x LHResponseCodePb) Enum() *LHResponseCodePb

func (LHResponseCodePb) EnumDescriptor deprecated 

func (LHResponseCodePb) EnumDescriptor() ([]byte, []int)

Deprecated: Use LHResponseCodePb.Descriptor instead.

func (LHResponseCodePb) Number 

func (x LHResponseCodePb) Number() protoreflect.EnumNumber

func (LHResponseCodePb) String 

func (x LHResponseCodePb) String() string

func (LHResponseCodePb) Type 

func (LHResponseCodePb) Type() protoreflect.EnumType

type LHStatusPb 

type LHStatusPb int32
const (
	LHStatusPb_STARTING  LHStatusPb = 0
	LHStatusPb_RUNNING   LHStatusPb = 1
	LHStatusPb_COMPLETED LHStatusPb = 2
	LHStatusPb_HALTING   LHStatusPb = 3
	LHStatusPb_HALTED    LHStatusPb = 4
	LHStatusPb_ERROR     LHStatusPb = 5
)

func (LHStatusPb) Descriptor 

func (LHStatusPb) Descriptor() protoreflect.EnumDescriptor

func (LHStatusPb) Enum 

func (x LHStatusPb) Enum() *LHStatusPb

func (LHStatusPb) EnumDescriptor deprecated 

func (LHStatusPb) EnumDescriptor() ([]byte, []int)

Deprecated: Use LHStatusPb.Descriptor instead.

func (LHStatusPb) Number 

func (x LHStatusPb) Number() protoreflect.EnumNumber

func (LHStatusPb) String 

func (x LHStatusPb) String() string

func (LHStatusPb) Type 

func (LHStatusPb) Type() protoreflect.EnumType

type ListExternalEventsPb 

type ListExternalEventsPb struct {
	WfRunId string `protobuf:"bytes,1,opt,name=wf_run_id,json=wfRunId,proto3" json:"wf_run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListExternalEventsPb) Descriptor deprecated 

func (*ListExternalEventsPb) Descriptor() ([]byte, []int)

Deprecated: Use ListExternalEventsPb.ProtoReflect.Descriptor instead.

func (*ListExternalEventsPb) GetWfRunId 

func (x *ListExternalEventsPb) GetWfRunId() string

func (*ListExternalEventsPb) ProtoMessage 

func (*ListExternalEventsPb) ProtoMessage()

func (*ListExternalEventsPb) ProtoReflect 

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

func (*ListExternalEventsPb) Reset 

func (x *ListExternalEventsPb) Reset()

func (*ListExternalEventsPb) String 

func (x *ListExternalEventsPb) String() string

type ListExternalEventsReplyPb 

type ListExternalEventsReplyPb struct {
	Code    LHResponseCodePb   `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message *string            `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	Results []*ExternalEventPb `protobuf:"bytes,3,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*ListExternalEventsReplyPb) Descriptor deprecated 

func (*ListExternalEventsReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use ListExternalEventsReplyPb.ProtoReflect.Descriptor instead.

func (*ListExternalEventsReplyPb) GetCode 

func (x *ListExternalEventsReplyPb) GetCode() LHResponseCodePb

func (*ListExternalEventsReplyPb) GetMessage 

func (x *ListExternalEventsReplyPb) GetMessage() string

func (*ListExternalEventsReplyPb) GetResults 

func (x *ListExternalEventsReplyPb) GetResults() []*ExternalEventPb

func (*ListExternalEventsReplyPb) ProtoMessage 

func (*ListExternalEventsReplyPb) ProtoMessage()

func (*ListExternalEventsReplyPb) ProtoReflect 

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

func (*ListExternalEventsReplyPb) Reset 

func (x *ListExternalEventsReplyPb) Reset()

func (*ListExternalEventsReplyPb) String 

func (x *ListExternalEventsReplyPb) String() string

type ListNodeRunsPb 

type ListNodeRunsPb struct {
	WfRunId string `protobuf:"bytes,1,opt,name=wf_run_id,json=wfRunId,proto3" json:"wf_run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNodeRunsPb) Descriptor deprecated 

func (*ListNodeRunsPb) Descriptor() ([]byte, []int)

Deprecated: Use ListNodeRunsPb.ProtoReflect.Descriptor instead.

func (*ListNodeRunsPb) GetWfRunId 

func (x *ListNodeRunsPb) GetWfRunId() string

func (*ListNodeRunsPb) ProtoMessage 

func (*ListNodeRunsPb) ProtoMessage()

func (*ListNodeRunsPb) ProtoReflect 

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

func (*ListNodeRunsPb) Reset 

func (x *ListNodeRunsPb) Reset()

func (*ListNodeRunsPb) String 

func (x *ListNodeRunsPb) String() string

type ListNodeRunsReplyPb 

type ListNodeRunsReplyPb struct {
	Code    LHResponseCodePb `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message *string          `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	Results []*NodeRunPb     `protobuf:"bytes,3,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNodeRunsReplyPb) Descriptor deprecated 

func (*ListNodeRunsReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use ListNodeRunsReplyPb.ProtoReflect.Descriptor instead.

func (*ListNodeRunsReplyPb) GetCode 

func (x *ListNodeRunsReplyPb) GetCode() LHResponseCodePb

func (*ListNodeRunsReplyPb) GetMessage 

func (x *ListNodeRunsReplyPb) GetMessage() string

func (*ListNodeRunsReplyPb) GetResults 

func (x *ListNodeRunsReplyPb) GetResults() []*NodeRunPb

func (*ListNodeRunsReplyPb) ProtoMessage 

func (*ListNodeRunsReplyPb) ProtoMessage()

func (*ListNodeRunsReplyPb) ProtoReflect 

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

func (*ListNodeRunsReplyPb) Reset 

func (x *ListNodeRunsReplyPb) Reset()

func (*ListNodeRunsReplyPb) String 

func (x *ListNodeRunsReplyPb) String() string

type ListTaskMetricsPb 

type ListTaskMetricsPb struct {
	LastWindowStart *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=last_window_start,json=lastWindowStart,proto3" json:"last_window_start,omitempty"`
	NumWindows      int32                  `protobuf:"varint,2,opt,name=num_windows,json=numWindows,proto3" json:"num_windows,omitempty"`
	TaskDefName     string                 `protobuf:"bytes,3,opt,name=task_def_name,json=taskDefName,proto3" json:"task_def_name,omitempty"`
	WindowLength    MetricsWindowLengthPb  `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListTaskMetricsPb) Descriptor deprecated 

func (*ListTaskMetricsPb) Descriptor() ([]byte, []int)

Deprecated: Use ListTaskMetricsPb.ProtoReflect.Descriptor instead.

func (*ListTaskMetricsPb) GetLastWindowStart 

func (x *ListTaskMetricsPb) GetLastWindowStart() *timestamppb.Timestamp

func (*ListTaskMetricsPb) GetNumWindows 

func (x *ListTaskMetricsPb) GetNumWindows() int32

func (*ListTaskMetricsPb) GetTaskDefName 

func (x *ListTaskMetricsPb) GetTaskDefName() string

func (*ListTaskMetricsPb) GetWindowLength 

func (x *ListTaskMetricsPb) GetWindowLength() MetricsWindowLengthPb

func (*ListTaskMetricsPb) ProtoMessage 

func (*ListTaskMetricsPb) ProtoMessage()

func (*ListTaskMetricsPb) ProtoReflect 

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

func (*ListTaskMetricsPb) Reset 

func (x *ListTaskMetricsPb) Reset()

func (*ListTaskMetricsPb) String 

func (x *ListTaskMetricsPb) String() string

type ListTaskMetricsReplyPb 

type ListTaskMetricsReplyPb struct {
	Code    LHResponseCodePb    `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message *string             `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	Results []*TaskDefMetricsPb `protobuf:"bytes,3,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTaskMetricsReplyPb) Descriptor deprecated 

func (*ListTaskMetricsReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use ListTaskMetricsReplyPb.ProtoReflect.Descriptor instead.

func (*ListTaskMetricsReplyPb) GetCode 

func (x *ListTaskMetricsReplyPb) GetCode() LHResponseCodePb

func (*ListTaskMetricsReplyPb) GetMessage 

func (x *ListTaskMetricsReplyPb) GetMessage() string

func (*ListTaskMetricsReplyPb) GetResults 

func (x *ListTaskMetricsReplyPb) GetResults() []*TaskDefMetricsPb

func (*ListTaskMetricsReplyPb) ProtoMessage 

func (*ListTaskMetricsReplyPb) ProtoMessage()

func (*ListTaskMetricsReplyPb) ProtoReflect 

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

func (*ListTaskMetricsReplyPb) Reset 

func (x *ListTaskMetricsReplyPb) Reset()

func (*ListTaskMetricsReplyPb) String 

func (x *ListTaskMetricsReplyPb) String() string

type ListVariablesPb 

type ListVariablesPb struct {
	WfRunId string `protobuf:"bytes,1,opt,name=wf_run_id,json=wfRunId,proto3" json:"wf_run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListVariablesPb) Descriptor deprecated 

func (*ListVariablesPb) Descriptor() ([]byte, []int)

Deprecated: Use ListVariablesPb.ProtoReflect.Descriptor instead.

func (*ListVariablesPb) GetWfRunId 

func (x *ListVariablesPb) GetWfRunId() string

func (*ListVariablesPb) ProtoMessage 

func (*ListVariablesPb) ProtoMessage()

func (*ListVariablesPb) ProtoReflect 

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

func (*ListVariablesPb) Reset 

func (x *ListVariablesPb) Reset()

func (*ListVariablesPb) String 

func (x *ListVariablesPb) String() string

type ListVariablesReplyPb 

type ListVariablesReplyPb struct {
	Code    LHResponseCodePb `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message *string          `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	Results []*VariablePb    `protobuf:"bytes,3,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*ListVariablesReplyPb) Descriptor deprecated 

func (*ListVariablesReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use ListVariablesReplyPb.ProtoReflect.Descriptor instead.

func (*ListVariablesReplyPb) GetCode 

func (x *ListVariablesReplyPb) GetCode() LHResponseCodePb

func (*ListVariablesReplyPb) GetMessage 

func (x *ListVariablesReplyPb) GetMessage() string

func (*ListVariablesReplyPb) GetResults 

func (x *ListVariablesReplyPb) GetResults() []*VariablePb

func (*ListVariablesReplyPb) ProtoMessage 

func (*ListVariablesReplyPb) ProtoMessage()

func (*ListVariablesReplyPb) ProtoReflect 

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

func (*ListVariablesReplyPb) Reset 

func (x *ListVariablesReplyPb) Reset()

func (*ListVariablesReplyPb) String 

func (x *ListVariablesReplyPb) String() string

type ListWfMetricsPb 

type ListWfMetricsPb struct {
	LastWindowStart *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=last_window_start,json=lastWindowStart,proto3" json:"last_window_start,omitempty"`
	NumWindows      int32                  `protobuf:"varint,2,opt,name=num_windows,json=numWindows,proto3" json:"num_windows,omitempty"`
	WfSpecName      string                 `protobuf:"bytes,3,opt,name=wf_spec_name,json=wfSpecName,proto3" json:"wf_spec_name,omitempty"`
	WfSpecVersion   int32                  `protobuf:"varint,4,opt,name=wf_spec_version,json=wfSpecVersion,proto3" json:"wf_spec_version,omitempty"`
	WindowLength    MetricsWindowLengthPb  `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListWfMetricsPb) Descriptor deprecated 

func (*ListWfMetricsPb) Descriptor() ([]byte, []int)

Deprecated: Use ListWfMetricsPb.ProtoReflect.Descriptor instead.

func (*ListWfMetricsPb) GetLastWindowStart 

func (x *ListWfMetricsPb) GetLastWindowStart() *timestamppb.Timestamp

func (*ListWfMetricsPb) GetNumWindows 

func (x *ListWfMetricsPb) GetNumWindows() int32

func (*ListWfMetricsPb) GetWfSpecName 

func (x *ListWfMetricsPb) GetWfSpecName() string

func (*ListWfMetricsPb) GetWfSpecVersion 

func (x *ListWfMetricsPb) GetWfSpecVersion() int32

func (*ListWfMetricsPb) GetWindowLength 

func (x *ListWfMetricsPb) GetWindowLength() MetricsWindowLengthPb

func (*ListWfMetricsPb) ProtoMessage 

func (*ListWfMetricsPb) ProtoMessage()

func (*ListWfMetricsPb) ProtoReflect 

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

func (*ListWfMetricsPb) Reset 

func (x *ListWfMetricsPb) Reset()

func (*ListWfMetricsPb) String 

func (x *ListWfMetricsPb) String() string

type ListWfMetricsReplyPb 

type ListWfMetricsReplyPb struct {
	Code    LHResponseCodePb   `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message *string            `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	Results []*WfSpecMetricsPb `protobuf:"bytes,3,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*ListWfMetricsReplyPb) Descriptor deprecated 

func (*ListWfMetricsReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use ListWfMetricsReplyPb.ProtoReflect.Descriptor instead.

func (*ListWfMetricsReplyPb) GetCode 

func (x *ListWfMetricsReplyPb) GetCode() LHResponseCodePb

func (*ListWfMetricsReplyPb) GetMessage 

func (x *ListWfMetricsReplyPb) GetMessage() string

func (*ListWfMetricsReplyPb) GetResults 

func (x *ListWfMetricsReplyPb) GetResults() []*WfSpecMetricsPb

func (*ListWfMetricsReplyPb) ProtoMessage 

func (*ListWfMetricsReplyPb) ProtoMessage()

func (*ListWfMetricsReplyPb) ProtoReflect 

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

func (*ListWfMetricsReplyPb) Reset 

func (x *ListWfMetricsReplyPb) Reset()

func (*ListWfMetricsReplyPb) String 

func (x *ListWfMetricsReplyPb) String() string

type ManualHaltPb 

type ManualHaltPb struct {

	// Nothing to store.
	MeaningOfLife bool `protobuf:"varint,137,opt,name=meaning_of_life,json=meaningOfLife,proto3" json:"meaning_of_life,omitempty"`
	// contains filtered or unexported fields
}

func (*ManualHaltPb) Descriptor deprecated 

func (*ManualHaltPb) Descriptor() ([]byte, []int)

Deprecated: Use ManualHaltPb.ProtoReflect.Descriptor instead.

func (*ManualHaltPb) GetMeaningOfLife 

func (x *ManualHaltPb) GetMeaningOfLife() bool

func (*ManualHaltPb) ProtoMessage 

func (*ManualHaltPb) ProtoMessage()

func (*ManualHaltPb) ProtoReflect 

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

func (*ManualHaltPb) Reset 

func (x *ManualHaltPb) Reset()

func (*ManualHaltPb) String 

func (x *ManualHaltPb) String() string

type MetricsWindowLengthPb 

type MetricsWindowLengthPb int32

Metrics 

const (
	MetricsWindowLengthPb_MINUTES_5 MetricsWindowLengthPb = 0
	MetricsWindowLengthPb_HOURS_2   MetricsWindowLengthPb = 1
	MetricsWindowLengthPb_DAYS_1    MetricsWindowLengthPb = 2
)

func (MetricsWindowLengthPb) Descriptor 

func (MetricsWindowLengthPb) Descriptor() protoreflect.EnumDescriptor

func (MetricsWindowLengthPb) Enum 

func (x MetricsWindowLengthPb) Enum() *MetricsWindowLengthPb

func (MetricsWindowLengthPb) EnumDescriptor deprecated 

func (MetricsWindowLengthPb) EnumDescriptor() ([]byte, []int)

Deprecated: Use MetricsWindowLengthPb.Descriptor instead.

func (MetricsWindowLengthPb) Number 

func (x MetricsWindowLengthPb) Number() protoreflect.EnumNumber

func (MetricsWindowLengthPb) String 

func (x MetricsWindowLengthPb) String() string

func (MetricsWindowLengthPb) Type 

func (MetricsWindowLengthPb) Type() protoreflect.EnumType

type NodePb 

type NodePb struct {
	OutgoingEdges     []*EdgePb              `protobuf:"bytes,1,rep,name=outgoing_edges,json=outgoingEdges,proto3" json:"outgoing_edges,omitempty"`
	VariableMutations []*VariableMutationPb  `protobuf:"bytes,2,rep,name=variable_mutations,json=variableMutations,proto3" json:"variable_mutations,omitempty"`
	FailureHandlers   []*FailureHandlerDefPb `protobuf:"bytes,4,rep,name=failure_handlers,json=failureHandlers,proto3" json:"failure_handlers,omitempty"`
	// Types that are assignable to Node:
	//
	//	*NodePb_Entrypoint
	//	*NodePb_Exit
	//	*NodePb_Task
	//	*NodePb_ExternalEvent
	//	*NodePb_StartThread
	//	*NodePb_WaitForThread
	//	*NodePb_Nop
	//	*NodePb_Sleep
	Node isNodePb_Node `protobuf_oneof:"node"`
	// contains filtered or unexported fields
}

func (*NodePb) Descriptor deprecated 

func (*NodePb) Descriptor() ([]byte, []int)

Deprecated: Use NodePb.ProtoReflect.Descriptor instead.

func (*NodePb) GetEntrypoint 

func (x *NodePb) GetEntrypoint() *EntrypointNodePb

func (*NodePb) GetExit 

func (x *NodePb) GetExit() *ExitNodePb

func (*NodePb) GetExternalEvent 

func (x *NodePb) GetExternalEvent() *ExternalEventNodePb

func (*NodePb) GetFailureHandlers 

func (x *NodePb) GetFailureHandlers() []*FailureHandlerDefPb

func (*NodePb) GetNode 

func (m *NodePb) GetNode() isNodePb_Node

func (*NodePb) GetNop 

func (x *NodePb) GetNop() *NopNodePb

func (*NodePb) GetOutgoingEdges 

func (x *NodePb) GetOutgoingEdges() []*EdgePb

func (*NodePb) GetSleep 

func (x *NodePb) GetSleep() *SleepNodePb

func (*NodePb) GetStartThread 

func (x *NodePb) GetStartThread() *StartThreadNodePb

func (*NodePb) GetTask 

func (x *NodePb) GetTask() *TaskNodePb

func (*NodePb) GetVariableMutations 

func (x *NodePb) GetVariableMutations() []*VariableMutationPb

func (*NodePb) GetWaitForThread 

func (x *NodePb) GetWaitForThread() *WaitForThreadNodePb

func (*NodePb) ProtoMessage 

func (*NodePb) ProtoMessage()

func (*NodePb) ProtoReflect 

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

func (*NodePb) Reset 

func (x *NodePb) Reset()

func (*NodePb) String 

func (x *NodePb) String() string

type NodePb_Entrypoint 

type NodePb_Entrypoint struct {
	Entrypoint *EntrypointNodePb `protobuf:"bytes,5,opt,name=entrypoint,proto3,oneof"`
}

type NodePb_Exit 

type NodePb_Exit struct {
	Exit *ExitNodePb `protobuf:"bytes,6,opt,name=exit,proto3,oneof"`
}

type NodePb_ExternalEvent 

type NodePb_ExternalEvent struct {
	ExternalEvent *ExternalEventNodePb `protobuf:"bytes,8,opt,name=external_event,json=externalEvent,proto3,oneof"`
}

type NodePb_Nop 

type NodePb_Nop struct {
	Nop *NopNodePb `protobuf:"bytes,11,opt,name=nop,proto3,oneof"`
}

type NodePb_Sleep 

type NodePb_Sleep struct {
	Sleep *SleepNodePb `protobuf:"bytes,12,opt,name=sleep,proto3,oneof"`
}

type NodePb_StartThread 

type NodePb_StartThread struct {
	StartThread *StartThreadNodePb `protobuf:"bytes,9,opt,name=start_thread,json=startThread,proto3,oneof"`
}

type NodePb_Task 

type NodePb_Task struct {
	Task *TaskNodePb `protobuf:"bytes,7,opt,name=task,proto3,oneof"`
}

type NodePb_WaitForThread 

type NodePb_WaitForThread struct {
	WaitForThread *WaitForThreadNodePb `protobuf:"bytes,10,opt,name=wait_for_thread,json=waitForThread,proto3,oneof"`
}

type NodeRunIdPb 

type NodeRunIdPb struct {
	WfRunId         string `protobuf:"bytes,1,opt,name=wf_run_id,json=wfRunId,proto3" json:"wf_run_id,omitempty"`
	ThreadRunNumber int32  `protobuf:"varint,2,opt,name=thread_run_number,json=threadRunNumber,proto3" json:"thread_run_number,omitempty"`
	Position        int32  `protobuf:"varint,3,opt,name=position,proto3" json:"position,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeRunIdPb) Descriptor deprecated 

func (*NodeRunIdPb) Descriptor() ([]byte, []int)

Deprecated: Use NodeRunIdPb.ProtoReflect.Descriptor instead.

func (*NodeRunIdPb) GetPosition 

func (x *NodeRunIdPb) GetPosition() int32

func (*NodeRunIdPb) GetThreadRunNumber 

func (x *NodeRunIdPb) GetThreadRunNumber() int32

func (*NodeRunIdPb) GetWfRunId 

func (x *NodeRunIdPb) GetWfRunId() string

func (*NodeRunIdPb) ProtoMessage 

func (*NodeRunIdPb) ProtoMessage()

func (*NodeRunIdPb) ProtoReflect 

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

func (*NodeRunIdPb) Reset 

func (x *NodeRunIdPb) Reset()

func (*NodeRunIdPb) String 

func (x *NodeRunIdPb) String() string

type NodeRunPb 

type NodeRunPb struct {
	WfRunId         string                 `protobuf:"bytes,1,opt,name=wf_run_id,json=wfRunId,proto3" json:"wf_run_id,omitempty"`
	ThreadRunNumber int32                  `protobuf:"varint,2,opt,name=thread_run_number,json=threadRunNumber,proto3" json:"thread_run_number,omitempty"`
	Position        int32                  `protobuf:"varint,3,opt,name=position,proto3" json:"position,omitempty"`
	AttemptNumber   int32                  `protobuf:"varint,4,opt,name=attempt_number,json=attemptNumber,proto3" json:"attempt_number,omitempty"`
	Number          int32                  `protobuf:"varint,5,opt,name=number,proto3" json:"number,omitempty"`
	Status          LHStatusPb             `protobuf:"varint,6,opt,name=status,proto3,enum=littlehorse.LHStatusPb" json:"status,omitempty"`
	ArrivalTime     *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=arrival_time,json=arrivalTime,proto3" json:"arrival_time,omitempty"`
	EndTime         *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=end_time,json=endTime,proto3,oneof" json:"end_time,omitempty"`
	WfSpecId        string                 `protobuf:"bytes,9,opt,name=wf_spec_id,json=wfSpecId,proto3" json:"wf_spec_id,omitempty"`
	ThreadSpecName  string                 `protobuf:"bytes,10,opt,name=thread_spec_name,json=threadSpecName,proto3" json:"thread_spec_name,omitempty"`
	NodeName        string                 `protobuf:"bytes,11,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	ResultCode      *TaskResultCodePb      `` /* 133-byte string literal not displayed */
	ErrorMessage    *string                `protobuf:"bytes,13,opt,name=error_message,json=errorMessage,proto3,oneof" json:"error_message,omitempty"`
	Failures        []*FailurePb           `protobuf:"bytes,14,rep,name=failures,proto3" json:"failures,omitempty"`
	// Types that are assignable to NodeType:
	//
	//	*NodeRunPb_Task
	//	*NodeRunPb_ExternalEvent
	//	*NodeRunPb_Entrypoint
	//	*NodeRunPb_Exit
	//	*NodeRunPb_StartThread
	//	*NodeRunPb_WaitThread
	//	*NodeRunPb_Sleep
	NodeType          isNodeRunPb_NodeType `protobuf_oneof:"node_type"`
	FailureHandlerIds []int32              `protobuf:"varint,23,rep,packed,name=failure_handler_ids,json=failureHandlerIds,proto3" json:"failure_handler_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeRunPb) Descriptor deprecated 

func (*NodeRunPb) Descriptor() ([]byte, []int)

Deprecated: Use NodeRunPb.ProtoReflect.Descriptor instead.

func (*NodeRunPb) GetArrivalTime 

func (x *NodeRunPb) GetArrivalTime() *timestamppb.Timestamp

func (*NodeRunPb) GetAttemptNumber 

func (x *NodeRunPb) GetAttemptNumber() int32

func (*NodeRunPb) GetEndTime 

func (x *NodeRunPb) GetEndTime() *timestamppb.Timestamp

func (*NodeRunPb) GetEntrypoint 

func (x *NodeRunPb) GetEntrypoint() *EntrypointRunPb

func (*NodeRunPb) GetErrorMessage 

func (x *NodeRunPb) GetErrorMessage() string

func (*NodeRunPb) GetExit 

func (x *NodeRunPb) GetExit() *ExitRunPb

func (*NodeRunPb) GetExternalEvent 

func (x *NodeRunPb) GetExternalEvent() *ExternalEventRunPb

func (*NodeRunPb) GetFailureHandlerIds 

func (x *NodeRunPb) GetFailureHandlerIds() []int32

func (*NodeRunPb) GetFailures 

func (x *NodeRunPb) GetFailures() []*FailurePb

func (*NodeRunPb) GetNodeName 

func (x *NodeRunPb) GetNodeName() string

func (*NodeRunPb) GetNodeType 

func (m *NodeRunPb) GetNodeType() isNodeRunPb_NodeType

func (*NodeRunPb) GetNumber 

func (x *NodeRunPb) GetNumber() int32

func (*NodeRunPb) GetPosition 

func (x *NodeRunPb) GetPosition() int32

func (*NodeRunPb) GetResultCode 

func (x *NodeRunPb) GetResultCode() TaskResultCodePb

func (*NodeRunPb) GetSleep 

func (x *NodeRunPb) GetSleep() *SleepNodeRunPb

func (*NodeRunPb) GetStartThread 

func (x *NodeRunPb) GetStartThread() *StartThreadRunPb

func (*NodeRunPb) GetStatus 

func (x *NodeRunPb) GetStatus() LHStatusPb

func (*NodeRunPb) GetTask 

func (x *NodeRunPb) GetTask() *TaskRunPb

func (*NodeRunPb) GetThreadRunNumber 

func (x *NodeRunPb) GetThreadRunNumber() int32

func (*NodeRunPb) GetThreadSpecName 

func (x *NodeRunPb) GetThreadSpecName() string

func (*NodeRunPb) GetWaitThread 

func (x *NodeRunPb) GetWaitThread() *WaitThreadRunPb

func (*NodeRunPb) GetWfRunId 

func (x *NodeRunPb) GetWfRunId() string

func (*NodeRunPb) GetWfSpecId 

func (x *NodeRunPb) GetWfSpecId() string

func (*NodeRunPb) ProtoMessage 

func (*NodeRunPb) ProtoMessage()

func (*NodeRunPb) ProtoReflect 

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

func (*NodeRunPb) Reset 

func (x *NodeRunPb) Reset()

func (*NodeRunPb) String 

func (x *NodeRunPb) String() string

type NodeRunPb_Entrypoint 

type NodeRunPb_Entrypoint struct {
	Entrypoint *EntrypointRunPb `protobuf:"bytes,17,opt,name=entrypoint,proto3,oneof"`
}

type NodeRunPb_Exit 

type NodeRunPb_Exit struct {
	Exit *ExitRunPb `protobuf:"bytes,19,opt,name=exit,proto3,oneof"`
}

type NodeRunPb_ExternalEvent 

type NodeRunPb_ExternalEvent struct {
	ExternalEvent *ExternalEventRunPb `protobuf:"bytes,16,opt,name=external_event,json=externalEvent,proto3,oneof"`
}

type NodeRunPb_Sleep 

type NodeRunPb_Sleep struct {
	Sleep *SleepNodeRunPb `protobuf:"bytes,22,opt,name=sleep,proto3,oneof"`
}

type NodeRunPb_StartThread 

type NodeRunPb_StartThread struct {
	StartThread *StartThreadRunPb `protobuf:"bytes,20,opt,name=start_thread,json=startThread,proto3,oneof"`
}

type NodeRunPb_Task 

type NodeRunPb_Task struct {
	Task *TaskRunPb `protobuf:"bytes,15,opt,name=task,proto3,oneof"`
}

type NodeRunPb_WaitThread 

type NodeRunPb_WaitThread struct {
	WaitThread *WaitThreadRunPb `protobuf:"bytes,21,opt,name=wait_thread,json=waitThread,proto3,oneof"`
}

type NopNodePb 

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

func (*NopNodePb) Descriptor deprecated 

func (*NopNodePb) Descriptor() ([]byte, []int)

Deprecated: Use NopNodePb.ProtoReflect.Descriptor instead.

func (*NopNodePb) ProtoMessage 

func (*NopNodePb) ProtoMessage()

func (*NopNodePb) ProtoReflect 

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

func (*NopNodePb) Reset 

func (x *NopNodePb) Reset()

func (*NopNodePb) String 

func (x *NopNodePb) String() string

type ObservabilityEventPb 

type ObservabilityEventPb struct {
	WfRunId string                 `protobuf:"bytes,1,opt,name=wf_run_id,json=wfRunId,proto3" json:"wf_run_id,omitempty"`
	Time    *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// Types that are assignable to Event:
	//
	//	*ObservabilityEventPb_WfRunStart
	//	*ObservabilityEventPb_ThreadStart
	//	*ObservabilityEventPb_TaskScheduled
	//	*ObservabilityEventPb_TaskStart
	//	*ObservabilityEventPb_TaskResult
	//	*ObservabilityEventPb_ExtEvtRegistered
	//	*ObservabilityEventPb_WaitingForExtEvt
	//	*ObservabilityEventPb_ExtEvtMatched
	//	*ObservabilityEventPb_Interrupted
	//	*ObservabilityEventPb_ThreadStatus
	//	*ObservabilityEventPb_WfRunStatus
	Event isObservabilityEventPb_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

Observability Events

func (*ObservabilityEventPb) Descriptor deprecated 

func (*ObservabilityEventPb) Descriptor() ([]byte, []int)

Deprecated: Use ObservabilityEventPb.ProtoReflect.Descriptor instead.

func (*ObservabilityEventPb) GetEvent 

func (m *ObservabilityEventPb) GetEvent() isObservabilityEventPb_Event

func (*ObservabilityEventPb) GetExtEvtMatched 

func (x *ObservabilityEventPb) GetExtEvtMatched() *ExtEvtMatchedOePb

func (*ObservabilityEventPb) GetExtEvtRegistered 

func (x *ObservabilityEventPb) GetExtEvtRegistered() *ExtEvtRegisteredOePb

func (*ObservabilityEventPb) GetInterrupted 

func (x *ObservabilityEventPb) GetInterrupted() *InterruptedOePb

func (*ObservabilityEventPb) GetTaskResult 

func (x *ObservabilityEventPb) GetTaskResult() *TaskResultOePb

func (*ObservabilityEventPb) GetTaskScheduled 

func (x *ObservabilityEventPb) GetTaskScheduled() *TaskScheduledOePb

func (*ObservabilityEventPb) GetTaskStart 

func (x *ObservabilityEventPb) GetTaskStart() *TaskStartOePb

func (*ObservabilityEventPb) GetThreadStart 

func (x *ObservabilityEventPb) GetThreadStart() *ThreadStartOePb

func (*ObservabilityEventPb) GetThreadStatus 

func (x *ObservabilityEventPb) GetThreadStatus() *ThreadStatusOePb

func (*ObservabilityEventPb) GetTime 

func (x *ObservabilityEventPb) GetTime() *timestamppb.Timestamp

func (*ObservabilityEventPb) GetWaitingForExtEvt 

func (x *ObservabilityEventPb) GetWaitingForExtEvt() *WaitingForExtEvtOePb

func (*ObservabilityEventPb) GetWfRunId 

func (x *ObservabilityEventPb) GetWfRunId() string

func (*ObservabilityEventPb) GetWfRunStart 

func (x *ObservabilityEventPb) GetWfRunStart() *WfRunStartOePb

func (*ObservabilityEventPb) GetWfRunStatus 

func (x *ObservabilityEventPb) GetWfRunStatus() *WfRunStatusOePb

func (*ObservabilityEventPb) ProtoMessage 

func (*ObservabilityEventPb) ProtoMessage()

func (*ObservabilityEventPb) ProtoReflect 

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

func (*ObservabilityEventPb) Reset 

func (x *ObservabilityEventPb) Reset()

func (*ObservabilityEventPb) String 

func (x *ObservabilityEventPb) String() string

type ObservabilityEventPb_ExtEvtMatched 

type ObservabilityEventPb_ExtEvtMatched struct {
	ExtEvtMatched *ExtEvtMatchedOePb `protobuf:"bytes,10,opt,name=ext_evt_matched,json=extEvtMatched,proto3,oneof"`
}

type ObservabilityEventPb_ExtEvtRegistered 

type ObservabilityEventPb_ExtEvtRegistered struct {
	ExtEvtRegistered *ExtEvtRegisteredOePb `protobuf:"bytes,8,opt,name=ext_evt_registered,json=extEvtRegistered,proto3,oneof"`
}

type ObservabilityEventPb_Interrupted 

type ObservabilityEventPb_Interrupted struct {
	Interrupted *InterruptedOePb `protobuf:"bytes,11,opt,name=interrupted,proto3,oneof"`
}

type ObservabilityEventPb_TaskResult 

type ObservabilityEventPb_TaskResult struct {
	TaskResult *TaskResultOePb `protobuf:"bytes,7,opt,name=task_result,json=taskResult,proto3,oneof"`
}

type ObservabilityEventPb_TaskScheduled 

type ObservabilityEventPb_TaskScheduled struct {
	TaskScheduled *TaskScheduledOePb `protobuf:"bytes,5,opt,name=task_scheduled,json=taskScheduled,proto3,oneof"`
}

type ObservabilityEventPb_TaskStart 

type ObservabilityEventPb_TaskStart struct {
	TaskStart *TaskStartOePb `protobuf:"bytes,6,opt,name=task_start,json=taskStart,proto3,oneof"`
}

type ObservabilityEventPb_ThreadStart 

type ObservabilityEventPb_ThreadStart struct {
	ThreadStart *ThreadStartOePb `protobuf:"bytes,4,opt,name=thread_start,json=threadStart,proto3,oneof"`
}

type ObservabilityEventPb_ThreadStatus 

type ObservabilityEventPb_ThreadStatus struct {
	ThreadStatus *ThreadStatusOePb `protobuf:"bytes,12,opt,name=thread_status,json=threadStatus,proto3,oneof"`
}

type ObservabilityEventPb_WaitingForExtEvt 

type ObservabilityEventPb_WaitingForExtEvt struct {
	WaitingForExtEvt *WaitingForExtEvtOePb `protobuf:"bytes,9,opt,name=waiting_for_ext_evt,json=waitingForExtEvt,proto3,oneof"`
}

type ObservabilityEventPb_WfRunStart 

type ObservabilityEventPb_WfRunStart struct {
	WfRunStart *WfRunStartOePb `protobuf:"bytes,3,opt,name=wf_run_start,json=wfRunStart,proto3,oneof"`
}

type ObservabilityEventPb_WfRunStatus 

type ObservabilityEventPb_WfRunStatus struct {
	WfRunStatus *WfRunStatusOePb `protobuf:"bytes,13,opt,name=wf_run_status,json=wfRunStatus,proto3,oneof"`
}

type OutputSchemaPb 

type OutputSchemaPb struct {
	OutputType VariableTypePb `protobuf:"varint,1,opt,name=output_type,json=outputType,proto3,enum=littlehorse.VariableTypePb" json:"output_type,omitempty"`
	// contains filtered or unexported fields
}

TaskDef

func (*OutputSchemaPb) Descriptor deprecated 

func (*OutputSchemaPb) Descriptor() ([]byte, []int)

Deprecated: Use OutputSchemaPb.ProtoReflect.Descriptor instead.

func (*OutputSchemaPb) GetOutputType 

func (x *OutputSchemaPb) GetOutputType() VariableTypePb

func (*OutputSchemaPb) ProtoMessage 

func (*OutputSchemaPb) ProtoMessage()

func (*OutputSchemaPb) ProtoReflect 

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

func (*OutputSchemaPb) Reset 

func (x *OutputSchemaPb) Reset()

func (*OutputSchemaPb) String 

func (x *OutputSchemaPb) String() string

type ParentHaltedPb 

type ParentHaltedPb struct {
	ParentThreadId int32 `protobuf:"varint,1,opt,name=parent_thread_id,json=parentThreadId,proto3" json:"parent_thread_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ParentHaltedPb) Descriptor deprecated 

func (*ParentHaltedPb) Descriptor() ([]byte, []int)

Deprecated: Use ParentHaltedPb.ProtoReflect.Descriptor instead.

func (*ParentHaltedPb) GetParentThreadId 

func (x *ParentHaltedPb) GetParentThreadId() int32

func (*ParentHaltedPb) ProtoMessage 

func (*ParentHaltedPb) ProtoMessage()

func (*ParentHaltedPb) ProtoReflect 

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

func (*ParentHaltedPb) Reset 

func (x *ParentHaltedPb) Reset()

func (*ParentHaltedPb) String 

func (x *ParentHaltedPb) String() string

type PendingFailureHandlerHaltReasonPb 

type PendingFailureHandlerHaltReasonPb struct {
	NodeRunPosition int32 `protobuf:"varint,1,opt,name=node_run_position,json=nodeRunPosition,proto3" json:"node_run_position,omitempty"`
	// contains filtered or unexported fields
}

func (*PendingFailureHandlerHaltReasonPb) Descriptor deprecated 

func (*PendingFailureHandlerHaltReasonPb) Descriptor() ([]byte, []int)

Deprecated: Use PendingFailureHandlerHaltReasonPb.ProtoReflect.Descriptor instead.

func (*PendingFailureHandlerHaltReasonPb) GetNodeRunPosition 

func (x *PendingFailureHandlerHaltReasonPb) GetNodeRunPosition() int32

func (*PendingFailureHandlerHaltReasonPb) ProtoMessage 

func (*PendingFailureHandlerHaltReasonPb) ProtoMessage()

func (*PendingFailureHandlerHaltReasonPb) ProtoReflect 

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

func (*PendingFailureHandlerHaltReasonPb) Reset 

func (x *PendingFailureHandlerHaltReasonPb) Reset()

func (*PendingFailureHandlerHaltReasonPb) String 

func (x *PendingFailureHandlerHaltReasonPb) String() string

type PendingFailureHandlerPb 

type PendingFailureHandlerPb struct {
	FailedThreadRun int32  `protobuf:"varint,1,opt,name=failed_thread_run,json=failedThreadRun,proto3" json:"failed_thread_run,omitempty"`
	HandlerSpecName string `protobuf:"bytes,2,opt,name=handler_spec_name,json=handlerSpecName,proto3" json:"handler_spec_name,omitempty"`
	// contains filtered or unexported fields
}

func (*PendingFailureHandlerPb) Descriptor deprecated 

func (*PendingFailureHandlerPb) Descriptor() ([]byte, []int)

Deprecated: Use PendingFailureHandlerPb.ProtoReflect.Descriptor instead.

func (*PendingFailureHandlerPb) GetFailedThreadRun 

func (x *PendingFailureHandlerPb) GetFailedThreadRun() int32

func (*PendingFailureHandlerPb) GetHandlerSpecName 

func (x *PendingFailureHandlerPb) GetHandlerSpecName() string

func (*PendingFailureHandlerPb) ProtoMessage 

func (*PendingFailureHandlerPb) ProtoMessage()

func (*PendingFailureHandlerPb) ProtoReflect 

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

func (*PendingFailureHandlerPb) Reset 

func (x *PendingFailureHandlerPb) Reset()

func (*PendingFailureHandlerPb) String 

func (x *PendingFailureHandlerPb) String() string

type PendingInterruptHaltReasonPb 

type PendingInterruptHaltReasonPb struct {
	ExternalEventId *ExternalEventIdPb `protobuf:"bytes,1,opt,name=external_event_id,json=externalEventId,proto3" json:"external_event_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PendingInterruptHaltReasonPb) Descriptor deprecated 

func (*PendingInterruptHaltReasonPb) Descriptor() ([]byte, []int)

Deprecated: Use PendingInterruptHaltReasonPb.ProtoReflect.Descriptor instead.

func (*PendingInterruptHaltReasonPb) GetExternalEventId 

func (x *PendingInterruptHaltReasonPb) GetExternalEventId() *ExternalEventIdPb

func (*PendingInterruptHaltReasonPb) ProtoMessage 

func (*PendingInterruptHaltReasonPb) ProtoMessage()

func (*PendingInterruptHaltReasonPb) ProtoReflect 

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

func (*PendingInterruptHaltReasonPb) Reset 

func (x *PendingInterruptHaltReasonPb) Reset()

func (*PendingInterruptHaltReasonPb) String 

func (x *PendingInterruptHaltReasonPb) String() string

type PendingInterruptPb 

type PendingInterruptPb struct {
	ExternalEventId     *ExternalEventIdPb `protobuf:"bytes,1,opt,name=external_event_id,json=externalEventId,proto3" json:"external_event_id,omitempty"`
	HandlerSpecName     string             `protobuf:"bytes,2,opt,name=handler_spec_name,json=handlerSpecName,proto3" json:"handler_spec_name,omitempty"`
	InterruptedThreadId int32              `protobuf:"varint,3,opt,name=interrupted_thread_id,json=interruptedThreadId,proto3" json:"interrupted_thread_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PendingInterruptPb) Descriptor deprecated 

func (*PendingInterruptPb) Descriptor() ([]byte, []int)

Deprecated: Use PendingInterruptPb.ProtoReflect.Descriptor instead.

func (*PendingInterruptPb) GetExternalEventId 

func (x *PendingInterruptPb) GetExternalEventId() *ExternalEventIdPb

func (*PendingInterruptPb) GetHandlerSpecName 

func (x *PendingInterruptPb) GetHandlerSpecName() string

func (*PendingInterruptPb) GetInterruptedThreadId 

func (x *PendingInterruptPb) GetInterruptedThreadId() int32

func (*PendingInterruptPb) ProtoMessage 

func (*PendingInterruptPb) ProtoMessage()

func (*PendingInterruptPb) ProtoReflect 

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

func (*PendingInterruptPb) Reset 

func (x *PendingInterruptPb) Reset()

func (*PendingInterruptPb) String 

func (x *PendingInterruptPb) String() string

type PollTaskPb 

type PollTaskPb struct {
	TaskDefName       string  `protobuf:"bytes,1,opt,name=task_def_name,json=taskDefName,proto3" json:"task_def_name,omitempty"`
	ClientId          string  `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	TaskWorkerVersion *string `protobuf:"bytes,3,opt,name=task_worker_version,json=taskWorkerVersion,proto3,oneof" json:"task_worker_version,omitempty"`
	// contains filtered or unexported fields
}

func (*PollTaskPb) Descriptor deprecated 

func (*PollTaskPb) Descriptor() ([]byte, []int)

Deprecated: Use PollTaskPb.ProtoReflect.Descriptor instead.

func (*PollTaskPb) GetClientId 

func (x *PollTaskPb) GetClientId() string

func (*PollTaskPb) GetTaskDefName 

func (x *PollTaskPb) GetTaskDefName() string

func (*PollTaskPb) GetTaskWorkerVersion 

func (x *PollTaskPb) GetTaskWorkerVersion() string

func (*PollTaskPb) ProtoMessage 

func (*PollTaskPb) ProtoMessage()

func (*PollTaskPb) ProtoReflect 

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

func (*PollTaskPb) Reset 

func (x *PollTaskPb) Reset()

func (*PollTaskPb) String 

func (x *PollTaskPb) String() string

type PollTaskReplyPb 

type PollTaskReplyPb struct {
	Code    LHResponseCodePb `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message *string          `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	Result  *ScheduledTaskPb `protobuf:"bytes,3,opt,name=result,proto3,oneof" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*PollTaskReplyPb) Descriptor deprecated 

func (*PollTaskReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use PollTaskReplyPb.ProtoReflect.Descriptor instead.

func (*PollTaskReplyPb) GetCode 

func (x *PollTaskReplyPb) GetCode() LHResponseCodePb

func (*PollTaskReplyPb) GetMessage 

func (x *PollTaskReplyPb) GetMessage() string

func (*PollTaskReplyPb) GetResult 

func (x *PollTaskReplyPb) GetResult() *ScheduledTaskPb

func (*PollTaskReplyPb) ProtoMessage 

func (*PollTaskReplyPb) ProtoMessage()

func (*PollTaskReplyPb) ProtoReflect 

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

func (*PollTaskReplyPb) Reset 

func (x *PollTaskReplyPb) Reset()

func (*PollTaskReplyPb) String 

func (x *PollTaskReplyPb) String() string

type PutExternalEventDefPb 

type PutExternalEventDefPb struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*PutExternalEventDefPb) Descriptor deprecated 

func (*PutExternalEventDefPb) Descriptor() ([]byte, []int)

Deprecated: Use PutExternalEventDefPb.ProtoReflect.Descriptor instead.

func (*PutExternalEventDefPb) GetName 

func (x *PutExternalEventDefPb) GetName() string

func (*PutExternalEventDefPb) ProtoMessage 

func (*PutExternalEventDefPb) ProtoMessage()

func (*PutExternalEventDefPb) ProtoReflect 

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

func (*PutExternalEventDefPb) Reset 

func (x *PutExternalEventDefPb) Reset()

func (*PutExternalEventDefPb) String 

func (x *PutExternalEventDefPb) String() string

type PutExternalEventDefReplyPb 

type PutExternalEventDefReplyPb struct {
	Code    LHResponseCodePb    `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message *string             `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	Result  *ExternalEventDefPb `protobuf:"bytes,3,opt,name=result,proto3,oneof" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*PutExternalEventDefReplyPb) Descriptor deprecated 

func (*PutExternalEventDefReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use PutExternalEventDefReplyPb.ProtoReflect.Descriptor instead.

func (*PutExternalEventDefReplyPb) GetCode 

func (x *PutExternalEventDefReplyPb) GetCode() LHResponseCodePb

func (*PutExternalEventDefReplyPb) GetMessage 

func (x *PutExternalEventDefReplyPb) GetMessage() string

func (*PutExternalEventDefReplyPb) GetResult 

func (x *PutExternalEventDefReplyPb) GetResult() *ExternalEventDefPb

func (*PutExternalEventDefReplyPb) ProtoMessage 

func (*PutExternalEventDefReplyPb) ProtoMessage()

func (*PutExternalEventDefReplyPb) ProtoReflect 

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

func (*PutExternalEventDefReplyPb) Reset 

func (x *PutExternalEventDefReplyPb) Reset()

func (*PutExternalEventDefReplyPb) String 

func (x *PutExternalEventDefReplyPb) String() string

type PutExternalEventPb 

type PutExternalEventPb struct {
	WfRunId              string           `protobuf:"bytes,1,opt,name=wf_run_id,json=wfRunId,proto3" json:"wf_run_id,omitempty"`
	ExternalEventDefName string           `protobuf:"bytes,2,opt,name=external_event_def_name,json=externalEventDefName,proto3" json:"external_event_def_name,omitempty"`
	Guid                 *string          `protobuf:"bytes,3,opt,name=guid,proto3,oneof" json:"guid,omitempty"`
	Content              *VariableValuePb `protobuf:"bytes,5,opt,name=content,proto3" json:"content,omitempty"`
	ThreadRunNumber      *int32           `protobuf:"varint,6,opt,name=thread_run_number,json=threadRunNumber,proto3,oneof" json:"thread_run_number,omitempty"`
	NodeRunPosition      *int32           `protobuf:"varint,7,opt,name=node_run_position,json=nodeRunPosition,proto3,oneof" json:"node_run_position,omitempty"`
	// contains filtered or unexported fields
}

func (*PutExternalEventPb) Descriptor deprecated 

func (*PutExternalEventPb) Descriptor() ([]byte, []int)

Deprecated: Use PutExternalEventPb.ProtoReflect.Descriptor instead.

func (*PutExternalEventPb) GetContent 

func (x *PutExternalEventPb) GetContent() *VariableValuePb

func (*PutExternalEventPb) GetExternalEventDefName 

func (x *PutExternalEventPb) GetExternalEventDefName() string

func (*PutExternalEventPb) GetGuid 

func (x *PutExternalEventPb) GetGuid() string

func (*PutExternalEventPb) GetNodeRunPosition 

func (x *PutExternalEventPb) GetNodeRunPosition() int32

func (*PutExternalEventPb) GetThreadRunNumber 

func (x *PutExternalEventPb) GetThreadRunNumber() int32

func (*PutExternalEventPb) GetWfRunId 

func (x *PutExternalEventPb) GetWfRunId() string

func (*PutExternalEventPb) ProtoMessage 

func (*PutExternalEventPb) ProtoMessage()

func (*PutExternalEventPb) ProtoReflect 

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

func (*PutExternalEventPb) Reset 

func (x *PutExternalEventPb) Reset()

func (*PutExternalEventPb) String 

func (x *PutExternalEventPb) String() string

type PutExternalEventReplyPb 

type PutExternalEventReplyPb struct {
	Code    LHResponseCodePb `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message *string          `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	Result  *ExternalEventPb `protobuf:"bytes,3,opt,name=result,proto3,oneof" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*PutExternalEventReplyPb) Descriptor deprecated 

func (*PutExternalEventReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use PutExternalEventReplyPb.ProtoReflect.Descriptor instead.

func (*PutExternalEventReplyPb) GetCode 

func (x *PutExternalEventReplyPb) GetCode() LHResponseCodePb

func (*PutExternalEventReplyPb) GetMessage 

func (x *PutExternalEventReplyPb) GetMessage() string

func (*PutExternalEventReplyPb) GetResult 

func (x *PutExternalEventReplyPb) GetResult() *ExternalEventPb

func (*PutExternalEventReplyPb) ProtoMessage 

func (*PutExternalEventReplyPb) ProtoMessage()

func (*PutExternalEventReplyPb) ProtoReflect 

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

func (*PutExternalEventReplyPb) Reset 

func (x *PutExternalEventReplyPb) Reset()

func (*PutExternalEventReplyPb) String 

func (x *PutExternalEventReplyPb) String() string

type PutTaskDefPb 

type PutTaskDefPb struct {
	Name      string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	InputVars []*VariableDefPb `protobuf:"bytes,2,rep,name=input_vars,json=inputVars,proto3" json:"input_vars,omitempty"`
	// contains filtered or unexported fields
}

func (*PutTaskDefPb) Descriptor deprecated 

func (*PutTaskDefPb) Descriptor() ([]byte, []int)

Deprecated: Use PutTaskDefPb.ProtoReflect.Descriptor instead.

func (*PutTaskDefPb) GetInputVars 

func (x *PutTaskDefPb) GetInputVars() []*VariableDefPb

func (*PutTaskDefPb) GetName 

func (x *PutTaskDefPb) GetName() string

func (*PutTaskDefPb) ProtoMessage 

func (*PutTaskDefPb) ProtoMessage()

func (*PutTaskDefPb) ProtoReflect 

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

func (*PutTaskDefPb) Reset 

func (x *PutTaskDefPb) Reset()

func (*PutTaskDefPb) String 

func (x *PutTaskDefPb) String() string

type PutTaskDefReplyPb 

type PutTaskDefReplyPb struct {
	Code    LHResponseCodePb `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message *string          `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	Result  *TaskDefPb       `protobuf:"bytes,3,opt,name=result,proto3,oneof" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*PutTaskDefReplyPb) Descriptor deprecated 

func (*PutTaskDefReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use PutTaskDefReplyPb.ProtoReflect.Descriptor instead.

func (*PutTaskDefReplyPb) GetCode 

func (x *PutTaskDefReplyPb) GetCode() LHResponseCodePb

func (*PutTaskDefReplyPb) GetMessage 

func (x *PutTaskDefReplyPb) GetMessage() string

func (*PutTaskDefReplyPb) GetResult 

func (x *PutTaskDefReplyPb) GetResult() *TaskDefPb

func (*PutTaskDefReplyPb) ProtoMessage 

func (*PutTaskDefReplyPb) ProtoMessage()

func (*PutTaskDefReplyPb) ProtoReflect 

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

func (*PutTaskDefReplyPb) Reset 

func (x *PutTaskDefReplyPb) Reset()

func (*PutTaskDefReplyPb) String 

func (x *PutTaskDefReplyPb) String() string

type PutWfSpecPb 

type PutWfSpecPb struct {
	Name                 string                   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ThreadSpecs          map[string]*ThreadSpecPb `` /* 182-byte string literal not displayed */
	EntrypointThreadName string                   `protobuf:"bytes,6,opt,name=entrypoint_thread_name,json=entrypointThreadName,proto3" json:"entrypoint_thread_name,omitempty"`
	// contains filtered or unexported fields
}

func (*PutWfSpecPb) Descriptor deprecated 

func (*PutWfSpecPb) Descriptor() ([]byte, []int)

Deprecated: Use PutWfSpecPb.ProtoReflect.Descriptor instead.

func (*PutWfSpecPb) GetEntrypointThreadName 

func (x *PutWfSpecPb) GetEntrypointThreadName() string

func (*PutWfSpecPb) GetName 

func (x *PutWfSpecPb) GetName() string

func (*PutWfSpecPb) GetThreadSpecs 

func (x *PutWfSpecPb) GetThreadSpecs() map[string]*ThreadSpecPb

func (*PutWfSpecPb) ProtoMessage 

func (*PutWfSpecPb) ProtoMessage()

func (*PutWfSpecPb) ProtoReflect 

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

func (*PutWfSpecPb) Reset 

func (x *PutWfSpecPb) Reset()

func (*PutWfSpecPb) String 

func (x *PutWfSpecPb) String() string

type PutWfSpecReplyPb 

type PutWfSpecReplyPb struct {
	Code    LHResponseCodePb `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message *string          `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	Result  *WfSpecPb        `protobuf:"bytes,3,opt,name=result,proto3,oneof" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*PutWfSpecReplyPb) Descriptor deprecated 

func (*PutWfSpecReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use PutWfSpecReplyPb.ProtoReflect.Descriptor instead.

func (*PutWfSpecReplyPb) GetCode 

func (x *PutWfSpecReplyPb) GetCode() LHResponseCodePb

func (*PutWfSpecReplyPb) GetMessage 

func (x *PutWfSpecReplyPb) GetMessage() string

func (*PutWfSpecReplyPb) GetResult 

func (x *PutWfSpecReplyPb) GetResult() *WfSpecPb

func (*PutWfSpecReplyPb) ProtoMessage 

func (*PutWfSpecReplyPb) ProtoMessage()

func (*PutWfSpecReplyPb) ProtoReflect 

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

func (*PutWfSpecReplyPb) Reset 

func (x *PutWfSpecReplyPb) Reset()

func (*PutWfSpecReplyPb) String 

func (x *PutWfSpecReplyPb) String() string

type RegisterTaskWorkerPb 

type RegisterTaskWorkerPb struct {
	ClientId     string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	TaskDefName  string `protobuf:"bytes,2,opt,name=task_def_name,json=taskDefName,proto3" json:"task_def_name,omitempty"`
	ListenerName string `protobuf:"bytes,3,opt,name=listener_name,json=listenerName,proto3" json:"listener_name,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterTaskWorkerPb) Descriptor deprecated 

func (*RegisterTaskWorkerPb) Descriptor() ([]byte, []int)

Deprecated: Use RegisterTaskWorkerPb.ProtoReflect.Descriptor instead.

func (*RegisterTaskWorkerPb) GetClientId 

func (x *RegisterTaskWorkerPb) GetClientId() string

func (*RegisterTaskWorkerPb) GetListenerName 

func (x *RegisterTaskWorkerPb) GetListenerName() string

func (*RegisterTaskWorkerPb) GetTaskDefName 

func (x *RegisterTaskWorkerPb) GetTaskDefName() string

func (*RegisterTaskWorkerPb) ProtoMessage 

func (*RegisterTaskWorkerPb) ProtoMessage()

func (*RegisterTaskWorkerPb) ProtoReflect 

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

func (*RegisterTaskWorkerPb) Reset 

func (x *RegisterTaskWorkerPb) Reset()

func (*RegisterTaskWorkerPb) String 

func (x *RegisterTaskWorkerPb) String() string

type RegisterTaskWorkerReplyPb 

type RegisterTaskWorkerReplyPb struct {
	Code      LHResponseCodePb `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message   *string          `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	YourHosts []*HostInfoPb    `protobuf:"bytes,3,rep,name=your_hosts,json=yourHosts,proto3" json:"your_hosts,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterTaskWorkerReplyPb) Descriptor deprecated 

func (*RegisterTaskWorkerReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use RegisterTaskWorkerReplyPb.ProtoReflect.Descriptor instead.

func (*RegisterTaskWorkerReplyPb) GetCode 

func (x *RegisterTaskWorkerReplyPb) GetCode() LHResponseCodePb

func (*RegisterTaskWorkerReplyPb) GetMessage 

func (x *RegisterTaskWorkerReplyPb) GetMessage() string

func (*RegisterTaskWorkerReplyPb) GetYourHosts 

func (x *RegisterTaskWorkerReplyPb) GetYourHosts() []*HostInfoPb

func (*RegisterTaskWorkerReplyPb) ProtoMessage 

func (*RegisterTaskWorkerReplyPb) ProtoMessage()

func (*RegisterTaskWorkerReplyPb) ProtoReflect 

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

func (*RegisterTaskWorkerReplyPb) Reset 

func (x *RegisterTaskWorkerReplyPb) Reset()

func (*RegisterTaskWorkerReplyPb) String 

func (x *RegisterTaskWorkerReplyPb) String() string

type ReportTaskReplyPb 

type ReportTaskReplyPb struct {
	Code    LHResponseCodePb `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message *string          `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*ReportTaskReplyPb) Descriptor deprecated 

func (*ReportTaskReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use ReportTaskReplyPb.ProtoReflect.Descriptor instead.

func (*ReportTaskReplyPb) GetCode 

func (x *ReportTaskReplyPb) GetCode() LHResponseCodePb

func (*ReportTaskReplyPb) GetMessage 

func (x *ReportTaskReplyPb) GetMessage() string

func (*ReportTaskReplyPb) ProtoMessage 

func (*ReportTaskReplyPb) ProtoMessage()

func (*ReportTaskReplyPb) ProtoReflect 

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

func (*ReportTaskReplyPb) Reset 

func (x *ReportTaskReplyPb) Reset()

func (*ReportTaskReplyPb) String 

func (x *ReportTaskReplyPb) String() string

type ResumeWfRunPb 

type ResumeWfRunPb struct {
	WfRunId         string `protobuf:"bytes,1,opt,name=wf_run_id,json=wfRunId,proto3" json:"wf_run_id,omitempty"`
	ThreadRunNumber int32  `protobuf:"varint,2,opt,name=thread_run_number,json=threadRunNumber,proto3" json:"thread_run_number,omitempty"`
	// contains filtered or unexported fields
}

func (*ResumeWfRunPb) Descriptor deprecated 

func (*ResumeWfRunPb) Descriptor() ([]byte, []int)

Deprecated: Use ResumeWfRunPb.ProtoReflect.Descriptor instead.

func (*ResumeWfRunPb) GetThreadRunNumber 

func (x *ResumeWfRunPb) GetThreadRunNumber() int32

func (*ResumeWfRunPb) GetWfRunId 

func (x *ResumeWfRunPb) GetWfRunId() string

func (*ResumeWfRunPb) ProtoMessage 

func (*ResumeWfRunPb) ProtoMessage()

func (*ResumeWfRunPb) ProtoReflect 

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

func (*ResumeWfRunPb) Reset 

func (x *ResumeWfRunPb) Reset()

func (*ResumeWfRunPb) String 

func (x *ResumeWfRunPb) String() string

type ResumeWfRunReplyPb 

type ResumeWfRunReplyPb struct {
	Code    LHResponseCodePb `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message *string          `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*ResumeWfRunReplyPb) Descriptor deprecated 

func (*ResumeWfRunReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use ResumeWfRunReplyPb.ProtoReflect.Descriptor instead.

func (*ResumeWfRunReplyPb) GetCode 

func (x *ResumeWfRunReplyPb) GetCode() LHResponseCodePb

func (*ResumeWfRunReplyPb) GetMessage 

func (x *ResumeWfRunReplyPb) GetMessage() string

func (*ResumeWfRunReplyPb) ProtoMessage 

func (*ResumeWfRunReplyPb) ProtoMessage()

func (*ResumeWfRunReplyPb) ProtoReflect 

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

func (*ResumeWfRunReplyPb) Reset 

func (x *ResumeWfRunReplyPb) Reset()

func (*ResumeWfRunReplyPb) String 

func (x *ResumeWfRunReplyPb) String() string

type RunWfPb 

type RunWfPb struct {
	WfSpecName    string                      `protobuf:"bytes,1,opt,name=wf_spec_name,json=wfSpecName,proto3" json:"wf_spec_name,omitempty"`
	WfSpecVersion *int32                      `protobuf:"varint,2,opt,name=wf_spec_version,json=wfSpecVersion,proto3,oneof" json:"wf_spec_version,omitempty"`
	Variables     map[string]*VariableValuePb `` /* 159-byte string literal not displayed */
	Id            *string                     `protobuf:"bytes,4,opt,name=id,proto3,oneof" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*RunWfPb) Descriptor deprecated 

func (*RunWfPb) Descriptor() ([]byte, []int)

Deprecated: Use RunWfPb.ProtoReflect.Descriptor instead.

func (*RunWfPb) GetId 

func (x *RunWfPb) GetId() string

func (*RunWfPb) GetVariables 

func (x *RunWfPb) GetVariables() map[string]*VariableValuePb

func (*RunWfPb) GetWfSpecName 

func (x *RunWfPb) GetWfSpecName() string

func (*RunWfPb) GetWfSpecVersion 

func (x *RunWfPb) GetWfSpecVersion() int32

func (*RunWfPb) ProtoMessage 

func (*RunWfPb) ProtoMessage()

func (*RunWfPb) ProtoReflect 

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

func (*RunWfPb) Reset 

func (x *RunWfPb) Reset()

func (*RunWfPb) String 

func (x *RunWfPb) String() string

type RunWfReplyPb 

type RunWfReplyPb struct {
	Code          LHResponseCodePb `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message       *string          `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	WfSpecVersion *int32           `protobuf:"varint,3,opt,name=wf_spec_version,json=wfSpecVersion,proto3,oneof" json:"wf_spec_version,omitempty"`
	WfRunId       *string          `protobuf:"bytes,4,opt,name=wf_run_id,json=wfRunId,proto3,oneof" json:"wf_run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RunWfReplyPb) Descriptor deprecated 

func (*RunWfReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use RunWfReplyPb.ProtoReflect.Descriptor instead.

func (*RunWfReplyPb) GetCode 

func (x *RunWfReplyPb) GetCode() LHResponseCodePb

func (*RunWfReplyPb) GetMessage 

func (x *RunWfReplyPb) GetMessage() string

func (*RunWfReplyPb) GetWfRunId 

func (x *RunWfReplyPb) GetWfRunId() string

func (*RunWfReplyPb) GetWfSpecVersion 

func (x *RunWfReplyPb) GetWfSpecVersion() int32

func (*RunWfReplyPb) ProtoMessage 

func (*RunWfReplyPb) ProtoMessage()

func (*RunWfReplyPb) ProtoReflect 

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

func (*RunWfReplyPb) Reset 

func (x *RunWfReplyPb) Reset()

func (*RunWfReplyPb) String 

func (x *RunWfReplyPb) String() string

type ScheduledTaskPb 

type ScheduledTaskPb struct {
	TaskDefId       string                 `protobuf:"bytes,1,opt,name=task_def_id,json=taskDefId,proto3" json:"task_def_id,omitempty"`
	TaskDefName     string                 `protobuf:"bytes,2,opt,name=task_def_name,json=taskDefName,proto3" json:"task_def_name,omitempty"`
	ThreadRunNumber int32                  `protobuf:"varint,4,opt,name=thread_run_number,json=threadRunNumber,proto3" json:"thread_run_number,omitempty"`
	TaskRunNumber   int32                  `protobuf:"varint,5,opt,name=task_run_number,json=taskRunNumber,proto3" json:"task_run_number,omitempty"`
	TaskRunPosition int32                  `protobuf:"varint,6,opt,name=task_run_position,json=taskRunPosition,proto3" json:"task_run_position,omitempty"`
	WfRunId         string                 `protobuf:"bytes,7,opt,name=wf_run_id,json=wfRunId,proto3" json:"wf_run_id,omitempty"`
	WfRunEventQueue string                 `protobuf:"bytes,8,opt,name=wf_run_event_queue,json=wfRunEventQueue,proto3" json:"wf_run_event_queue,omitempty"`
	WfSpecId        string                 `protobuf:"bytes,9,opt,name=wf_spec_id,json=wfSpecId,proto3" json:"wf_spec_id,omitempty"`
	AttemptNumber   int32                  `protobuf:"varint,10,opt,name=attempt_number,json=attemptNumber,proto3" json:"attempt_number,omitempty"`
	NodeName        string                 `protobuf:"bytes,11,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	Variables       []*VarNameAndValPb     `protobuf:"bytes,12,rep,name=variables,proto3" json:"variables,omitempty"`
	CreatedAt       *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*ScheduledTaskPb) Descriptor deprecated 

func (*ScheduledTaskPb) Descriptor() ([]byte, []int)

Deprecated: Use ScheduledTaskPb.ProtoReflect.Descriptor instead.

func (*ScheduledTaskPb) GetAttemptNumber 

func (x *ScheduledTaskPb) GetAttemptNumber() int32

func (*ScheduledTaskPb) GetCreatedAt 

func (x *ScheduledTaskPb) GetCreatedAt() *timestamppb.Timestamp

func (*ScheduledTaskPb) GetNodeName 

func (x *ScheduledTaskPb) GetNodeName() string

func (*ScheduledTaskPb) GetTaskDefId 

func (x *ScheduledTaskPb) GetTaskDefId() string

func (*ScheduledTaskPb) GetTaskDefName 

func (x *ScheduledTaskPb) GetTaskDefName() string

func (*ScheduledTaskPb) GetTaskRunNumber 

func (x *ScheduledTaskPb) GetTaskRunNumber() int32

func (*ScheduledTaskPb) GetTaskRunPosition 

func (x *ScheduledTaskPb) GetTaskRunPosition() int32

func (*ScheduledTaskPb) GetThreadRunNumber 

func (x *ScheduledTaskPb) GetThreadRunNumber() int32

func (*ScheduledTaskPb) GetVariables 

func (x *ScheduledTaskPb) GetVariables() []*VarNameAndValPb

func (*ScheduledTaskPb) GetWfRunEventQueue 

func (x *ScheduledTaskPb) GetWfRunEventQueue() string

func (*ScheduledTaskPb) GetWfRunId 

func (x *ScheduledTaskPb) GetWfRunId() string

func (*ScheduledTaskPb) GetWfSpecId 

func (x *ScheduledTaskPb) GetWfSpecId() string

func (*ScheduledTaskPb) ProtoMessage 

func (*ScheduledTaskPb) ProtoMessage()

func (*ScheduledTaskPb) ProtoReflect 

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

func (*ScheduledTaskPb) Reset 

func (x *ScheduledTaskPb) Reset()

func (*ScheduledTaskPb) String 

func (x *ScheduledTaskPb) String() string

type SearchExternalEventDefPb 

type SearchExternalEventDefPb struct {
	Bookmark []byte `protobuf:"bytes,1,opt,name=bookmark,proto3,oneof" json:"bookmark,omitempty"`
	Limit    *int32 `protobuf:"varint,2,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchExternalEventDefPb) Descriptor deprecated 

func (*SearchExternalEventDefPb) Descriptor() ([]byte, []int)

Deprecated: Use SearchExternalEventDefPb.ProtoReflect.Descriptor instead.

func (*SearchExternalEventDefPb) GetBookmark 

func (x *SearchExternalEventDefPb) GetBookmark() []byte

func (*SearchExternalEventDefPb) GetLimit 

func (x *SearchExternalEventDefPb) GetLimit() int32

func (*SearchExternalEventDefPb) ProtoMessage 

func (*SearchExternalEventDefPb) ProtoMessage()

func (*SearchExternalEventDefPb) ProtoReflect 

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

func (*SearchExternalEventDefPb) Reset 

func (x *SearchExternalEventDefPb) Reset()

func (*SearchExternalEventDefPb) String 

func (x *SearchExternalEventDefPb) String() string

type SearchExternalEventDefReplyPb 

type SearchExternalEventDefReplyPb struct {
	Code     LHResponseCodePb        `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message  *string                 `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	Results  []*ExternalEventDefIdPb `protobuf:"bytes,3,rep,name=results,proto3" json:"results,omitempty"`
	Bookmark []byte                  `protobuf:"bytes,4,opt,name=bookmark,proto3,oneof" json:"bookmark,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchExternalEventDefReplyPb) Descriptor deprecated 

func (*SearchExternalEventDefReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use SearchExternalEventDefReplyPb.ProtoReflect.Descriptor instead.

func (*SearchExternalEventDefReplyPb) GetBookmark 

func (x *SearchExternalEventDefReplyPb) GetBookmark() []byte

func (*SearchExternalEventDefReplyPb) GetCode 

func (x *SearchExternalEventDefReplyPb) GetCode() LHResponseCodePb

func (*SearchExternalEventDefReplyPb) GetMessage 

func (x *SearchExternalEventDefReplyPb) GetMessage() string

func (*SearchExternalEventDefReplyPb) GetResults 

func (x *SearchExternalEventDefReplyPb) GetResults() []*ExternalEventDefIdPb

func (*SearchExternalEventDefReplyPb) ProtoMessage 

func (*SearchExternalEventDefReplyPb) ProtoMessage()

func (*SearchExternalEventDefReplyPb) ProtoReflect 

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

func (*SearchExternalEventDefReplyPb) Reset 

func (x *SearchExternalEventDefReplyPb) Reset()

func (*SearchExternalEventDefReplyPb) String 

func (x *SearchExternalEventDefReplyPb) String() string

type SearchExternalEventPb 

type SearchExternalEventPb struct {
	Bookmark []byte `protobuf:"bytes,1,opt,name=bookmark,proto3,oneof" json:"bookmark,omitempty"`
	Limit    *int32 `protobuf:"varint,2,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	// Types that are assignable to ExtEvtCriteria:
	//
	//	*SearchExternalEventPb_WfRunId
	ExtEvtCriteria isSearchExternalEventPb_ExtEvtCriteria `protobuf_oneof:"ext_evt_criteria"`
	// contains filtered or unexported fields
}

func (*SearchExternalEventPb) Descriptor deprecated 

func (*SearchExternalEventPb) Descriptor() ([]byte, []int)

Deprecated: Use SearchExternalEventPb.ProtoReflect.Descriptor instead.

func (*SearchExternalEventPb) GetBookmark 

func (x *SearchExternalEventPb) GetBookmark() []byte

func (*SearchExternalEventPb) GetExtEvtCriteria 

func (m *SearchExternalEventPb) GetExtEvtCriteria() isSearchExternalEventPb_ExtEvtCriteria

func (*SearchExternalEventPb) GetLimit 

func (x *SearchExternalEventPb) GetLimit() int32

func (*SearchExternalEventPb) GetWfRunId 

func (x *SearchExternalEventPb) GetWfRunId() string

func (*SearchExternalEventPb) ProtoMessage 

func (*SearchExternalEventPb) ProtoMessage()

func (*SearchExternalEventPb) ProtoReflect 

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

func (*SearchExternalEventPb) Reset 

func (x *SearchExternalEventPb) Reset()

func (*SearchExternalEventPb) String 

func (x *SearchExternalEventPb) String() string

type SearchExternalEventPb_WfRunId 

type SearchExternalEventPb_WfRunId struct {
	WfRunId string `protobuf:"bytes,3,opt,name=wf_run_id,json=wfRunId,proto3,oneof"`
}

type SearchExternalEventReplyPb 

type SearchExternalEventReplyPb struct {
	Code     LHResponseCodePb     `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message  *string              `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	Results  []*ExternalEventIdPb `protobuf:"bytes,3,rep,name=results,proto3" json:"results,omitempty"`
	Bookmark []byte               `protobuf:"bytes,4,opt,name=bookmark,proto3,oneof" json:"bookmark,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchExternalEventReplyPb) Descriptor deprecated 

func (*SearchExternalEventReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use SearchExternalEventReplyPb.ProtoReflect.Descriptor instead.

func (*SearchExternalEventReplyPb) GetBookmark 

func (x *SearchExternalEventReplyPb) GetBookmark() []byte

func (*SearchExternalEventReplyPb) GetCode 

func (x *SearchExternalEventReplyPb) GetCode() LHResponseCodePb

func (*SearchExternalEventReplyPb) GetMessage 

func (x *SearchExternalEventReplyPb) GetMessage() string

func (*SearchExternalEventReplyPb) GetResults 

func (x *SearchExternalEventReplyPb) GetResults() []*ExternalEventIdPb

func (*SearchExternalEventReplyPb) ProtoMessage 

func (*SearchExternalEventReplyPb) ProtoMessage()

func (*SearchExternalEventReplyPb) ProtoReflect 

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

func (*SearchExternalEventReplyPb) Reset 

func (x *SearchExternalEventReplyPb) Reset()

func (*SearchExternalEventReplyPb) String 

func (x *SearchExternalEventReplyPb) String() string

type SearchNodeRunPb 

type SearchNodeRunPb struct {
	Bookmark []byte `protobuf:"bytes,1,opt,name=bookmark,proto3,oneof" json:"bookmark,omitempty"`
	Limit    *int32 `protobuf:"varint,2,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	// Types that are assignable to NoderunCriteria:
	//
	//	*SearchNodeRunPb_StatusAndTaskdef
	//	*SearchNodeRunPb_WfRunId
	NoderunCriteria isSearchNodeRunPb_NoderunCriteria `protobuf_oneof:"noderun_criteria"`
	// contains filtered or unexported fields
}

func (*SearchNodeRunPb) Descriptor deprecated 

func (*SearchNodeRunPb) Descriptor() ([]byte, []int)

Deprecated: Use SearchNodeRunPb.ProtoReflect.Descriptor instead.

func (*SearchNodeRunPb) GetBookmark 

func (x *SearchNodeRunPb) GetBookmark() []byte

func (*SearchNodeRunPb) GetLimit 

func (x *SearchNodeRunPb) GetLimit() int32

func (*SearchNodeRunPb) GetNoderunCriteria 

func (m *SearchNodeRunPb) GetNoderunCriteria() isSearchNodeRunPb_NoderunCriteria

func (*SearchNodeRunPb) GetStatusAndTaskdef 

func (x *SearchNodeRunPb) GetStatusAndTaskdef() *SearchNodeRunPb_StatusAndTaskDefPb

func (*SearchNodeRunPb) GetWfRunId 

func (x *SearchNodeRunPb) GetWfRunId() string

func (*SearchNodeRunPb) ProtoMessage 

func (*SearchNodeRunPb) ProtoMessage()

func (*SearchNodeRunPb) ProtoReflect 

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

func (*SearchNodeRunPb) Reset 

func (x *SearchNodeRunPb) Reset()

func (*SearchNodeRunPb) String 

func (x *SearchNodeRunPb) String() string

type SearchNodeRunPb_StatusAndTaskDefPb 

type SearchNodeRunPb_StatusAndTaskDefPb struct {
	Status        LHStatusPb             `protobuf:"varint,1,opt,name=status,proto3,enum=littlehorse.LHStatusPb" json:"status,omitempty"`
	TaskDefName   string                 `protobuf:"bytes,2,opt,name=task_def_name,json=taskDefName,proto3" json:"task_def_name,omitempty"`
	EarliestStart *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=earliest_start,json=earliestStart,proto3,oneof" json:"earliest_start,omitempty"`
	LatestStart   *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=latest_start,json=latestStart,proto3,oneof" json:"latest_start,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchNodeRunPb_StatusAndTaskDefPb) Descriptor deprecated 

func (*SearchNodeRunPb_StatusAndTaskDefPb) Descriptor() ([]byte, []int)

Deprecated: Use SearchNodeRunPb_StatusAndTaskDefPb.ProtoReflect.Descriptor instead.

func (*SearchNodeRunPb_StatusAndTaskDefPb) GetEarliestStart 

func (x *SearchNodeRunPb_StatusAndTaskDefPb) GetEarliestStart() *timestamppb.Timestamp

func (*SearchNodeRunPb_StatusAndTaskDefPb) GetLatestStart 

func (x *SearchNodeRunPb_StatusAndTaskDefPb) GetLatestStart() *timestamppb.Timestamp

func (*SearchNodeRunPb_StatusAndTaskDefPb) GetStatus 

func (x *SearchNodeRunPb_StatusAndTaskDefPb) GetStatus() LHStatusPb

func (*SearchNodeRunPb_StatusAndTaskDefPb) GetTaskDefName 

func (x *SearchNodeRunPb_StatusAndTaskDefPb) GetTaskDefName() string

func (*SearchNodeRunPb_StatusAndTaskDefPb) ProtoMessage 

func (*SearchNodeRunPb_StatusAndTaskDefPb) ProtoMessage()

func (*SearchNodeRunPb_StatusAndTaskDefPb) ProtoReflect 

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

func (*SearchNodeRunPb_StatusAndTaskDefPb) Reset 

func (x *SearchNodeRunPb_StatusAndTaskDefPb) Reset()

func (*SearchNodeRunPb_StatusAndTaskDefPb) String 

func (x *SearchNodeRunPb_StatusAndTaskDefPb) String() string

type SearchNodeRunPb_StatusAndTaskdef 

type SearchNodeRunPb_StatusAndTaskdef struct {
	StatusAndTaskdef *SearchNodeRunPb_StatusAndTaskDefPb `protobuf:"bytes,3,opt,name=status_and_taskdef,json=statusAndTaskdef,proto3,oneof"`
}

type SearchNodeRunPb_WfRunId 

type SearchNodeRunPb_WfRunId struct {
	WfRunId string `protobuf:"bytes,4,opt,name=wf_run_id,json=wfRunId,proto3,oneof"`
}

type SearchNodeRunReplyPb 

type SearchNodeRunReplyPb struct {
	Code     LHResponseCodePb `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message  *string          `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	Results  []*NodeRunIdPb   `protobuf:"bytes,3,rep,name=results,proto3" json:"results,omitempty"`
	Bookmark []byte           `protobuf:"bytes,4,opt,name=bookmark,proto3,oneof" json:"bookmark,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchNodeRunReplyPb) Descriptor deprecated 

func (*SearchNodeRunReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use SearchNodeRunReplyPb.ProtoReflect.Descriptor instead.

func (*SearchNodeRunReplyPb) GetBookmark 

func (x *SearchNodeRunReplyPb) GetBookmark() []byte

func (*SearchNodeRunReplyPb) GetCode 

func (x *SearchNodeRunReplyPb) GetCode() LHResponseCodePb

func (*SearchNodeRunReplyPb) GetMessage 

func (x *SearchNodeRunReplyPb) GetMessage() string

func (*SearchNodeRunReplyPb) GetResults 

func (x *SearchNodeRunReplyPb) GetResults() []*NodeRunIdPb

func (*SearchNodeRunReplyPb) ProtoMessage 

func (*SearchNodeRunReplyPb) ProtoMessage()

func (*SearchNodeRunReplyPb) ProtoReflect 

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

func (*SearchNodeRunReplyPb) Reset 

func (x *SearchNodeRunReplyPb) Reset()

func (*SearchNodeRunReplyPb) String 

func (x *SearchNodeRunReplyPb) String() string

type SearchTaskDefPb 

type SearchTaskDefPb struct {
	Bookmark []byte `protobuf:"bytes,1,opt,name=bookmark,proto3,oneof" json:"bookmark,omitempty"`
	Limit    *int32 `protobuf:"varint,2,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchTaskDefPb) Descriptor deprecated 

func (*SearchTaskDefPb) Descriptor() ([]byte, []int)

Deprecated: Use SearchTaskDefPb.ProtoReflect.Descriptor instead.

func (*SearchTaskDefPb) GetBookmark 

func (x *SearchTaskDefPb) GetBookmark() []byte

func (*SearchTaskDefPb) GetLimit 

func (x *SearchTaskDefPb) GetLimit() int32

func (*SearchTaskDefPb) ProtoMessage 

func (*SearchTaskDefPb) ProtoMessage()

func (*SearchTaskDefPb) ProtoReflect 

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

func (*SearchTaskDefPb) Reset 

func (x *SearchTaskDefPb) Reset()

func (*SearchTaskDefPb) String 

func (x *SearchTaskDefPb) String() string

type SearchTaskDefReplyPb 

type SearchTaskDefReplyPb struct {
	Code     LHResponseCodePb `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message  *string          `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	Results  []*TaskDefIdPb   `protobuf:"bytes,3,rep,name=results,proto3" json:"results,omitempty"`
	Bookmark []byte           `protobuf:"bytes,4,opt,name=bookmark,proto3,oneof" json:"bookmark,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchTaskDefReplyPb) Descriptor deprecated 

func (*SearchTaskDefReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use SearchTaskDefReplyPb.ProtoReflect.Descriptor instead.

func (*SearchTaskDefReplyPb) GetBookmark 

func (x *SearchTaskDefReplyPb) GetBookmark() []byte

func (*SearchTaskDefReplyPb) GetCode 

func (x *SearchTaskDefReplyPb) GetCode() LHResponseCodePb

func (*SearchTaskDefReplyPb) GetMessage 

func (x *SearchTaskDefReplyPb) GetMessage() string

func (*SearchTaskDefReplyPb) GetResults 

func (x *SearchTaskDefReplyPb) GetResults() []*TaskDefIdPb

func (*SearchTaskDefReplyPb) ProtoMessage 

func (*SearchTaskDefReplyPb) ProtoMessage()

func (*SearchTaskDefReplyPb) ProtoReflect 

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

func (*SearchTaskDefReplyPb) Reset 

func (x *SearchTaskDefReplyPb) Reset()

func (*SearchTaskDefReplyPb) String 

func (x *SearchTaskDefReplyPb) String() string

type SearchVariablePb 

type SearchVariablePb struct {
	Bookmark []byte `protobuf:"bytes,1,opt,name=bookmark,proto3,oneof" json:"bookmark,omitempty"`
	Limit    *int32 `protobuf:"varint,2,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	// Types that are assignable to VariableCriteria:
	//
	//	*SearchVariablePb_WfRunId
	//	*SearchVariablePb_Value
	VariableCriteria isSearchVariablePb_VariableCriteria `protobuf_oneof:"variable_criteria"`
	// contains filtered or unexported fields
}

func (*SearchVariablePb) Descriptor deprecated 

func (*SearchVariablePb) Descriptor() ([]byte, []int)

Deprecated: Use SearchVariablePb.ProtoReflect.Descriptor instead.

func (*SearchVariablePb) GetBookmark 

func (x *SearchVariablePb) GetBookmark() []byte

func (*SearchVariablePb) GetLimit 

func (x *SearchVariablePb) GetLimit() int32

func (*SearchVariablePb) GetValue 

func (x *SearchVariablePb) GetValue() *SearchVariablePb_NameAndValuePb

func (*SearchVariablePb) GetVariableCriteria 

func (m *SearchVariablePb) GetVariableCriteria() isSearchVariablePb_VariableCriteria

func (*SearchVariablePb) GetWfRunId 

func (x *SearchVariablePb) GetWfRunId() string

func (*SearchVariablePb) ProtoMessage 

func (*SearchVariablePb) ProtoMessage()

func (*SearchVariablePb) ProtoReflect 

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

func (*SearchVariablePb) Reset 

func (x *SearchVariablePb) Reset()

func (*SearchVariablePb) String 

func (x *SearchVariablePb) String() string

type SearchVariablePb_NameAndValuePb 

type SearchVariablePb_NameAndValuePb struct {
	Value         *VariableValuePb `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	WfSpecVersion *int32           `protobuf:"varint,2,opt,name=wf_spec_version,json=wfSpecVersion,proto3,oneof" json:"wf_spec_version,omitempty"`
	VarName       string           `protobuf:"bytes,3,opt,name=var_name,json=varName,proto3" json:"var_name,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchVariablePb_NameAndValuePb) Descriptor deprecated 

func (*SearchVariablePb_NameAndValuePb) Descriptor() ([]byte, []int)

Deprecated: Use SearchVariablePb_NameAndValuePb.ProtoReflect.Descriptor instead.

func (*SearchVariablePb_NameAndValuePb) GetValue 

func (x *SearchVariablePb_NameAndValuePb) GetValue() *VariableValuePb

func (*SearchVariablePb_NameAndValuePb) GetVarName 

func (x *SearchVariablePb_NameAndValuePb) GetVarName() string

func (*SearchVariablePb_NameAndValuePb) GetWfSpecVersion 

func (x *SearchVariablePb_NameAndValuePb) GetWfSpecVersion() int32

func (*SearchVariablePb_NameAndValuePb) ProtoMessage 

func (*SearchVariablePb_NameAndValuePb) ProtoMessage()

func (*SearchVariablePb_NameAndValuePb) ProtoReflect 

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

func (*SearchVariablePb_NameAndValuePb) Reset 

func (x *SearchVariablePb_NameAndValuePb) Reset()

func (*SearchVariablePb_NameAndValuePb) String 

func (x *SearchVariablePb_NameAndValuePb) String() string

type SearchVariablePb_Value 

type SearchVariablePb_Value struct {
	Value *SearchVariablePb_NameAndValuePb `protobuf:"bytes,4,opt,name=value,proto3,oneof"`
}

type SearchVariablePb_WfRunId 

type SearchVariablePb_WfRunId struct {
	WfRunId string `protobuf:"bytes,3,opt,name=wf_run_id,json=wfRunId,proto3,oneof"`
}

type SearchVariableReplyPb 

type SearchVariableReplyPb struct {
	Code     LHResponseCodePb `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message  *string          `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	Results  []*VariableIdPb  `protobuf:"bytes,3,rep,name=results,proto3" json:"results,omitempty"`
	Bookmark []byte           `protobuf:"bytes,4,opt,name=bookmark,proto3,oneof" json:"bookmark,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchVariableReplyPb) Descriptor deprecated 

func (*SearchVariableReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use SearchVariableReplyPb.ProtoReflect.Descriptor instead.

func (*SearchVariableReplyPb) GetBookmark 

func (x *SearchVariableReplyPb) GetBookmark() []byte

func (*SearchVariableReplyPb) GetCode 

func (x *SearchVariableReplyPb) GetCode() LHResponseCodePb

func (*SearchVariableReplyPb) GetMessage 

func (x *SearchVariableReplyPb) GetMessage() string

func (*SearchVariableReplyPb) GetResults 

func (x *SearchVariableReplyPb) GetResults() []*VariableIdPb

func (*SearchVariableReplyPb) ProtoMessage 

func (*SearchVariableReplyPb) ProtoMessage()

func (*SearchVariableReplyPb) ProtoReflect 

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

func (*SearchVariableReplyPb) Reset 

func (x *SearchVariableReplyPb) Reset()

func (*SearchVariableReplyPb) String 

func (x *SearchVariableReplyPb) String() string

type SearchWfRunPb 

type SearchWfRunPb struct {
	Bookmark []byte `protobuf:"bytes,1,opt,name=bookmark,proto3,oneof" json:"bookmark,omitempty"`
	Limit    *int32 `protobuf:"varint,2,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	// Types that are assignable to WfrunCriteria:
	//
	//	*SearchWfRunPb_StatusAndSpec
	WfrunCriteria isSearchWfRunPb_WfrunCriteria `protobuf_oneof:"wfrun_criteria"`
	// contains filtered or unexported fields
}

func (*SearchWfRunPb) Descriptor deprecated 

func (*SearchWfRunPb) Descriptor() ([]byte, []int)

Deprecated: Use SearchWfRunPb.ProtoReflect.Descriptor instead.

func (*SearchWfRunPb) GetBookmark 

func (x *SearchWfRunPb) GetBookmark() []byte

func (*SearchWfRunPb) GetLimit 

func (x *SearchWfRunPb) GetLimit() int32

func (*SearchWfRunPb) GetStatusAndSpec 

func (x *SearchWfRunPb) GetStatusAndSpec() *SearchWfRunPb_StatusAndSpecPb

func (*SearchWfRunPb) GetWfrunCriteria 

func (m *SearchWfRunPb) GetWfrunCriteria() isSearchWfRunPb_WfrunCriteria

func (*SearchWfRunPb) ProtoMessage 

func (*SearchWfRunPb) ProtoMessage()

func (*SearchWfRunPb) ProtoReflect 

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

func (*SearchWfRunPb) Reset 

func (x *SearchWfRunPb) Reset()

func (*SearchWfRunPb) String 

func (x *SearchWfRunPb) String() string

type SearchWfRunPb_StatusAndSpec 

type SearchWfRunPb_StatusAndSpec struct {
	StatusAndSpec *SearchWfRunPb_StatusAndSpecPb `protobuf:"bytes,3,opt,name=status_and_spec,json=statusAndSpec,proto3,oneof"`
}

type SearchWfRunPb_StatusAndSpecPb 

type SearchWfRunPb_StatusAndSpecPb struct {
	WfSpecName    string                 `protobuf:"bytes,1,opt,name=wf_spec_name,json=wfSpecName,proto3" json:"wf_spec_name,omitempty"`
	Status        LHStatusPb             `protobuf:"varint,2,opt,name=status,proto3,enum=littlehorse.LHStatusPb" json:"status,omitempty"`
	WfSpecVersion int32                  `protobuf:"varint,3,opt,name=wf_spec_version,json=wfSpecVersion,proto3" json:"wf_spec_version,omitempty"`
	EarliestStart *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=earliest_start,json=earliestStart,proto3,oneof" json:"earliest_start,omitempty"`
	LatestStart   *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=latest_start,json=latestStart,proto3,oneof" json:"latest_start,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchWfRunPb_StatusAndSpecPb) Descriptor deprecated 

func (*SearchWfRunPb_StatusAndSpecPb) Descriptor() ([]byte, []int)

Deprecated: Use SearchWfRunPb_StatusAndSpecPb.ProtoReflect.Descriptor instead.

func (*SearchWfRunPb_StatusAndSpecPb) GetEarliestStart 

func (x *SearchWfRunPb_StatusAndSpecPb) GetEarliestStart() *timestamppb.Timestamp

func (*SearchWfRunPb_StatusAndSpecPb) GetLatestStart 

func (x *SearchWfRunPb_StatusAndSpecPb) GetLatestStart() *timestamppb.Timestamp

func (*SearchWfRunPb_StatusAndSpecPb) GetStatus 

func (x *SearchWfRunPb_StatusAndSpecPb) GetStatus() LHStatusPb

func (*SearchWfRunPb_StatusAndSpecPb) GetWfSpecName 

func (x *SearchWfRunPb_StatusAndSpecPb) GetWfSpecName() string

func (*SearchWfRunPb_StatusAndSpecPb) GetWfSpecVersion 

func (x *SearchWfRunPb_StatusAndSpecPb) GetWfSpecVersion() int32

func (*SearchWfRunPb_StatusAndSpecPb) ProtoMessage 

func (*SearchWfRunPb_StatusAndSpecPb) ProtoMessage()

func (*SearchWfRunPb_StatusAndSpecPb) ProtoReflect 

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

func (*SearchWfRunPb_StatusAndSpecPb) Reset 

func (x *SearchWfRunPb_StatusAndSpecPb) Reset()

func (*SearchWfRunPb_StatusAndSpecPb) String 

func (x *SearchWfRunPb_StatusAndSpecPb) String() string

type SearchWfRunReplyPb 

type SearchWfRunReplyPb struct {
	Code    LHResponseCodePb `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message *string          `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	Results []*WfRunIdPb     `protobuf:"bytes,3,rep,name=results,proto3" json:"results,omitempty"`
	// The bookmark is used internally by the backend implementation to enable
	// pagination. If you wish to do a multi-part paginated request, you should
	// pass in the bookmark (unaltered) to the next request.
	Bookmark []byte `protobuf:"bytes,4,opt,name=bookmark,proto3,oneof" json:"bookmark,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchWfRunReplyPb) Descriptor deprecated 

func (*SearchWfRunReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use SearchWfRunReplyPb.ProtoReflect.Descriptor instead.

func (*SearchWfRunReplyPb) GetBookmark 

func (x *SearchWfRunReplyPb) GetBookmark() []byte

func (*SearchWfRunReplyPb) GetCode 

func (x *SearchWfRunReplyPb) GetCode() LHResponseCodePb

func (*SearchWfRunReplyPb) GetMessage 

func (x *SearchWfRunReplyPb) GetMessage() string

func (*SearchWfRunReplyPb) GetResults 

func (x *SearchWfRunReplyPb) GetResults() []*WfRunIdPb

func (*SearchWfRunReplyPb) ProtoMessage 

func (*SearchWfRunReplyPb) ProtoMessage()

func (*SearchWfRunReplyPb) ProtoReflect 

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

func (*SearchWfRunReplyPb) Reset 

func (x *SearchWfRunReplyPb) Reset()

func (*SearchWfRunReplyPb) String 

func (x *SearchWfRunReplyPb) String() string

type SearchWfSpecPb 

type SearchWfSpecPb struct {
	Bookmark []byte  `protobuf:"bytes,1,opt,name=bookmark,proto3,oneof" json:"bookmark,omitempty"`
	Limit    *int32  `protobuf:"varint,2,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	Name     *string `protobuf:"bytes,3,opt,name=name,proto3,oneof" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchWfSpecPb) Descriptor deprecated 

func (*SearchWfSpecPb) Descriptor() ([]byte, []int)

Deprecated: Use SearchWfSpecPb.ProtoReflect.Descriptor instead.

func (*SearchWfSpecPb) GetBookmark 

func (x *SearchWfSpecPb) GetBookmark() []byte

func (*SearchWfSpecPb) GetLimit 

func (x *SearchWfSpecPb) GetLimit() int32

func (*SearchWfSpecPb) GetName 

func (x *SearchWfSpecPb) GetName() string

func (*SearchWfSpecPb) ProtoMessage 

func (*SearchWfSpecPb) ProtoMessage()

func (*SearchWfSpecPb) ProtoReflect 

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

func (*SearchWfSpecPb) Reset 

func (x *SearchWfSpecPb) Reset()

func (*SearchWfSpecPb) String 

func (x *SearchWfSpecPb) String() string

type SearchWfSpecReplyPb 

type SearchWfSpecReplyPb struct {
	Code     LHResponseCodePb `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message  *string          `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	Results  []*WfSpecIdPb    `protobuf:"bytes,3,rep,name=results,proto3" json:"results,omitempty"`
	Bookmark []byte           `protobuf:"bytes,4,opt,name=bookmark,proto3,oneof" json:"bookmark,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchWfSpecReplyPb) Descriptor deprecated 

func (*SearchWfSpecReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use SearchWfSpecReplyPb.ProtoReflect.Descriptor instead.

func (*SearchWfSpecReplyPb) GetBookmark 

func (x *SearchWfSpecReplyPb) GetBookmark() []byte

func (*SearchWfSpecReplyPb) GetCode 

func (x *SearchWfSpecReplyPb) GetCode() LHResponseCodePb

func (*SearchWfSpecReplyPb) GetMessage 

func (x *SearchWfSpecReplyPb) GetMessage() string

func (*SearchWfSpecReplyPb) GetResults 

func (x *SearchWfSpecReplyPb) GetResults() []*WfSpecIdPb

func (*SearchWfSpecReplyPb) ProtoMessage 

func (*SearchWfSpecReplyPb) ProtoMessage()

func (*SearchWfSpecReplyPb) ProtoReflect 

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

func (*SearchWfSpecReplyPb) Reset 

func (x *SearchWfSpecReplyPb) Reset()

func (*SearchWfSpecReplyPb) String 

func (x *SearchWfSpecReplyPb) String() string

type SleepNodePb 

type SleepNodePb struct {

	// Types that are assignable to SleepLength:
	//
	//	*SleepNodePb_RawSeconds
	//	*SleepNodePb_Timestamp
	//	*SleepNodePb_IsoDate
	SleepLength isSleepNodePb_SleepLength `protobuf_oneof:"sleep_length"`
	// contains filtered or unexported fields
}

func (*SleepNodePb) Descriptor deprecated 

func (*SleepNodePb) Descriptor() ([]byte, []int)

Deprecated: Use SleepNodePb.ProtoReflect.Descriptor instead.

func (*SleepNodePb) GetIsoDate 

func (x *SleepNodePb) GetIsoDate() *VariableAssignmentPb

func (*SleepNodePb) GetRawSeconds 

func (x *SleepNodePb) GetRawSeconds() *VariableAssignmentPb

func (*SleepNodePb) GetSleepLength 

func (m *SleepNodePb) GetSleepLength() isSleepNodePb_SleepLength

func (*SleepNodePb) GetTimestamp 

func (x *SleepNodePb) GetTimestamp() *VariableAssignmentPb

func (*SleepNodePb) ProtoMessage 

func (*SleepNodePb) ProtoMessage()

func (*SleepNodePb) ProtoReflect 

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

func (*SleepNodePb) Reset 

func (x *SleepNodePb) Reset()

func (*SleepNodePb) String 

func (x *SleepNodePb) String() string

type SleepNodePb_IsoDate 

type SleepNodePb_IsoDate struct {
	IsoDate *VariableAssignmentPb `protobuf:"bytes,3,opt,name=iso_date,json=isoDate,proto3,oneof"`
}

type SleepNodePb_RawSeconds 

type SleepNodePb_RawSeconds struct {
	RawSeconds *VariableAssignmentPb `protobuf:"bytes,1,opt,name=raw_seconds,json=rawSeconds,proto3,oneof"`
}

type SleepNodePb_Timestamp 

type SleepNodePb_Timestamp struct {
	Timestamp *VariableAssignmentPb `protobuf:"bytes,2,opt,name=timestamp,proto3,oneof"`
}

type SleepNodeRunPb 

type SleepNodeRunPb struct {
	MaturationTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=maturation_time,json=maturationTime,proto3" json:"maturation_time,omitempty"`
	// contains filtered or unexported fields
}

func (*SleepNodeRunPb) Descriptor deprecated 

func (*SleepNodeRunPb) Descriptor() ([]byte, []int)

Deprecated: Use SleepNodeRunPb.ProtoReflect.Descriptor instead.

func (*SleepNodeRunPb) GetMaturationTime 

func (x *SleepNodeRunPb) GetMaturationTime() *timestamppb.Timestamp

func (*SleepNodeRunPb) ProtoMessage 

func (*SleepNodeRunPb) ProtoMessage()

func (*SleepNodeRunPb) ProtoReflect 

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

func (*SleepNodeRunPb) Reset 

func (x *SleepNodeRunPb) Reset()

func (*SleepNodeRunPb) String 

func (x *SleepNodeRunPb) String() string

type StartThreadNodePb 

type StartThreadNodePb struct {
	ThreadSpecName string                           `protobuf:"bytes,1,opt,name=thread_spec_name,json=threadSpecName,proto3" json:"thread_spec_name,omitempty"`
	Variables      map[string]*VariableAssignmentPb `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StartThreadNodePb) Descriptor deprecated 

func (*StartThreadNodePb) Descriptor() ([]byte, []int)

Deprecated: Use StartThreadNodePb.ProtoReflect.Descriptor instead.

func (*StartThreadNodePb) GetThreadSpecName 

func (x *StartThreadNodePb) GetThreadSpecName() string

func (*StartThreadNodePb) GetVariables 

func (x *StartThreadNodePb) GetVariables() map[string]*VariableAssignmentPb

func (*StartThreadNodePb) ProtoMessage 

func (*StartThreadNodePb) ProtoMessage()

func (*StartThreadNodePb) ProtoReflect 

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

func (*StartThreadNodePb) Reset 

func (x *StartThreadNodePb) Reset()

func (*StartThreadNodePb) String 

func (x *StartThreadNodePb) String() string

type StartThreadRunPb 

type StartThreadRunPb struct {
	ChildThreadId  *int32 `protobuf:"varint,1,opt,name=child_thread_id,json=childThreadId,proto3,oneof" json:"child_thread_id,omitempty"`
	ThreadSpecName string `protobuf:"bytes,2,opt,name=thread_spec_name,json=threadSpecName,proto3" json:"thread_spec_name,omitempty"`
	// contains filtered or unexported fields
}

func (*StartThreadRunPb) Descriptor deprecated 

func (*StartThreadRunPb) Descriptor() ([]byte, []int)

Deprecated: Use StartThreadRunPb.ProtoReflect.Descriptor instead.

func (*StartThreadRunPb) GetChildThreadId 

func (x *StartThreadRunPb) GetChildThreadId() int32

func (*StartThreadRunPb) GetThreadSpecName 

func (x *StartThreadRunPb) GetThreadSpecName() string

func (*StartThreadRunPb) ProtoMessage 

func (*StartThreadRunPb) ProtoMessage()

func (*StartThreadRunPb) ProtoReflect 

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

func (*StartThreadRunPb) Reset 

func (x *StartThreadRunPb) Reset()

func (*StartThreadRunPb) String 

func (x *StartThreadRunPb) String() string

type StopWfRunPb 

type StopWfRunPb struct {
	WfRunId         string `protobuf:"bytes,1,opt,name=wf_run_id,json=wfRunId,proto3" json:"wf_run_id,omitempty"`
	ThreadRunNumber int32  `protobuf:"varint,2,opt,name=thread_run_number,json=threadRunNumber,proto3" json:"thread_run_number,omitempty"`
	// contains filtered or unexported fields
}

func (*StopWfRunPb) Descriptor deprecated 

func (*StopWfRunPb) Descriptor() ([]byte, []int)

Deprecated: Use StopWfRunPb.ProtoReflect.Descriptor instead.

func (*StopWfRunPb) GetThreadRunNumber 

func (x *StopWfRunPb) GetThreadRunNumber() int32

func (*StopWfRunPb) GetWfRunId 

func (x *StopWfRunPb) GetWfRunId() string

func (*StopWfRunPb) ProtoMessage 

func (*StopWfRunPb) ProtoMessage()

func (*StopWfRunPb) ProtoReflect 

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

func (*StopWfRunPb) Reset 

func (x *StopWfRunPb) Reset()

func (*StopWfRunPb) String 

func (x *StopWfRunPb) String() string

type StopWfRunReplyPb 

type StopWfRunReplyPb struct {
	Code    LHResponseCodePb `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message *string          `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*StopWfRunReplyPb) Descriptor deprecated 

func (*StopWfRunReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use StopWfRunReplyPb.ProtoReflect.Descriptor instead.

func (*StopWfRunReplyPb) GetCode 

func (x *StopWfRunReplyPb) GetCode() LHResponseCodePb

func (*StopWfRunReplyPb) GetMessage 

func (x *StopWfRunReplyPb) GetMessage() string

func (*StopWfRunReplyPb) ProtoMessage 

func (*StopWfRunReplyPb) ProtoMessage()

func (*StopWfRunReplyPb) ProtoReflect 

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

func (*StopWfRunReplyPb) Reset 

func (x *StopWfRunReplyPb) Reset()

func (*StopWfRunReplyPb) String 

func (x *StopWfRunReplyPb) String() string

type TaskDefIdPb 

type TaskDefIdPb struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskDefIdPb) Descriptor deprecated 

func (*TaskDefIdPb) Descriptor() ([]byte, []int)

Deprecated: Use TaskDefIdPb.ProtoReflect.Descriptor instead.

func (*TaskDefIdPb) GetName 

func (x *TaskDefIdPb) GetName() string

func (*TaskDefIdPb) ProtoMessage 

func (*TaskDefIdPb) ProtoMessage()

func (*TaskDefIdPb) ProtoReflect 

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

func (*TaskDefIdPb) Reset 

func (x *TaskDefIdPb) Reset()

func (*TaskDefIdPb) String 

func (x *TaskDefIdPb) String() string

type TaskDefMetricsIdPb 

type TaskDefMetricsIdPb struct {
	WindowStart *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=window_start,json=windowStart,proto3" json:"window_start,omitempty"`
	WindowType  MetricsWindowLengthPb  `` /* 131-byte string literal not displayed */
	TaskDefName string                 `protobuf:"bytes,3,opt,name=task_def_name,json=taskDefName,proto3" json:"task_def_name,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskDefMetricsIdPb) Descriptor deprecated 

func (*TaskDefMetricsIdPb) Descriptor() ([]byte, []int)

Deprecated: Use TaskDefMetricsIdPb.ProtoReflect.Descriptor instead.

func (*TaskDefMetricsIdPb) GetTaskDefName 

func (x *TaskDefMetricsIdPb) GetTaskDefName() string

func (*TaskDefMetricsIdPb) GetWindowStart 

func (x *TaskDefMetricsIdPb) GetWindowStart() *timestamppb.Timestamp

func (*TaskDefMetricsIdPb) GetWindowType 

func (x *TaskDefMetricsIdPb) GetWindowType() MetricsWindowLengthPb

func (*TaskDefMetricsIdPb) ProtoMessage 

func (*TaskDefMetricsIdPb) ProtoMessage()

func (*TaskDefMetricsIdPb) ProtoReflect 

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

func (*TaskDefMetricsIdPb) Reset 

func (x *TaskDefMetricsIdPb) Reset()

func (*TaskDefMetricsIdPb) String 

func (x *TaskDefMetricsIdPb) String() string

type TaskDefMetricsPb 

type TaskDefMetricsPb struct {
	WindowStart        *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=window_start,json=windowStart,proto3" json:"window_start,omitempty"`
	Type               MetricsWindowLengthPb  `protobuf:"varint,2,opt,name=type,proto3,enum=littlehorse.MetricsWindowLengthPb" json:"type,omitempty"`
	TaskDefName        string                 `protobuf:"bytes,3,opt,name=taskDefName,proto3" json:"taskDefName,omitempty"`
	ScheduleToStartMax int64                  `protobuf:"varint,4,opt,name=schedule_to_start_max,json=scheduleToStartMax,proto3" json:"schedule_to_start_max,omitempty"`
	ScheduleToStartAvg int64                  `protobuf:"varint,5,opt,name=schedule_to_start_avg,json=scheduleToStartAvg,proto3" json:"schedule_to_start_avg,omitempty"`
	StartToCompleteMax int64                  `protobuf:"varint,6,opt,name=start_to_complete_max,json=startToCompleteMax,proto3" json:"start_to_complete_max,omitempty"`
	StartToCompleteAvg int64                  `protobuf:"varint,7,opt,name=start_to_complete_avg,json=startToCompleteAvg,proto3" json:"start_to_complete_avg,omitempty"`
	TotalCompleted     int64                  `protobuf:"varint,8,opt,name=total_completed,json=totalCompleted,proto3" json:"total_completed,omitempty"`
	TotalErrored       int64                  `protobuf:"varint,9,opt,name=total_errored,json=totalErrored,proto3" json:"total_errored,omitempty"`
	TotalStarted       int64                  `protobuf:"varint,10,opt,name=total_started,json=totalStarted,proto3" json:"total_started,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskDefMetricsPb) Descriptor deprecated 

func (*TaskDefMetricsPb) Descriptor() ([]byte, []int)

Deprecated: Use TaskDefMetricsPb.ProtoReflect.Descriptor instead.

func (*TaskDefMetricsPb) GetScheduleToStartAvg 

func (x *TaskDefMetricsPb) GetScheduleToStartAvg() int64

func (*TaskDefMetricsPb) GetScheduleToStartMax 

func (x *TaskDefMetricsPb) GetScheduleToStartMax() int64

func (*TaskDefMetricsPb) GetStartToCompleteAvg 

func (x *TaskDefMetricsPb) GetStartToCompleteAvg() int64

func (*TaskDefMetricsPb) GetStartToCompleteMax 

func (x *TaskDefMetricsPb) GetStartToCompleteMax() int64

func (*TaskDefMetricsPb) GetTaskDefName 

func (x *TaskDefMetricsPb) GetTaskDefName() string

func (*TaskDefMetricsPb) GetTotalCompleted 

func (x *TaskDefMetricsPb) GetTotalCompleted() int64

func (*TaskDefMetricsPb) GetTotalErrored 

func (x *TaskDefMetricsPb) GetTotalErrored() int64

func (*TaskDefMetricsPb) GetTotalStarted 

func (x *TaskDefMetricsPb) GetTotalStarted() int64

func (*TaskDefMetricsPb) GetType 

func (x *TaskDefMetricsPb) GetType() MetricsWindowLengthPb

func (*TaskDefMetricsPb) GetWindowStart 

func (x *TaskDefMetricsPb) GetWindowStart() *timestamppb.Timestamp

func (*TaskDefMetricsPb) ProtoMessage 

func (*TaskDefMetricsPb) ProtoMessage()

func (*TaskDefMetricsPb) ProtoReflect 

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

func (*TaskDefMetricsPb) Reset 

func (x *TaskDefMetricsPb) Reset()

func (*TaskDefMetricsPb) String 

func (x *TaskDefMetricsPb) String() string

type TaskDefMetricsQueryPb 

type TaskDefMetricsQueryPb struct {
	WindowStart *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=window_start,json=windowStart,proto3" json:"window_start,omitempty"`
	WindowType  MetricsWindowLengthPb  `` /* 131-byte string literal not displayed */
	TaskDefName *string                `protobuf:"bytes,3,opt,name=task_def_name,json=taskDefName,proto3,oneof" json:"task_def_name,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskDefMetricsQueryPb) Descriptor deprecated 

func (*TaskDefMetricsQueryPb) Descriptor() ([]byte, []int)

Deprecated: Use TaskDefMetricsQueryPb.ProtoReflect.Descriptor instead.

func (*TaskDefMetricsQueryPb) GetTaskDefName 

func (x *TaskDefMetricsQueryPb) GetTaskDefName() string

func (*TaskDefMetricsQueryPb) GetWindowStart 

func (x *TaskDefMetricsQueryPb) GetWindowStart() *timestamppb.Timestamp

func (*TaskDefMetricsQueryPb) GetWindowType 

func (x *TaskDefMetricsQueryPb) GetWindowType() MetricsWindowLengthPb

func (*TaskDefMetricsQueryPb) ProtoMessage 

func (*TaskDefMetricsQueryPb) ProtoMessage()

func (*TaskDefMetricsQueryPb) ProtoReflect 

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

func (*TaskDefMetricsQueryPb) Reset 

func (x *TaskDefMetricsQueryPb) Reset()

func (*TaskDefMetricsQueryPb) String 

func (x *TaskDefMetricsQueryPb) String() string

type TaskDefMetricsReplyPb 

type TaskDefMetricsReplyPb struct {
	Code    LHResponseCodePb  `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message *string           `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	Result  *TaskDefMetricsPb `protobuf:"bytes,3,opt,name=result,proto3,oneof" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskDefMetricsReplyPb) Descriptor deprecated 

func (*TaskDefMetricsReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use TaskDefMetricsReplyPb.ProtoReflect.Descriptor instead.

func (*TaskDefMetricsReplyPb) GetCode 

func (x *TaskDefMetricsReplyPb) GetCode() LHResponseCodePb

func (*TaskDefMetricsReplyPb) GetMessage 

func (x *TaskDefMetricsReplyPb) GetMessage() string

func (*TaskDefMetricsReplyPb) GetResult 

func (x *TaskDefMetricsReplyPb) GetResult() *TaskDefMetricsPb

func (*TaskDefMetricsReplyPb) ProtoMessage 

func (*TaskDefMetricsReplyPb) ProtoMessage()

func (*TaskDefMetricsReplyPb) ProtoReflect 

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

func (*TaskDefMetricsReplyPb) Reset 

func (x *TaskDefMetricsReplyPb) Reset()

func (*TaskDefMetricsReplyPb) String 

func (x *TaskDefMetricsReplyPb) String() string

type TaskDefPb 

type TaskDefPb struct {
	Name      string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	InputVars []*VariableDefPb       `protobuf:"bytes,2,rep,name=input_vars,json=inputVars,proto3" json:"input_vars,omitempty"`
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskDefPb) Descriptor deprecated 

func (*TaskDefPb) Descriptor() ([]byte, []int)

Deprecated: Use TaskDefPb.ProtoReflect.Descriptor instead.

func (*TaskDefPb) GetCreatedAt 

func (x *TaskDefPb) GetCreatedAt() *timestamppb.Timestamp

func (*TaskDefPb) GetInputVars 

func (x *TaskDefPb) GetInputVars() []*VariableDefPb

func (*TaskDefPb) GetName 

func (x *TaskDefPb) GetName() string

func (*TaskDefPb) ProtoMessage 

func (*TaskDefPb) ProtoMessage()

func (*TaskDefPb) ProtoReflect 

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

func (*TaskDefPb) Reset 

func (x *TaskDefPb) Reset()

func (*TaskDefPb) String 

func (x *TaskDefPb) String() string

type TaskNodePb 

type TaskNodePb struct {
	TaskDefName    string                  `protobuf:"bytes,1,opt,name=task_def_name,json=taskDefName,proto3" json:"task_def_name,omitempty"`
	TimeoutSeconds *VariableAssignmentPb   `protobuf:"bytes,2,opt,name=timeout_seconds,json=timeoutSeconds,proto3" json:"timeout_seconds,omitempty"`
	Retries        int32                   `protobuf:"varint,3,opt,name=retries,proto3" json:"retries,omitempty"`
	Variables      []*VariableAssignmentPb `protobuf:"bytes,4,rep,name=variables,proto3" json:"variables,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskNodePb) Descriptor deprecated 

func (*TaskNodePb) Descriptor() ([]byte, []int)

Deprecated: Use TaskNodePb.ProtoReflect.Descriptor instead.

func (*TaskNodePb) GetRetries 

func (x *TaskNodePb) GetRetries() int32

func (*TaskNodePb) GetTaskDefName 

func (x *TaskNodePb) GetTaskDefName() string

func (*TaskNodePb) GetTimeoutSeconds 

func (x *TaskNodePb) GetTimeoutSeconds() *VariableAssignmentPb

func (*TaskNodePb) GetVariables 

func (x *TaskNodePb) GetVariables() []*VariableAssignmentPb

func (*TaskNodePb) ProtoMessage 

func (*TaskNodePb) ProtoMessage()

func (*TaskNodePb) ProtoReflect 

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

func (*TaskNodePb) Reset 

func (x *TaskNodePb) Reset()

func (*TaskNodePb) String 

func (x *TaskNodePb) String() string

type TaskResultCodePb 

type TaskResultCodePb int32
const (
	TaskResultCodePb_SUCCESS                  TaskResultCodePb = 0
	TaskResultCodePb_TIMEOUT                  TaskResultCodePb = 1
	TaskResultCodePb_FAILED                   TaskResultCodePb = 2
	TaskResultCodePb_VAR_SUB_ERROR            TaskResultCodePb = 3
	TaskResultCodePb_VAR_MUTATION_ERROR       TaskResultCodePb = 4
	TaskResultCodePb_CHILD_FALIED             TaskResultCodePb = 5
	TaskResultCodePb_INTERRUPT_HANDLER_FAILED TaskResultCodePb = 6
	TaskResultCodePb_EXCEPTION_HANDLER_FAILED TaskResultCodePb = 7
	TaskResultCodePb_INTERNAL_ERROR           TaskResultCodePb = 8
)

func (TaskResultCodePb) Descriptor 

func (TaskResultCodePb) Descriptor() protoreflect.EnumDescriptor

func (TaskResultCodePb) Enum 

func (x TaskResultCodePb) Enum() *TaskResultCodePb

func (TaskResultCodePb) EnumDescriptor deprecated 

func (TaskResultCodePb) EnumDescriptor() ([]byte, []int)

Deprecated: Use TaskResultCodePb.Descriptor instead.

func (TaskResultCodePb) Number 

func (x TaskResultCodePb) Number() protoreflect.EnumNumber

func (TaskResultCodePb) String 

func (x TaskResultCodePb) String() string

func (TaskResultCodePb) Type 

func (TaskResultCodePb) Type() protoreflect.EnumType

type TaskResultEventPb 

type TaskResultEventPb struct {
	WfRunId         string                 `protobuf:"bytes,1,opt,name=wf_run_id,json=wfRunId,proto3" json:"wf_run_id,omitempty"`
	ThreadRunNumber int32                  `protobuf:"varint,2,opt,name=thread_run_number,json=threadRunNumber,proto3" json:"thread_run_number,omitempty"`
	TaskRunPosition int32                  `protobuf:"varint,3,opt,name=task_run_position,json=taskRunPosition,proto3" json:"task_run_position,omitempty"`
	Time            *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=time,proto3" json:"time,omitempty"`
	ResultCode      TaskResultCodePb       `` /* 126-byte string literal not displayed */
	Output          *VariableValuePb       `protobuf:"bytes,6,opt,name=output,proto3,oneof" json:"output,omitempty"`
	LogOutput       *VariableValuePb       `protobuf:"bytes,7,opt,name=log_output,json=logOutput,proto3,oneof" json:"log_output,omitempty"`
	FromRpc         bool                   `protobuf:"varint,8,opt,name=from_rpc,json=fromRpc,proto3" json:"from_rpc,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskResultEventPb) Descriptor deprecated 

func (*TaskResultEventPb) Descriptor() ([]byte, []int)

Deprecated: Use TaskResultEventPb.ProtoReflect.Descriptor instead.

func (*TaskResultEventPb) GetFromRpc 

func (x *TaskResultEventPb) GetFromRpc() bool

func (*TaskResultEventPb) GetLogOutput 

func (x *TaskResultEventPb) GetLogOutput() *VariableValuePb

func (*TaskResultEventPb) GetOutput 

func (x *TaskResultEventPb) GetOutput() *VariableValuePb

func (*TaskResultEventPb) GetResultCode 

func (x *TaskResultEventPb) GetResultCode() TaskResultCodePb

func (*TaskResultEventPb) GetTaskRunPosition 

func (x *TaskResultEventPb) GetTaskRunPosition() int32

func (*TaskResultEventPb) GetThreadRunNumber 

func (x *TaskResultEventPb) GetThreadRunNumber() int32

func (*TaskResultEventPb) GetTime 

func (x *TaskResultEventPb) GetTime() *timestamppb.Timestamp

func (*TaskResultEventPb) GetWfRunId 

func (x *TaskResultEventPb) GetWfRunId() string

func (*TaskResultEventPb) ProtoMessage 

func (*TaskResultEventPb) ProtoMessage()

func (*TaskResultEventPb) ProtoReflect 

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

func (*TaskResultEventPb) Reset 

func (x *TaskResultEventPb) Reset()

func (*TaskResultEventPb) String 

func (x *TaskResultEventPb) String() string

type TaskResultOePb 

type TaskResultOePb struct {
	ResultCode      TaskResultCodePb `` /* 126-byte string literal not displayed */
	ThreadRunNumber int32            `protobuf:"varint,2,opt,name=thread_run_number,json=threadRunNumber,proto3" json:"thread_run_number,omitempty"`
	TaskRunPosition int32            `protobuf:"varint,3,opt,name=task_run_position,json=taskRunPosition,proto3" json:"task_run_position,omitempty"`
	Output          *VariableValuePb `protobuf:"bytes,4,opt,name=output,proto3,oneof" json:"output,omitempty"`
	LogOutput       *VariableValuePb `protobuf:"bytes,5,opt,name=log_output,json=logOutput,proto3,oneof" json:"log_output,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskResultOePb) Descriptor deprecated 

func (*TaskResultOePb) Descriptor() ([]byte, []int)

Deprecated: Use TaskResultOePb.ProtoReflect.Descriptor instead.

func (*TaskResultOePb) GetLogOutput 

func (x *TaskResultOePb) GetLogOutput() *VariableValuePb

func (*TaskResultOePb) GetOutput 

func (x *TaskResultOePb) GetOutput() *VariableValuePb

func (*TaskResultOePb) GetResultCode 

func (x *TaskResultOePb) GetResultCode() TaskResultCodePb

func (*TaskResultOePb) GetTaskRunPosition 

func (x *TaskResultOePb) GetTaskRunPosition() int32

func (*TaskResultOePb) GetThreadRunNumber 

func (x *TaskResultOePb) GetThreadRunNumber() int32

func (*TaskResultOePb) ProtoMessage 

func (*TaskResultOePb) ProtoMessage()

func (*TaskResultOePb) ProtoReflect 

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

func (*TaskResultOePb) Reset 

func (x *TaskResultOePb) Reset()

func (*TaskResultOePb) String 

func (x *TaskResultOePb) String() string

type TaskRunPb 

type TaskRunPb struct {
	AttemptNumber     int32                  `protobuf:"varint,1,opt,name=attempt_number,json=attemptNumber,proto3" json:"attempt_number,omitempty"` // Task only
	Output            *VariableValuePb       `protobuf:"bytes,2,opt,name=output,proto3,oneof" json:"output,omitempty"`
	LogOutput         *VariableValuePb       `protobuf:"bytes,3,opt,name=log_output,json=logOutput,proto3,oneof" json:"log_output,omitempty"`
	StartTime         *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3,oneof" json:"start_time,omitempty"`
	TaskDefId         string                 `protobuf:"bytes,5,opt,name=task_def_id,json=taskDefId,proto3" json:"task_def_id,omitempty"`
	InputVariables    []*VarNameAndValPb     `protobuf:"bytes,6,rep,name=input_variables,json=inputVariables,proto3" json:"input_variables,omitempty"`
	TaskWorkerId      string                 `protobuf:"bytes,7,opt,name=task_worker_id,json=taskWorkerId,proto3" json:"task_worker_id,omitempty"`
	TaskWorkerVersion *string                `protobuf:"bytes,8,opt,name=task_worker_version,json=taskWorkerVersion,proto3,oneof" json:"task_worker_version,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskRunPb) Descriptor deprecated 

func (*TaskRunPb) Descriptor() ([]byte, []int)

Deprecated: Use TaskRunPb.ProtoReflect.Descriptor instead.

func (*TaskRunPb) GetAttemptNumber 

func (x *TaskRunPb) GetAttemptNumber() int32

func (*TaskRunPb) GetInputVariables 

func (x *TaskRunPb) GetInputVariables() []*VarNameAndValPb

func (*TaskRunPb) GetLogOutput 

func (x *TaskRunPb) GetLogOutput() *VariableValuePb

func (*TaskRunPb) GetOutput 

func (x *TaskRunPb) GetOutput() *VariableValuePb

func (*TaskRunPb) GetStartTime 

func (x *TaskRunPb) GetStartTime() *timestamppb.Timestamp

func (*TaskRunPb) GetTaskDefId 

func (x *TaskRunPb) GetTaskDefId() string

func (*TaskRunPb) GetTaskWorkerId 

func (x *TaskRunPb) GetTaskWorkerId() string

func (*TaskRunPb) GetTaskWorkerVersion 

func (x *TaskRunPb) GetTaskWorkerVersion() string

func (*TaskRunPb) ProtoMessage 

func (*TaskRunPb) ProtoMessage()

func (*TaskRunPb) ProtoReflect 

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

func (*TaskRunPb) Reset 

func (x *TaskRunPb) Reset()

func (*TaskRunPb) String 

func (x *TaskRunPb) String() string

type TaskScheduledOePb 

type TaskScheduledOePb struct {
	TaskDefName     string             `protobuf:"bytes,1,opt,name=task_def_name,json=taskDefName,proto3" json:"task_def_name,omitempty"`
	ThreadRunNumber int32              `protobuf:"varint,2,opt,name=thread_run_number,json=threadRunNumber,proto3" json:"thread_run_number,omitempty"`
	TaskRunNumber   int32              `protobuf:"varint,3,opt,name=task_run_number,json=taskRunNumber,proto3" json:"task_run_number,omitempty"`
	TaskRunPosition int32              `protobuf:"varint,4,opt,name=task_run_position,json=taskRunPosition,proto3" json:"task_run_position,omitempty"`
	Variables       []*VarNameAndValPb `protobuf:"bytes,5,rep,name=variables,proto3" json:"variables,omitempty"`
	NodeName        string             `protobuf:"bytes,6,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	WfSpecName      string             `protobuf:"bytes,7,opt,name=wf_spec_name,json=wfSpecName,proto3" json:"wf_spec_name,omitempty"`
	WfSpecVersion   int32              `protobuf:"varint,8,opt,name=wf_spec_version,json=wfSpecVersion,proto3" json:"wf_spec_version,omitempty"`
	AttemptNumber   int32              `protobuf:"varint,9,opt,name=attempt_number,json=attemptNumber,proto3" json:"attempt_number,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskScheduledOePb) Descriptor deprecated 

func (*TaskScheduledOePb) Descriptor() ([]byte, []int)

Deprecated: Use TaskScheduledOePb.ProtoReflect.Descriptor instead.

func (*TaskScheduledOePb) GetAttemptNumber 

func (x *TaskScheduledOePb) GetAttemptNumber() int32

func (*TaskScheduledOePb) GetNodeName 

func (x *TaskScheduledOePb) GetNodeName() string

func (*TaskScheduledOePb) GetTaskDefName 

func (x *TaskScheduledOePb) GetTaskDefName() string

func (*TaskScheduledOePb) GetTaskRunNumber 

func (x *TaskScheduledOePb) GetTaskRunNumber() int32

func (*TaskScheduledOePb) GetTaskRunPosition 

func (x *TaskScheduledOePb) GetTaskRunPosition() int32

func (*TaskScheduledOePb) GetThreadRunNumber 

func (x *TaskScheduledOePb) GetThreadRunNumber() int32

func (*TaskScheduledOePb) GetVariables 

func (x *TaskScheduledOePb) GetVariables() []*VarNameAndValPb

func (*TaskScheduledOePb) GetWfSpecName 

func (x *TaskScheduledOePb) GetWfSpecName() string

func (*TaskScheduledOePb) GetWfSpecVersion 

func (x *TaskScheduledOePb) GetWfSpecVersion() int32

func (*TaskScheduledOePb) ProtoMessage 

func (*TaskScheduledOePb) ProtoMessage()

func (*TaskScheduledOePb) ProtoReflect 

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

func (*TaskScheduledOePb) Reset 

func (x *TaskScheduledOePb) Reset()

func (*TaskScheduledOePb) String 

func (x *TaskScheduledOePb) String() string

type TaskStartOePb 

type TaskStartOePb struct {
	WorkerId        string `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	ThreadRunNumber int32  `protobuf:"varint,2,opt,name=thread_run_number,json=threadRunNumber,proto3" json:"thread_run_number,omitempty"`
	TaskRunPosition int32  `protobuf:"varint,3,opt,name=task_run_position,json=taskRunPosition,proto3" json:"task_run_position,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskStartOePb) Descriptor deprecated 

func (*TaskStartOePb) Descriptor() ([]byte, []int)

Deprecated: Use TaskStartOePb.ProtoReflect.Descriptor instead.

func (*TaskStartOePb) GetTaskRunPosition 

func (x *TaskStartOePb) GetTaskRunPosition() int32

func (*TaskStartOePb) GetThreadRunNumber 

func (x *TaskStartOePb) GetThreadRunNumber() int32

func (*TaskStartOePb) GetWorkerId 

func (x *TaskStartOePb) GetWorkerId() string

func (*TaskStartOePb) ProtoMessage 

func (*TaskStartOePb) ProtoMessage()

func (*TaskStartOePb) ProtoReflect 

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

func (*TaskStartOePb) Reset 

func (x *TaskStartOePb) Reset()

func (*TaskStartOePb) String 

func (x *TaskStartOePb) String() string

type TaskWorkerGroupIdPb 

type TaskWorkerGroupIdPb struct {
	TaskDefName string `protobuf:"bytes,1,opt,name=task_def_name,json=taskDefName,proto3" json:"task_def_name,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskWorkerGroupIdPb) Descriptor deprecated 

func (*TaskWorkerGroupIdPb) Descriptor() ([]byte, []int)

Deprecated: Use TaskWorkerGroupIdPb.ProtoReflect.Descriptor instead.

func (*TaskWorkerGroupIdPb) GetTaskDefName 

func (x *TaskWorkerGroupIdPb) GetTaskDefName() string

func (*TaskWorkerGroupIdPb) ProtoMessage 

func (*TaskWorkerGroupIdPb) ProtoMessage()

func (*TaskWorkerGroupIdPb) ProtoReflect 

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

func (*TaskWorkerGroupIdPb) Reset 

func (x *TaskWorkerGroupIdPb) Reset()

func (*TaskWorkerGroupIdPb) String 

func (x *TaskWorkerGroupIdPb) String() string

type TaskWorkerGroupPb 

type TaskWorkerGroupPb struct {
	TaskDefName string                           `protobuf:"bytes,1,opt,name=task_def_name,json=taskDefName,proto3" json:"task_def_name,omitempty"`
	CreatedAt   *timestamppb.Timestamp           `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	TaskWorkers map[string]*TaskWorkerMetadataPb `` /* 182-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TaskWorkerGroupPb) Descriptor deprecated 

func (*TaskWorkerGroupPb) Descriptor() ([]byte, []int)

Deprecated: Use TaskWorkerGroupPb.ProtoReflect.Descriptor instead.

func (*TaskWorkerGroupPb) GetCreatedAt 

func (x *TaskWorkerGroupPb) GetCreatedAt() *timestamppb.Timestamp

func (*TaskWorkerGroupPb) GetTaskDefName 

func (x *TaskWorkerGroupPb) GetTaskDefName() string

func (*TaskWorkerGroupPb) GetTaskWorkers 

func (x *TaskWorkerGroupPb) GetTaskWorkers() map[string]*TaskWorkerMetadataPb

func (*TaskWorkerGroupPb) ProtoMessage 

func (*TaskWorkerGroupPb) ProtoMessage()

func (*TaskWorkerGroupPb) ProtoReflect 

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

func (*TaskWorkerGroupPb) Reset 

func (x *TaskWorkerGroupPb) Reset()

func (*TaskWorkerGroupPb) String 

func (x *TaskWorkerGroupPb) String() string

type TaskWorkerHeartBeatPb 

type TaskWorkerHeartBeatPb struct {
	ClientId     string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	TaskDefName  string `protobuf:"bytes,2,opt,name=task_def_name,json=taskDefName,proto3" json:"task_def_name,omitempty"`
	ListenerName string `protobuf:"bytes,3,opt,name=listener_name,json=listenerName,proto3" json:"listener_name,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskWorkerHeartBeatPb) Descriptor deprecated 

func (*TaskWorkerHeartBeatPb) Descriptor() ([]byte, []int)

Deprecated: Use TaskWorkerHeartBeatPb.ProtoReflect.Descriptor instead.

func (*TaskWorkerHeartBeatPb) GetClientId 

func (x *TaskWorkerHeartBeatPb) GetClientId() string

func (*TaskWorkerHeartBeatPb) GetListenerName 

func (x *TaskWorkerHeartBeatPb) GetListenerName() string

func (*TaskWorkerHeartBeatPb) GetTaskDefName 

func (x *TaskWorkerHeartBeatPb) GetTaskDefName() string

func (*TaskWorkerHeartBeatPb) ProtoMessage 

func (*TaskWorkerHeartBeatPb) ProtoMessage()

func (*TaskWorkerHeartBeatPb) ProtoReflect 

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

func (*TaskWorkerHeartBeatPb) Reset 

func (x *TaskWorkerHeartBeatPb) Reset()

func (*TaskWorkerHeartBeatPb) String 

func (x *TaskWorkerHeartBeatPb) String() string

type TaskWorkerMetadataPb 

type TaskWorkerMetadataPb struct {
	ClientId        string                 `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	LatestHeartbeat *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=latest_heartbeat,json=latestHeartbeat,proto3" json:"latest_heartbeat,omitempty"`
	Hosts           []*HostInfoPb          `protobuf:"bytes,3,rep,name=hosts,proto3" json:"hosts,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskWorkerMetadataPb) Descriptor deprecated 

func (*TaskWorkerMetadataPb) Descriptor() ([]byte, []int)

Deprecated: Use TaskWorkerMetadataPb.ProtoReflect.Descriptor instead.

func (*TaskWorkerMetadataPb) GetClientId 

func (x *TaskWorkerMetadataPb) GetClientId() string

func (*TaskWorkerMetadataPb) GetHosts 

func (x *TaskWorkerMetadataPb) GetHosts() []*HostInfoPb

func (*TaskWorkerMetadataPb) GetLatestHeartbeat 

func (x *TaskWorkerMetadataPb) GetLatestHeartbeat() *timestamppb.Timestamp

func (*TaskWorkerMetadataPb) ProtoMessage 

func (*TaskWorkerMetadataPb) ProtoMessage()

func (*TaskWorkerMetadataPb) ProtoReflect 

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

func (*TaskWorkerMetadataPb) Reset 

func (x *TaskWorkerMetadataPb) Reset()

func (*TaskWorkerMetadataPb) String 

func (x *TaskWorkerMetadataPb) String() string

type ThreadHaltReasonPb 

type ThreadHaltReasonPb struct {

	// Types that are assignable to Reason:
	//
	//	*ThreadHaltReasonPb_ParentHalted
	//	*ThreadHaltReasonPb_Interrupted
	//	*ThreadHaltReasonPb_PendingInterrupt
	//	*ThreadHaltReasonPb_PendingFailure
	//	*ThreadHaltReasonPb_HandlingFailure
	//	*ThreadHaltReasonPb_ManualHalt
	Reason isThreadHaltReasonPb_Reason `protobuf_oneof:"reason"`
	// contains filtered or unexported fields
}

func (*ThreadHaltReasonPb) Descriptor deprecated 

func (*ThreadHaltReasonPb) Descriptor() ([]byte, []int)

Deprecated: Use ThreadHaltReasonPb.ProtoReflect.Descriptor instead.

func (*ThreadHaltReasonPb) GetHandlingFailure 

func (x *ThreadHaltReasonPb) GetHandlingFailure() *HandlingFailureHaltReasonPb

func (*ThreadHaltReasonPb) GetInterrupted 

func (x *ThreadHaltReasonPb) GetInterrupted() *InterruptedPb

func (*ThreadHaltReasonPb) GetManualHalt 

func (x *ThreadHaltReasonPb) GetManualHalt() *ManualHaltPb

func (*ThreadHaltReasonPb) GetParentHalted 

func (x *ThreadHaltReasonPb) GetParentHalted() *ParentHaltedPb

func (*ThreadHaltReasonPb) GetPendingFailure 

func (x *ThreadHaltReasonPb) GetPendingFailure() *PendingFailureHandlerHaltReasonPb

func (*ThreadHaltReasonPb) GetPendingInterrupt 

func (x *ThreadHaltReasonPb) GetPendingInterrupt() *PendingInterruptHaltReasonPb

func (*ThreadHaltReasonPb) GetReason 

func (m *ThreadHaltReasonPb) GetReason() isThreadHaltReasonPb_Reason

func (*ThreadHaltReasonPb) ProtoMessage 

func (*ThreadHaltReasonPb) ProtoMessage()

func (*ThreadHaltReasonPb) ProtoReflect 

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

func (*ThreadHaltReasonPb) Reset 

func (x *ThreadHaltReasonPb) Reset()

func (*ThreadHaltReasonPb) String 

func (x *ThreadHaltReasonPb) String() string

type ThreadHaltReasonPb_HandlingFailure 

type ThreadHaltReasonPb_HandlingFailure struct {
	HandlingFailure *HandlingFailureHaltReasonPb `protobuf:"bytes,5,opt,name=handling_failure,json=handlingFailure,proto3,oneof"`
}

type ThreadHaltReasonPb_Interrupted 

type ThreadHaltReasonPb_Interrupted struct {
	Interrupted *InterruptedPb `protobuf:"bytes,2,opt,name=interrupted,proto3,oneof"`
}

type ThreadHaltReasonPb_ManualHalt 

type ThreadHaltReasonPb_ManualHalt struct {
	ManualHalt *ManualHaltPb `protobuf:"bytes,6,opt,name=manual_halt,json=manualHalt,proto3,oneof"`
}

type ThreadHaltReasonPb_ParentHalted 

type ThreadHaltReasonPb_ParentHalted struct {
	ParentHalted *ParentHaltedPb `protobuf:"bytes,1,opt,name=parent_halted,json=parentHalted,proto3,oneof"`
}

type ThreadHaltReasonPb_PendingFailure 

type ThreadHaltReasonPb_PendingFailure struct {
	PendingFailure *PendingFailureHandlerHaltReasonPb `protobuf:"bytes,4,opt,name=pending_failure,json=pendingFailure,proto3,oneof"`
}

type ThreadHaltReasonPb_PendingInterrupt 

type ThreadHaltReasonPb_PendingInterrupt struct {
	PendingInterrupt *PendingInterruptHaltReasonPb `protobuf:"bytes,3,opt,name=pending_interrupt,json=pendingInterrupt,proto3,oneof"`
}

type ThreadRunPb 

type ThreadRunPb struct {
	WfRunId               string                 `protobuf:"bytes,1,opt,name=wf_run_id,json=wfRunId,proto3" json:"wf_run_id,omitempty"`
	Number                int32                  `protobuf:"varint,2,opt,name=number,proto3" json:"number,omitempty"`
	Status                LHStatusPb             `protobuf:"varint,3,opt,name=status,proto3,enum=littlehorse.LHStatusPb" json:"status,omitempty"`
	WfSpecName            string                 `protobuf:"bytes,4,opt,name=wf_spec_name,json=wfSpecName,proto3" json:"wf_spec_name,omitempty"`
	WfSpecVersion         int32                  `protobuf:"varint,5,opt,name=wf_spec_version,json=wfSpecVersion,proto3" json:"wf_spec_version,omitempty"`
	ThreadSpecName        string                 `protobuf:"bytes,6,opt,name=thread_spec_name,json=threadSpecName,proto3" json:"thread_spec_name,omitempty"`
	StartTime             *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime               *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=end_time,json=endTime,proto3,oneof" json:"end_time,omitempty"`
	ErrorMessage          *string                `protobuf:"bytes,9,opt,name=error_message,json=errorMessage,proto3,oneof" json:"error_message,omitempty"`
	ResultCode            *TaskResultCodePb      `` /* 133-byte string literal not displayed */
	ChildThreadIds        []int32                `protobuf:"varint,11,rep,packed,name=child_thread_ids,json=childThreadIds,proto3" json:"child_thread_ids,omitempty"`
	ParentThreadId        *int32                 `protobuf:"varint,12,opt,name=parent_thread_id,json=parentThreadId,proto3,oneof" json:"parent_thread_id,omitempty"`
	HaltReasons           []*ThreadHaltReasonPb  `protobuf:"bytes,13,rep,name=halt_reasons,json=haltReasons,proto3" json:"halt_reasons,omitempty"`
	InterruptTriggerId    *ExternalEventIdPb     `protobuf:"bytes,14,opt,name=interrupt_trigger_id,json=interruptTriggerId,proto3,oneof" json:"interrupt_trigger_id,omitempty"`
	FailureBeingHandled   *FailureBeingHandledPb `` /* 127-byte string literal not displayed */
	CurrentNodePosition   int32                  `protobuf:"varint,16,opt,name=current_node_position,json=currentNodePosition,proto3" json:"current_node_position,omitempty"`
	HandledFailedChildren []int32                `` /* 135-byte string literal not displayed */
	Type                  ThreadTypePb           `protobuf:"varint,18,opt,name=type,proto3,enum=littlehorse.ThreadTypePb" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*ThreadRunPb) Descriptor deprecated 

func (*ThreadRunPb) Descriptor() ([]byte, []int)

Deprecated: Use ThreadRunPb.ProtoReflect.Descriptor instead.

func (*ThreadRunPb) GetChildThreadIds 

func (x *ThreadRunPb) GetChildThreadIds() []int32

func (*ThreadRunPb) GetCurrentNodePosition 

func (x *ThreadRunPb) GetCurrentNodePosition() int32

func (*ThreadRunPb) GetEndTime 

func (x *ThreadRunPb) GetEndTime() *timestamppb.Timestamp

func (*ThreadRunPb) GetErrorMessage 

func (x *ThreadRunPb) GetErrorMessage() string

func (*ThreadRunPb) GetFailureBeingHandled 

func (x *ThreadRunPb) GetFailureBeingHandled() *FailureBeingHandledPb

func (*ThreadRunPb) GetHaltReasons 

func (x *ThreadRunPb) GetHaltReasons() []*ThreadHaltReasonPb

func (*ThreadRunPb) GetHandledFailedChildren 

func (x *ThreadRunPb) GetHandledFailedChildren() []int32

func (*ThreadRunPb) GetInterruptTriggerId 

func (x *ThreadRunPb) GetInterruptTriggerId() *ExternalEventIdPb

func (*ThreadRunPb) GetNumber 

func (x *ThreadRunPb) GetNumber() int32

func (*ThreadRunPb) GetParentThreadId 

func (x *ThreadRunPb) GetParentThreadId() int32

func (*ThreadRunPb) GetResultCode 

func (x *ThreadRunPb) GetResultCode() TaskResultCodePb

func (*ThreadRunPb) GetStartTime 

func (x *ThreadRunPb) GetStartTime() *timestamppb.Timestamp

func (*ThreadRunPb) GetStatus 

func (x *ThreadRunPb) GetStatus() LHStatusPb

func (*ThreadRunPb) GetThreadSpecName 

func (x *ThreadRunPb) GetThreadSpecName() string

func (*ThreadRunPb) GetType 

func (x *ThreadRunPb) GetType() ThreadTypePb

func (*ThreadRunPb) GetWfRunId 

func (x *ThreadRunPb) GetWfRunId() string

func (*ThreadRunPb) GetWfSpecName 

func (x *ThreadRunPb) GetWfSpecName() string

func (*ThreadRunPb) GetWfSpecVersion 

func (x *ThreadRunPb) GetWfSpecVersion() int32

func (*ThreadRunPb) ProtoMessage 

func (*ThreadRunPb) ProtoMessage()

func (*ThreadRunPb) ProtoReflect 

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

func (*ThreadRunPb) Reset 

func (x *ThreadRunPb) Reset()

func (*ThreadRunPb) String 

func (x *ThreadRunPb) String() string

type ThreadSpecPb 

type ThreadSpecPb struct {
	Nodes         map[string]*NodePb `` /* 151-byte string literal not displayed */
	VariableDefs  []*VariableDefPb   `protobuf:"bytes,2,rep,name=variable_defs,json=variableDefs,proto3" json:"variable_defs,omitempty"`
	InterruptDefs []*InterruptDefPb  `protobuf:"bytes,3,rep,name=interrupt_defs,json=interruptDefs,proto3" json:"interrupt_defs,omitempty"`
	// contains filtered or unexported fields
}

func (*ThreadSpecPb) Descriptor deprecated 

func (*ThreadSpecPb) Descriptor() ([]byte, []int)

Deprecated: Use ThreadSpecPb.ProtoReflect.Descriptor instead.

func (*ThreadSpecPb) GetInterruptDefs 

func (x *ThreadSpecPb) GetInterruptDefs() []*InterruptDefPb

func (*ThreadSpecPb) GetNodes 

func (x *ThreadSpecPb) GetNodes() map[string]*NodePb

func (*ThreadSpecPb) GetVariableDefs 

func (x *ThreadSpecPb) GetVariableDefs() []*VariableDefPb

func (*ThreadSpecPb) ProtoMessage 

func (*ThreadSpecPb) ProtoMessage()

func (*ThreadSpecPb) ProtoReflect 

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

func (*ThreadSpecPb) Reset 

func (x *ThreadSpecPb) Reset()

func (*ThreadSpecPb) String 

func (x *ThreadSpecPb) String() string

type ThreadStartOePb 

type ThreadStartOePb struct {
	Variables       map[string]*VariableValuePb `` /* 159-byte string literal not displayed */
	ThreadRunNumber int32                       `protobuf:"varint,2,opt,name=thread_run_number,json=threadRunNumber,proto3" json:"thread_run_number,omitempty"`
	ThreadSpecName  string                      `protobuf:"bytes,3,opt,name=thread_spec_name,json=threadSpecName,proto3" json:"thread_spec_name,omitempty"`
	ParentThread    *int32                      `protobuf:"varint,4,opt,name=parent_thread,json=parentThread,proto3,oneof" json:"parent_thread,omitempty"`
	Type            ThreadTypePb                `protobuf:"varint,5,opt,name=type,proto3,enum=littlehorse.ThreadTypePb" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*ThreadStartOePb) Descriptor deprecated 

func (*ThreadStartOePb) Descriptor() ([]byte, []int)

Deprecated: Use ThreadStartOePb.ProtoReflect.Descriptor instead.

func (*ThreadStartOePb) GetParentThread 

func (x *ThreadStartOePb) GetParentThread() int32

func (*ThreadStartOePb) GetThreadRunNumber 

func (x *ThreadStartOePb) GetThreadRunNumber() int32

func (*ThreadStartOePb) GetThreadSpecName 

func (x *ThreadStartOePb) GetThreadSpecName() string

func (*ThreadStartOePb) GetType 

func (x *ThreadStartOePb) GetType() ThreadTypePb

func (*ThreadStartOePb) GetVariables 

func (x *ThreadStartOePb) GetVariables() map[string]*VariableValuePb

func (*ThreadStartOePb) ProtoMessage 

func (*ThreadStartOePb) ProtoMessage()

func (*ThreadStartOePb) ProtoReflect 

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

func (*ThreadStartOePb) Reset 

func (x *ThreadStartOePb) Reset()

func (*ThreadStartOePb) String 

func (x *ThreadStartOePb) String() string

type ThreadStatusOePb 

type ThreadStatusOePb struct {
	Status          LHStatusPb `protobuf:"varint,1,opt,name=status,proto3,enum=littlehorse.LHStatusPb" json:"status,omitempty"`
	ThreadRunNumber int32      `protobuf:"varint,2,opt,name=thread_run_number,json=threadRunNumber,proto3" json:"thread_run_number,omitempty"`
	// contains filtered or unexported fields
}

func (*ThreadStatusOePb) Descriptor deprecated 

func (*ThreadStatusOePb) Descriptor() ([]byte, []int)

Deprecated: Use ThreadStatusOePb.ProtoReflect.Descriptor instead.

func (*ThreadStatusOePb) GetStatus 

func (x *ThreadStatusOePb) GetStatus() LHStatusPb

func (*ThreadStatusOePb) GetThreadRunNumber 

func (x *ThreadStatusOePb) GetThreadRunNumber() int32

func (*ThreadStatusOePb) ProtoMessage 

func (*ThreadStatusOePb) ProtoMessage()

func (*ThreadStatusOePb) ProtoReflect 

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

func (*ThreadStatusOePb) Reset 

func (x *ThreadStatusOePb) Reset()

func (*ThreadStatusOePb) String 

func (x *ThreadStatusOePb) String() string

type ThreadTypePb 

type ThreadTypePb int32
const (
	ThreadTypePb_ENTRYPOINT      ThreadTypePb = 0
	ThreadTypePb_CHILD           ThreadTypePb = 1
	ThreadTypePb_INTERRUPT       ThreadTypePb = 2
	ThreadTypePb_FAILURE_HANDLER ThreadTypePb = 3
)

func (ThreadTypePb) Descriptor 

func (ThreadTypePb) Descriptor() protoreflect.EnumDescriptor

func (ThreadTypePb) Enum 

func (x ThreadTypePb) Enum() *ThreadTypePb

func (ThreadTypePb) EnumDescriptor deprecated 

func (ThreadTypePb) EnumDescriptor() ([]byte, []int)

Deprecated: Use ThreadTypePb.Descriptor instead.

func (ThreadTypePb) Number 

func (x ThreadTypePb) Number() protoreflect.EnumNumber

func (ThreadTypePb) String 

func (x ThreadTypePb) String() string

func (ThreadTypePb) Type 

func (ThreadTypePb) Type() protoreflect.EnumType

type UnimplementedLHPublicApiServer 

type UnimplementedLHPublicApiServer struct {
}

UnimplementedLHPublicApiServer must be embedded to have forward compatible implementations.

func (UnimplementedLHPublicApiServer) DeleteExternalEventDef 

func (UnimplementedLHPublicApiServer) DeleteExternalEventDef(context.Context, *DeleteExternalEventDefPb) (*DeleteObjectReplyPb, error)

func (UnimplementedLHPublicApiServer) DeleteTaskDef 

func (UnimplementedLHPublicApiServer) DeleteTaskDef(context.Context, *DeleteTaskDefPb) (*DeleteObjectReplyPb, error)

func (UnimplementedLHPublicApiServer) DeleteWfRun 

func (UnimplementedLHPublicApiServer) DeleteWfRun(context.Context, *DeleteWfRunPb) (*DeleteObjectReplyPb, error)

func (UnimplementedLHPublicApiServer) DeleteWfSpec 

func (UnimplementedLHPublicApiServer) DeleteWfSpec(context.Context, *DeleteWfSpecPb) (*DeleteObjectReplyPb, error)

func (UnimplementedLHPublicApiServer) GetExternalEvent 

func (UnimplementedLHPublicApiServer) GetExternalEvent(context.Context, *ExternalEventIdPb) (*GetExternalEventReplyPb, error)

func (UnimplementedLHPublicApiServer) GetExternalEventDef 

func (UnimplementedLHPublicApiServer) GetExternalEventDef(context.Context, *ExternalEventDefIdPb) (*GetExternalEventDefReplyPb, error)

func (UnimplementedLHPublicApiServer) GetLatestWfSpec 

func (UnimplementedLHPublicApiServer) GetLatestWfSpec(context.Context, *GetLatestWfSpecPb) (*GetWfSpecReplyPb, error)

func (UnimplementedLHPublicApiServer) GetNodeRun 

func (UnimplementedLHPublicApiServer) GetNodeRun(context.Context, *NodeRunIdPb) (*GetNodeRunReplyPb, error)

func (UnimplementedLHPublicApiServer) GetTaskDef 

func (UnimplementedLHPublicApiServer) GetTaskDef(context.Context, *TaskDefIdPb) (*GetTaskDefReplyPb, error)

func (UnimplementedLHPublicApiServer) GetVariable 

func (UnimplementedLHPublicApiServer) GetVariable(context.Context, *VariableIdPb) (*GetVariableReplyPb, error)

func (UnimplementedLHPublicApiServer) GetWfRun 

func (UnimplementedLHPublicApiServer) GetWfRun(context.Context, *WfRunIdPb) (*GetWfRunReplyPb, error)

func (UnimplementedLHPublicApiServer) GetWfSpec 

func (UnimplementedLHPublicApiServer) GetWfSpec(context.Context, *WfSpecIdPb) (*GetWfSpecReplyPb, error)

func (UnimplementedLHPublicApiServer) HealthCheck 

func (UnimplementedLHPublicApiServer) HealthCheck(context.Context, *HealthCheckPb) (*HealthCheckReplyPb, error)

func (UnimplementedLHPublicApiServer) ListExternalEvents 

func (UnimplementedLHPublicApiServer) ListExternalEvents(context.Context, *ListExternalEventsPb) (*ListExternalEventsReplyPb, error)

func (UnimplementedLHPublicApiServer) ListNodeRuns 

func (UnimplementedLHPublicApiServer) ListNodeRuns(context.Context, *ListNodeRunsPb) (*ListNodeRunsReplyPb, error)

func (UnimplementedLHPublicApiServer) ListTaskDefMetrics 

func (UnimplementedLHPublicApiServer) ListTaskDefMetrics(context.Context, *ListTaskMetricsPb) (*ListTaskMetricsReplyPb, error)

func (UnimplementedLHPublicApiServer) ListVariables 

func (UnimplementedLHPublicApiServer) ListVariables(context.Context, *ListVariablesPb) (*ListVariablesReplyPb, error)

func (UnimplementedLHPublicApiServer) ListWfSpecMetrics 

func (UnimplementedLHPublicApiServer) ListWfSpecMetrics(context.Context, *ListWfMetricsPb) (*ListWfMetricsReplyPb, error)

func (UnimplementedLHPublicApiServer) PollTask 

func (UnimplementedLHPublicApiServer) PollTask(LHPublicApi_PollTaskServer) error

func (UnimplementedLHPublicApiServer) PutExternalEvent 

func (UnimplementedLHPublicApiServer) PutExternalEvent(context.Context, *PutExternalEventPb) (*PutExternalEventReplyPb, error)

func (UnimplementedLHPublicApiServer) PutExternalEventDef 

func (UnimplementedLHPublicApiServer) PutExternalEventDef(context.Context, *PutExternalEventDefPb) (*PutExternalEventDefReplyPb, error)

func (UnimplementedLHPublicApiServer) PutTaskDef 

func (UnimplementedLHPublicApiServer) PutTaskDef(context.Context, *PutTaskDefPb) (*PutTaskDefReplyPb, error)

func (UnimplementedLHPublicApiServer) PutWfSpec 

func (UnimplementedLHPublicApiServer) PutWfSpec(context.Context, *PutWfSpecPb) (*PutWfSpecReplyPb, error)

func (UnimplementedLHPublicApiServer) RegisterTaskWorker 

func (UnimplementedLHPublicApiServer) RegisterTaskWorker(context.Context, *RegisterTaskWorkerPb) (*RegisterTaskWorkerReplyPb, error)

func (UnimplementedLHPublicApiServer) ReportTask 

func (UnimplementedLHPublicApiServer) ReportTask(context.Context, *TaskResultEventPb) (*ReportTaskReplyPb, error)

func (UnimplementedLHPublicApiServer) ResumeWfRun 

func (UnimplementedLHPublicApiServer) ResumeWfRun(context.Context, *ResumeWfRunPb) (*ResumeWfRunReplyPb, error)

func (UnimplementedLHPublicApiServer) RunWf 

func (UnimplementedLHPublicApiServer) RunWf(context.Context, *RunWfPb) (*RunWfReplyPb, error)

func (UnimplementedLHPublicApiServer) SearchExternalEvent 

func (UnimplementedLHPublicApiServer) SearchExternalEvent(context.Context, *SearchExternalEventPb) (*SearchExternalEventReplyPb, error)

func (UnimplementedLHPublicApiServer) SearchExternalEventDef 

func (UnimplementedLHPublicApiServer) SearchExternalEventDef(context.Context, *SearchExternalEventDefPb) (*SearchExternalEventDefReplyPb, error)

func (UnimplementedLHPublicApiServer) SearchNodeRun 

func (UnimplementedLHPublicApiServer) SearchNodeRun(context.Context, *SearchNodeRunPb) (*SearchNodeRunReplyPb, error)

func (UnimplementedLHPublicApiServer) SearchTaskDef 

func (UnimplementedLHPublicApiServer) SearchTaskDef(context.Context, *SearchTaskDefPb) (*SearchTaskDefReplyPb, error)

func (UnimplementedLHPublicApiServer) SearchVariable 

func (UnimplementedLHPublicApiServer) SearchVariable(context.Context, *SearchVariablePb) (*SearchVariableReplyPb, error)

func (UnimplementedLHPublicApiServer) SearchWfRun 

func (UnimplementedLHPublicApiServer) SearchWfRun(context.Context, *SearchWfRunPb) (*SearchWfRunReplyPb, error)

func (UnimplementedLHPublicApiServer) SearchWfSpec 

func (UnimplementedLHPublicApiServer) SearchWfSpec(context.Context, *SearchWfSpecPb) (*SearchWfSpecReplyPb, error)

func (UnimplementedLHPublicApiServer) StopWfRun 

func (UnimplementedLHPublicApiServer) StopWfRun(context.Context, *StopWfRunPb) (*StopWfRunReplyPb, error)

func (UnimplementedLHPublicApiServer) TaskDefMetrics 

func (UnimplementedLHPublicApiServer) TaskDefMetrics(context.Context, *TaskDefMetricsQueryPb) (*TaskDefMetricsReplyPb, error)

func (UnimplementedLHPublicApiServer) WfSpecMetrics 

func (UnimplementedLHPublicApiServer) WfSpecMetrics(context.Context, *WfSpecMetricsQueryPb) (*WfSpecMetricsReplyPb, error)

type UnsafeLHPublicApiServer 

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

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

type VarNameAndValPb 

type VarNameAndValPb struct {
	VarName string           `protobuf:"bytes,1,opt,name=var_name,json=varName,proto3" json:"var_name,omitempty"`
	Value   *VariableValuePb `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*VarNameAndValPb) Descriptor deprecated 

func (*VarNameAndValPb) Descriptor() ([]byte, []int)

Deprecated: Use VarNameAndValPb.ProtoReflect.Descriptor instead.

func (*VarNameAndValPb) GetValue 

func (x *VarNameAndValPb) GetValue() *VariableValuePb

func (*VarNameAndValPb) GetVarName 

func (x *VarNameAndValPb) GetVarName() string

func (*VarNameAndValPb) ProtoMessage 

func (*VarNameAndValPb) ProtoMessage()

func (*VarNameAndValPb) ProtoReflect 

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

func (*VarNameAndValPb) Reset 

func (x *VarNameAndValPb) Reset()

func (*VarNameAndValPb) String 

func (x *VarNameAndValPb) String() string

type VariableAssignmentPb 

type VariableAssignmentPb struct {
	JsonPath *string `protobuf:"bytes,1,opt,name=json_path,json=jsonPath,proto3,oneof" json:"json_path,omitempty"`
	// Types that are assignable to Source:
	//
	//	*VariableAssignmentPb_VariableName
	//	*VariableAssignmentPb_LiteralValue
	Source isVariableAssignmentPb_Source `protobuf_oneof:"source"`
	// contains filtered or unexported fields
}

func (*VariableAssignmentPb) Descriptor deprecated 

func (*VariableAssignmentPb) Descriptor() ([]byte, []int)

Deprecated: Use VariableAssignmentPb.ProtoReflect.Descriptor instead.

func (*VariableAssignmentPb) GetJsonPath 

func (x *VariableAssignmentPb) GetJsonPath() string

func (*VariableAssignmentPb) GetLiteralValue 

func (x *VariableAssignmentPb) GetLiteralValue() *VariableValuePb

func (*VariableAssignmentPb) GetSource 

func (m *VariableAssignmentPb) GetSource() isVariableAssignmentPb_Source

func (*VariableAssignmentPb) GetVariableName 

func (x *VariableAssignmentPb) GetVariableName() string

func (*VariableAssignmentPb) ProtoMessage 

func (*VariableAssignmentPb) ProtoMessage()

func (*VariableAssignmentPb) ProtoReflect 

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

func (*VariableAssignmentPb) Reset 

func (x *VariableAssignmentPb) Reset()

func (*VariableAssignmentPb) String 

func (x *VariableAssignmentPb) String() string

type VariableAssignmentPb_LiteralValue 

type VariableAssignmentPb_LiteralValue struct {
	LiteralValue *VariableValuePb `protobuf:"bytes,3,opt,name=literal_value,json=literalValue,proto3,oneof"`
}

type VariableAssignmentPb_VariableName 

type VariableAssignmentPb_VariableName struct {
	VariableName string `protobuf:"bytes,2,opt,name=variable_name,json=variableName,proto3,oneof"`
}

type VariableDefPb 

type VariableDefPb struct {
	Type     VariableTypePb `protobuf:"varint,1,opt,name=type,proto3,enum=littlehorse.VariableTypePb" json:"type,omitempty"`
	Name     string         `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Required bool           `protobuf:"varint,3,opt,name=required,proto3" json:"required,omitempty"`
	// contains filtered or unexported fields
}

func (*VariableDefPb) Descriptor deprecated 

func (*VariableDefPb) Descriptor() ([]byte, []int)

Deprecated: Use VariableDefPb.ProtoReflect.Descriptor instead.

func (*VariableDefPb) GetName 

func (x *VariableDefPb) GetName() string

func (*VariableDefPb) GetRequired 

func (x *VariableDefPb) GetRequired() bool

func (*VariableDefPb) GetType 

func (x *VariableDefPb) GetType() VariableTypePb

func (*VariableDefPb) ProtoMessage 

func (*VariableDefPb) ProtoMessage()

func (*VariableDefPb) ProtoReflect 

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

func (*VariableDefPb) Reset 

func (x *VariableDefPb) Reset()

func (*VariableDefPb) String 

func (x *VariableDefPb) String() string

type VariableIdPb 

type VariableIdPb struct {
	WfRunId         string `protobuf:"bytes,1,opt,name=wf_run_id,json=wfRunId,proto3" json:"wf_run_id,omitempty"`
	ThreadRunNumber int32  `protobuf:"varint,2,opt,name=thread_run_number,json=threadRunNumber,proto3" json:"thread_run_number,omitempty"`
	Name            string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*VariableIdPb) Descriptor deprecated 

func (*VariableIdPb) Descriptor() ([]byte, []int)

Deprecated: Use VariableIdPb.ProtoReflect.Descriptor instead.

func (*VariableIdPb) GetName 

func (x *VariableIdPb) GetName() string

func (*VariableIdPb) GetThreadRunNumber 

func (x *VariableIdPb) GetThreadRunNumber() int32

func (*VariableIdPb) GetWfRunId 

func (x *VariableIdPb) GetWfRunId() string

func (*VariableIdPb) ProtoMessage 

func (*VariableIdPb) ProtoMessage()

func (*VariableIdPb) ProtoReflect 

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

func (*VariableIdPb) Reset 

func (x *VariableIdPb) Reset()

func (*VariableIdPb) String 

func (x *VariableIdPb) String() string

type VariableMutationPb 

type VariableMutationPb struct {
	LhsName     string                 `protobuf:"bytes,1,opt,name=lhs_name,json=lhsName,proto3" json:"lhs_name,omitempty"`
	LhsJsonPath *string                `protobuf:"bytes,2,opt,name=lhs_json_path,json=lhsJsonPath,proto3,oneof" json:"lhs_json_path,omitempty"`
	Operation   VariableMutationTypePb `protobuf:"varint,3,opt,name=operation,proto3,enum=littlehorse.VariableMutationTypePb" json:"operation,omitempty"`
	// Types that are assignable to RhsValue:
	//
	//	*VariableMutationPb_SourceVariable
	//	*VariableMutationPb_LiteralValue
	//	*VariableMutationPb_NodeOutput
	RhsValue isVariableMutationPb_RhsValue `protobuf_oneof:"rhs_value"`
	// contains filtered or unexported fields
}

func (*VariableMutationPb) Descriptor deprecated 

func (*VariableMutationPb) Descriptor() ([]byte, []int)

Deprecated: Use VariableMutationPb.ProtoReflect.Descriptor instead.

func (*VariableMutationPb) GetLhsJsonPath 

func (x *VariableMutationPb) GetLhsJsonPath() string

func (*VariableMutationPb) GetLhsName 

func (x *VariableMutationPb) GetLhsName() string

func (*VariableMutationPb) GetLiteralValue 

func (x *VariableMutationPb) GetLiteralValue() *VariableValuePb

func (*VariableMutationPb) GetNodeOutput 

func (x *VariableMutationPb) GetNodeOutput() *VariableMutationPb_NodeOutputSourcePb

func (*VariableMutationPb) GetOperation 

func (x *VariableMutationPb) GetOperation() VariableMutationTypePb

func (*VariableMutationPb) GetRhsValue 

func (m *VariableMutationPb) GetRhsValue() isVariableMutationPb_RhsValue

func (*VariableMutationPb) GetSourceVariable 

func (x *VariableMutationPb) GetSourceVariable() *VariableAssignmentPb

func (*VariableMutationPb) ProtoMessage 

func (*VariableMutationPb) ProtoMessage()

func (*VariableMutationPb) ProtoReflect 

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

func (*VariableMutationPb) Reset 

func (x *VariableMutationPb) Reset()

func (*VariableMutationPb) String 

func (x *VariableMutationPb) String() string

type VariableMutationPb_LiteralValue 

type VariableMutationPb_LiteralValue struct {
	LiteralValue *VariableValuePb `protobuf:"bytes,5,opt,name=literal_value,json=literalValue,proto3,oneof"`
}

type VariableMutationPb_NodeOutput 

type VariableMutationPb_NodeOutput struct {
	NodeOutput *VariableMutationPb_NodeOutputSourcePb `protobuf:"bytes,6,opt,name=node_output,json=nodeOutput,proto3,oneof"`
}

type VariableMutationPb_NodeOutputSourcePb 

type VariableMutationPb_NodeOutputSourcePb struct {
	Jsonpath *string `protobuf:"bytes,10,opt,name=jsonpath,proto3,oneof" json:"jsonpath,omitempty"`
	// contains filtered or unexported fields
}

func (*VariableMutationPb_NodeOutputSourcePb) Descriptor deprecated 

func (*VariableMutationPb_NodeOutputSourcePb) Descriptor() ([]byte, []int)

Deprecated: Use VariableMutationPb_NodeOutputSourcePb.ProtoReflect.Descriptor instead.

func (*VariableMutationPb_NodeOutputSourcePb) GetJsonpath 

func (x *VariableMutationPb_NodeOutputSourcePb) GetJsonpath() string

func (*VariableMutationPb_NodeOutputSourcePb) ProtoMessage 

func (*VariableMutationPb_NodeOutputSourcePb) ProtoMessage()

func (*VariableMutationPb_NodeOutputSourcePb) ProtoReflect 

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

func (*VariableMutationPb_NodeOutputSourcePb) Reset 

func (x *VariableMutationPb_NodeOutputSourcePb) Reset()

func (*VariableMutationPb_NodeOutputSourcePb) String 

func (x *VariableMutationPb_NodeOutputSourcePb) String() string

type VariableMutationPb_SourceVariable 

type VariableMutationPb_SourceVariable struct {
	SourceVariable *VariableAssignmentPb `protobuf:"bytes,4,opt,name=source_variable,json=sourceVariable,proto3,oneof"`
}

type VariableMutationTypePb 

type VariableMutationTypePb int32
const (
	VariableMutationTypePb_ASSIGN            VariableMutationTypePb = 0
	VariableMutationTypePb_ADD               VariableMutationTypePb = 1
	VariableMutationTypePb_EXTEND            VariableMutationTypePb = 2
	VariableMutationTypePb_SUBTRACT          VariableMutationTypePb = 3
	VariableMutationTypePb_MULTIPLY          VariableMutationTypePb = 4
	VariableMutationTypePb_DIVIDE            VariableMutationTypePb = 5
	VariableMutationTypePb_REMOVE_IF_PRESENT VariableMutationTypePb = 6
	VariableMutationTypePb_REMOVE_INDEX      VariableMutationTypePb = 7
	VariableMutationTypePb_REMOVE_KEY        VariableMutationTypePb = 8
)

func (VariableMutationTypePb) Descriptor 

func (VariableMutationTypePb) Descriptor() protoreflect.EnumDescriptor

func (VariableMutationTypePb) Enum 

func (x VariableMutationTypePb) Enum() *VariableMutationTypePb

func (VariableMutationTypePb) EnumDescriptor deprecated 

func (VariableMutationTypePb) EnumDescriptor() ([]byte, []int)

Deprecated: Use VariableMutationTypePb.Descriptor instead.

func (VariableMutationTypePb) Number 

func (x VariableMutationTypePb) Number() protoreflect.EnumNumber

func (VariableMutationTypePb) String 

func (x VariableMutationTypePb) String() string

func (VariableMutationTypePb) Type 

func (VariableMutationTypePb) Type() protoreflect.EnumType

type VariablePb 

type VariablePb struct {
	Value           *VariableValuePb       `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	WfRunId         string                 `protobuf:"bytes,2,opt,name=wf_run_id,json=wfRunId,proto3" json:"wf_run_id,omitempty"`
	ThreadRunNumber int32                  `protobuf:"varint,3,opt,name=thread_run_number,json=threadRunNumber,proto3" json:"thread_run_number,omitempty"`
	Name            string                 `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Date            *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=date,proto3" json:"date,omitempty"`
	// contains filtered or unexported fields
}

func (*VariablePb) Descriptor deprecated 

func (*VariablePb) Descriptor() ([]byte, []int)

Deprecated: Use VariablePb.ProtoReflect.Descriptor instead.

func (*VariablePb) GetDate 

func (x *VariablePb) GetDate() *timestamppb.Timestamp

func (*VariablePb) GetName 

func (x *VariablePb) GetName() string

func (*VariablePb) GetThreadRunNumber 

func (x *VariablePb) GetThreadRunNumber() int32

func (*VariablePb) GetValue 

func (x *VariablePb) GetValue() *VariableValuePb

func (*VariablePb) GetWfRunId 

func (x *VariablePb) GetWfRunId() string

func (*VariablePb) ProtoMessage 

func (*VariablePb) ProtoMessage()

func (*VariablePb) ProtoReflect 

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

func (*VariablePb) Reset 

func (x *VariablePb) Reset()

func (*VariablePb) String 

func (x *VariablePb) String() string

type VariableTypePb 

type VariableTypePb int32

Variable 

const (
	VariableTypePb_JSON_OBJ VariableTypePb = 0
	VariableTypePb_JSON_ARR VariableTypePb = 1
	VariableTypePb_DOUBLE   VariableTypePb = 2
	VariableTypePb_BOOL     VariableTypePb = 3
	VariableTypePb_STR      VariableTypePb = 4
	VariableTypePb_INT      VariableTypePb = 5
	VariableTypePb_BYTES    VariableTypePb = 6
	VariableTypePb_NULL     VariableTypePb = 7
)

func (VariableTypePb) Descriptor 

func (VariableTypePb) Descriptor() protoreflect.EnumDescriptor

func (VariableTypePb) Enum 

func (x VariableTypePb) Enum() *VariableTypePb

func (VariableTypePb) EnumDescriptor deprecated 

func (VariableTypePb) EnumDescriptor() ([]byte, []int)

Deprecated: Use VariableTypePb.Descriptor instead.

func (VariableTypePb) Number 

func (x VariableTypePb) Number() protoreflect.EnumNumber

func (VariableTypePb) String 

func (x VariableTypePb) String() string

func (VariableTypePb) Type 

func (VariableTypePb) Type() protoreflect.EnumType

type VariableValuePb 

type VariableValuePb struct {
	Type    VariableTypePb `protobuf:"varint,1,opt,name=type,proto3,enum=littlehorse.VariableTypePb" json:"type,omitempty"`
	JsonObj *string        `protobuf:"bytes,2,opt,name=json_obj,json=jsonObj,proto3,oneof" json:"json_obj,omitempty"`
	JsonArr *string        `protobuf:"bytes,3,opt,name=json_arr,json=jsonArr,proto3,oneof" json:"json_arr,omitempty"`
	Double  *float64       `protobuf:"fixed64,4,opt,name=double,proto3,oneof" json:"double,omitempty"`
	Bool    *bool          `protobuf:"varint,5,opt,name=bool,proto3,oneof" json:"bool,omitempty"`
	Str     *string        `protobuf:"bytes,6,opt,name=str,proto3,oneof" json:"str,omitempty"`
	Int     *int64         `protobuf:"varint,7,opt,name=int,proto3,oneof" json:"int,omitempty"`
	Bytes   []byte         `protobuf:"bytes,8,opt,name=bytes,proto3,oneof" json:"bytes,omitempty"`
	// contains filtered or unexported fields
}

func (*VariableValuePb) Descriptor deprecated 

func (*VariableValuePb) Descriptor() ([]byte, []int)

Deprecated: Use VariableValuePb.ProtoReflect.Descriptor instead.

func (*VariableValuePb) GetBool 

func (x *VariableValuePb) GetBool() bool

func (*VariableValuePb) GetBytes 

func (x *VariableValuePb) GetBytes() []byte

func (*VariableValuePb) GetDouble 

func (x *VariableValuePb) GetDouble() float64

func (*VariableValuePb) GetInt 

func (x *VariableValuePb) GetInt() int64

func (*VariableValuePb) GetJsonArr 

func (x *VariableValuePb) GetJsonArr() string

func (*VariableValuePb) GetJsonObj 

func (x *VariableValuePb) GetJsonObj() string

func (*VariableValuePb) GetStr 

func (x *VariableValuePb) GetStr() string

func (*VariableValuePb) GetType 

func (x *VariableValuePb) GetType() VariableTypePb

func (*VariableValuePb) ProtoMessage 

func (*VariableValuePb) ProtoMessage()

func (*VariableValuePb) ProtoReflect 

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

func (*VariableValuePb) Reset 

func (x *VariableValuePb) Reset()

func (*VariableValuePb) String 

func (x *VariableValuePb) String() string

type WaitForThreadNodePb 

type WaitForThreadNodePb struct {
	ThreadRunNumber *VariableAssignmentPb `protobuf:"bytes,1,opt,name=thread_run_number,json=threadRunNumber,proto3" json:"thread_run_number,omitempty"`
	TimeoutSeconds  *VariableAssignmentPb `protobuf:"bytes,2,opt,name=timeout_seconds,json=timeoutSeconds,proto3" json:"timeout_seconds,omitempty"`
	// contains filtered or unexported fields
}

func (*WaitForThreadNodePb) Descriptor deprecated 

func (*WaitForThreadNodePb) Descriptor() ([]byte, []int)

Deprecated: Use WaitForThreadNodePb.ProtoReflect.Descriptor instead.

func (*WaitForThreadNodePb) GetThreadRunNumber 

func (x *WaitForThreadNodePb) GetThreadRunNumber() *VariableAssignmentPb

func (*WaitForThreadNodePb) GetTimeoutSeconds 

func (x *WaitForThreadNodePb) GetTimeoutSeconds() *VariableAssignmentPb

func (*WaitForThreadNodePb) ProtoMessage 

func (*WaitForThreadNodePb) ProtoMessage()

func (*WaitForThreadNodePb) ProtoReflect 

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

func (*WaitForThreadNodePb) Reset 

func (x *WaitForThreadNodePb) Reset()

func (*WaitForThreadNodePb) String 

func (x *WaitForThreadNodePb) String() string

type WaitThreadRunPb 

type WaitThreadRunPb struct {
	ThreadEndTime    *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=thread_end_time,json=threadEndTime,proto3,oneof" json:"thread_end_time,omitempty"`
	ThreadStatus     *LHStatusPb            `` /* 132-byte string literal not displayed */
	ThreadResultCode *TaskResultCodePb      `` /* 152-byte string literal not displayed */
	ThreadRunNumber  int32                  `protobuf:"varint,4,opt,name=thread_run_number,json=threadRunNumber,proto3" json:"thread_run_number,omitempty"`
	// contains filtered or unexported fields
}

func (*WaitThreadRunPb) Descriptor deprecated 

func (*WaitThreadRunPb) Descriptor() ([]byte, []int)

Deprecated: Use WaitThreadRunPb.ProtoReflect.Descriptor instead.

func (*WaitThreadRunPb) GetThreadEndTime 

func (x *WaitThreadRunPb) GetThreadEndTime() *timestamppb.Timestamp

func (*WaitThreadRunPb) GetThreadResultCode 

func (x *WaitThreadRunPb) GetThreadResultCode() TaskResultCodePb

func (*WaitThreadRunPb) GetThreadRunNumber 

func (x *WaitThreadRunPb) GetThreadRunNumber() int32

func (*WaitThreadRunPb) GetThreadStatus 

func (x *WaitThreadRunPb) GetThreadStatus() LHStatusPb

func (*WaitThreadRunPb) ProtoMessage 

func (*WaitThreadRunPb) ProtoMessage()

func (*WaitThreadRunPb) ProtoReflect 

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

func (*WaitThreadRunPb) Reset 

func (x *WaitThreadRunPb) Reset()

func (*WaitThreadRunPb) String 

func (x *WaitThreadRunPb) String() string

type WaitingForExtEvtOePb 

type WaitingForExtEvtOePb struct {
	ThreadRunNumber int32  `protobuf:"varint,1,opt,name=thread_run_number,json=threadRunNumber,proto3" json:"thread_run_number,omitempty"`
	NodeRunPosition int32  `protobuf:"varint,2,opt,name=node_run_position,json=nodeRunPosition,proto3" json:"node_run_position,omitempty"`
	ExtEvtDefName   string `protobuf:"bytes,3,opt,name=ext_evt_def_name,json=extEvtDefName,proto3" json:"ext_evt_def_name,omitempty"`
	// contains filtered or unexported fields
}

func (*WaitingForExtEvtOePb) Descriptor deprecated 

func (*WaitingForExtEvtOePb) Descriptor() ([]byte, []int)

Deprecated: Use WaitingForExtEvtOePb.ProtoReflect.Descriptor instead.

func (*WaitingForExtEvtOePb) GetExtEvtDefName 

func (x *WaitingForExtEvtOePb) GetExtEvtDefName() string

func (*WaitingForExtEvtOePb) GetNodeRunPosition 

func (x *WaitingForExtEvtOePb) GetNodeRunPosition() int32

func (*WaitingForExtEvtOePb) GetThreadRunNumber 

func (x *WaitingForExtEvtOePb) GetThreadRunNumber() int32

func (*WaitingForExtEvtOePb) ProtoMessage 

func (*WaitingForExtEvtOePb) ProtoMessage()

func (*WaitingForExtEvtOePb) ProtoReflect 

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

func (*WaitingForExtEvtOePb) Reset 

func (x *WaitingForExtEvtOePb) Reset()

func (*WaitingForExtEvtOePb) String 

func (x *WaitingForExtEvtOePb) String() string

type WfRunIdPb 

type WfRunIdPb struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

WfRun

func (*WfRunIdPb) Descriptor deprecated 

func (*WfRunIdPb) Descriptor() ([]byte, []int)

Deprecated: Use WfRunIdPb.ProtoReflect.Descriptor instead.

func (*WfRunIdPb) GetId 

func (x *WfRunIdPb) GetId() string

func (*WfRunIdPb) ProtoMessage 

func (*WfRunIdPb) ProtoMessage()

func (*WfRunIdPb) ProtoReflect 

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

func (*WfRunIdPb) Reset 

func (x *WfRunIdPb) Reset()

func (*WfRunIdPb) String 

func (x *WfRunIdPb) String() string

type WfRunPb 

type WfRunPb struct {

	// Yeah ok it's similar to WfRunStatePb but hear me out
	Id                string                     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	WfSpecName        string                     `protobuf:"bytes,2,opt,name=wf_spec_name,json=wfSpecName,proto3" json:"wf_spec_name,omitempty"`
	WfSpecVersion     int32                      `protobuf:"varint,3,opt,name=wf_spec_version,json=wfSpecVersion,proto3" json:"wf_spec_version,omitempty"`
	Status            LHStatusPb                 `protobuf:"varint,4,opt,name=status,proto3,enum=littlehorse.LHStatusPb" json:"status,omitempty"`
	LastUpdateOffset  int64                      `protobuf:"varint,5,opt,name=last_update_offset,json=lastUpdateOffset,proto3" json:"last_update_offset,omitempty"`
	StartTime         *timestamppb.Timestamp     `protobuf:"bytes,6,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime           *timestamppb.Timestamp     `protobuf:"bytes,7,opt,name=end_time,json=endTime,proto3,oneof" json:"end_time,omitempty"`
	ThreadRuns        []*ThreadRunPb             `protobuf:"bytes,8,rep,name=thread_runs,json=threadRuns,proto3" json:"thread_runs,omitempty"`
	PendingInterrupts []*PendingInterruptPb      `protobuf:"bytes,9,rep,name=pending_interrupts,json=pendingInterrupts,proto3" json:"pending_interrupts,omitempty"`
	PendingFailures   []*PendingFailureHandlerPb `protobuf:"bytes,10,rep,name=pending_failures,json=pendingFailures,proto3" json:"pending_failures,omitempty"`
	// contains filtered or unexported fields
}

func (*WfRunPb) Descriptor deprecated 

func (*WfRunPb) Descriptor() ([]byte, []int)

Deprecated: Use WfRunPb.ProtoReflect.Descriptor instead.

func (*WfRunPb) GetEndTime 

func (x *WfRunPb) GetEndTime() *timestamppb.Timestamp

func (*WfRunPb) GetId 

func (x *WfRunPb) GetId() string

func (*WfRunPb) GetLastUpdateOffset 

func (x *WfRunPb) GetLastUpdateOffset() int64

func (*WfRunPb) GetPendingFailures 

func (x *WfRunPb) GetPendingFailures() []*PendingFailureHandlerPb

func (*WfRunPb) GetPendingInterrupts 

func (x *WfRunPb) GetPendingInterrupts() []*PendingInterruptPb

func (*WfRunPb) GetStartTime 

func (x *WfRunPb) GetStartTime() *timestamppb.Timestamp

func (*WfRunPb) GetStatus 

func (x *WfRunPb) GetStatus() LHStatusPb

func (*WfRunPb) GetThreadRuns 

func (x *WfRunPb) GetThreadRuns() []*ThreadRunPb

func (*WfRunPb) GetWfSpecName 

func (x *WfRunPb) GetWfSpecName() string

func (*WfRunPb) GetWfSpecVersion 

func (x *WfRunPb) GetWfSpecVersion() int32

func (*WfRunPb) ProtoMessage 

func (*WfRunPb) ProtoMessage()

func (*WfRunPb) ProtoReflect 

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

func (*WfRunPb) Reset 

func (x *WfRunPb) Reset()

func (*WfRunPb) String 

func (x *WfRunPb) String() string

type WfRunStartOePb 

type WfRunStartOePb struct {
	WfSpecName    string `protobuf:"bytes,1,opt,name=wf_spec_name,json=wfSpecName,proto3" json:"wf_spec_name,omitempty"`
	WfSpecVersion int32  `protobuf:"varint,2,opt,name=wf_spec_version,json=wfSpecVersion,proto3" json:"wf_spec_version,omitempty"`
	// contains filtered or unexported fields
}

func (*WfRunStartOePb) Descriptor deprecated 

func (*WfRunStartOePb) Descriptor() ([]byte, []int)

Deprecated: Use WfRunStartOePb.ProtoReflect.Descriptor instead.

func (*WfRunStartOePb) GetWfSpecName 

func (x *WfRunStartOePb) GetWfSpecName() string

func (*WfRunStartOePb) GetWfSpecVersion 

func (x *WfRunStartOePb) GetWfSpecVersion() int32

func (*WfRunStartOePb) ProtoMessage 

func (*WfRunStartOePb) ProtoMessage()

func (*WfRunStartOePb) ProtoReflect 

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

func (*WfRunStartOePb) Reset 

func (x *WfRunStartOePb) Reset()

func (*WfRunStartOePb) String 

func (x *WfRunStartOePb) String() string

type WfRunStatusOePb 

type WfRunStatusOePb struct {
	Status LHStatusPb `protobuf:"varint,1,opt,name=status,proto3,enum=littlehorse.LHStatusPb" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*WfRunStatusOePb) Descriptor deprecated 

func (*WfRunStatusOePb) Descriptor() ([]byte, []int)

Deprecated: Use WfRunStatusOePb.ProtoReflect.Descriptor instead.

func (*WfRunStatusOePb) GetStatus 

func (x *WfRunStatusOePb) GetStatus() LHStatusPb

func (*WfRunStatusOePb) ProtoMessage 

func (*WfRunStatusOePb) ProtoMessage()

func (*WfRunStatusOePb) ProtoReflect 

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

func (*WfRunStatusOePb) Reset 

func (x *WfRunStatusOePb) Reset()

func (*WfRunStatusOePb) String 

func (x *WfRunStatusOePb) String() string

type WfSpecIdPb 

type WfSpecIdPb struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version int32  `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*WfSpecIdPb) Descriptor deprecated 

func (*WfSpecIdPb) Descriptor() ([]byte, []int)

Deprecated: Use WfSpecIdPb.ProtoReflect.Descriptor instead.

func (*WfSpecIdPb) GetName 

func (x *WfSpecIdPb) GetName() string

func (*WfSpecIdPb) GetVersion 

func (x *WfSpecIdPb) GetVersion() int32

func (*WfSpecIdPb) ProtoMessage 

func (*WfSpecIdPb) ProtoMessage()

func (*WfSpecIdPb) ProtoReflect 

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

func (*WfSpecIdPb) Reset 

func (x *WfSpecIdPb) Reset()

func (*WfSpecIdPb) String 

func (x *WfSpecIdPb) String() string

type WfSpecMetricsIdPb 

type WfSpecMetricsIdPb struct {
	WindowStart   *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=window_start,json=windowStart,proto3" json:"window_start,omitempty"`
	WindowType    MetricsWindowLengthPb  `` /* 131-byte string literal not displayed */
	WfSpecName    string                 `protobuf:"bytes,3,opt,name=wf_spec_name,json=wfSpecName,proto3" json:"wf_spec_name,omitempty"`
	WfSpecVersion int32                  `protobuf:"varint,4,opt,name=wf_spec_version,json=wfSpecVersion,proto3" json:"wf_spec_version,omitempty"`
	// contains filtered or unexported fields
}

func (*WfSpecMetricsIdPb) Descriptor deprecated 

func (*WfSpecMetricsIdPb) Descriptor() ([]byte, []int)

Deprecated: Use WfSpecMetricsIdPb.ProtoReflect.Descriptor instead.

func (*WfSpecMetricsIdPb) GetWfSpecName 

func (x *WfSpecMetricsIdPb) GetWfSpecName() string

func (*WfSpecMetricsIdPb) GetWfSpecVersion 

func (x *WfSpecMetricsIdPb) GetWfSpecVersion() int32

func (*WfSpecMetricsIdPb) GetWindowStart 

func (x *WfSpecMetricsIdPb) GetWindowStart() *timestamppb.Timestamp

func (*WfSpecMetricsIdPb) GetWindowType 

func (x *WfSpecMetricsIdPb) GetWindowType() MetricsWindowLengthPb

func (*WfSpecMetricsIdPb) ProtoMessage 

func (*WfSpecMetricsIdPb) ProtoMessage()

func (*WfSpecMetricsIdPb) ProtoReflect 

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

func (*WfSpecMetricsIdPb) Reset 

func (x *WfSpecMetricsIdPb) Reset()

func (*WfSpecMetricsIdPb) String 

func (x *WfSpecMetricsIdPb) String() string

type WfSpecMetricsPb 

type WfSpecMetricsPb struct {
	WindowStart        *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=window_start,json=windowStart,proto3" json:"window_start,omitempty"`
	Type               MetricsWindowLengthPb  `protobuf:"varint,2,opt,name=type,proto3,enum=littlehorse.MetricsWindowLengthPb" json:"type,omitempty"`
	WfSpecName         string                 `protobuf:"bytes,3,opt,name=wfSpecName,proto3" json:"wfSpecName,omitempty"`
	WfSpecVersion      int32                  `protobuf:"varint,4,opt,name=wfSpecVersion,proto3" json:"wfSpecVersion,omitempty"`
	TotalStarted       int64                  `protobuf:"varint,5,opt,name=total_started,json=totalStarted,proto3" json:"total_started,omitempty"`
	TotalCompleted     int64                  `protobuf:"varint,6,opt,name=total_completed,json=totalCompleted,proto3" json:"total_completed,omitempty"`
	TotalErrored       int64                  `protobuf:"varint,7,opt,name=total_errored,json=totalErrored,proto3" json:"total_errored,omitempty"`
	StartToCompleteMax int64                  `protobuf:"varint,8,opt,name=start_to_complete_max,json=startToCompleteMax,proto3" json:"start_to_complete_max,omitempty"`
	StartToCompleteAvg int64                  `protobuf:"varint,9,opt,name=start_to_complete_avg,json=startToCompleteAvg,proto3" json:"start_to_complete_avg,omitempty"`
	// contains filtered or unexported fields
}

func (*WfSpecMetricsPb) Descriptor deprecated 

func (*WfSpecMetricsPb) Descriptor() ([]byte, []int)

Deprecated: Use WfSpecMetricsPb.ProtoReflect.Descriptor instead.

func (*WfSpecMetricsPb) GetStartToCompleteAvg 

func (x *WfSpecMetricsPb) GetStartToCompleteAvg() int64

func (*WfSpecMetricsPb) GetStartToCompleteMax 

func (x *WfSpecMetricsPb) GetStartToCompleteMax() int64

func (*WfSpecMetricsPb) GetTotalCompleted 

func (x *WfSpecMetricsPb) GetTotalCompleted() int64

func (*WfSpecMetricsPb) GetTotalErrored 

func (x *WfSpecMetricsPb) GetTotalErrored() int64

func (*WfSpecMetricsPb) GetTotalStarted 

func (x *WfSpecMetricsPb) GetTotalStarted() int64

func (*WfSpecMetricsPb) GetType 

func (x *WfSpecMetricsPb) GetType() MetricsWindowLengthPb

func (*WfSpecMetricsPb) GetWfSpecName 

func (x *WfSpecMetricsPb) GetWfSpecName() string

func (*WfSpecMetricsPb) GetWfSpecVersion 

func (x *WfSpecMetricsPb) GetWfSpecVersion() int32

func (*WfSpecMetricsPb) GetWindowStart 

func (x *WfSpecMetricsPb) GetWindowStart() *timestamppb.Timestamp

func (*WfSpecMetricsPb) ProtoMessage 

func (*WfSpecMetricsPb) ProtoMessage()

func (*WfSpecMetricsPb) ProtoReflect 

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

func (*WfSpecMetricsPb) Reset 

func (x *WfSpecMetricsPb) Reset()

func (*WfSpecMetricsPb) String 

func (x *WfSpecMetricsPb) String() string

type WfSpecMetricsQueryPb 

type WfSpecMetricsQueryPb struct {
	WindowStart   *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=window_start,json=windowStart,proto3" json:"window_start,omitempty"`
	WindowType    MetricsWindowLengthPb  `` /* 131-byte string literal not displayed */
	WfSpecName    string                 `protobuf:"bytes,3,opt,name=wf_spec_name,json=wfSpecName,proto3" json:"wf_spec_name,omitempty"`
	WfSpecVersion int32                  `protobuf:"varint,4,opt,name=wf_spec_version,json=wfSpecVersion,proto3" json:"wf_spec_version,omitempty"`
	// contains filtered or unexported fields
}

func (*WfSpecMetricsQueryPb) Descriptor deprecated 

func (*WfSpecMetricsQueryPb) Descriptor() ([]byte, []int)

Deprecated: Use WfSpecMetricsQueryPb.ProtoReflect.Descriptor instead.

func (*WfSpecMetricsQueryPb) GetWfSpecName 

func (x *WfSpecMetricsQueryPb) GetWfSpecName() string

func (*WfSpecMetricsQueryPb) GetWfSpecVersion 

func (x *WfSpecMetricsQueryPb) GetWfSpecVersion() int32

func (*WfSpecMetricsQueryPb) GetWindowStart 

func (x *WfSpecMetricsQueryPb) GetWindowStart() *timestamppb.Timestamp

func (*WfSpecMetricsQueryPb) GetWindowType 

func (x *WfSpecMetricsQueryPb) GetWindowType() MetricsWindowLengthPb

func (*WfSpecMetricsQueryPb) ProtoMessage 

func (*WfSpecMetricsQueryPb) ProtoMessage()

func (*WfSpecMetricsQueryPb) ProtoReflect 

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

func (*WfSpecMetricsQueryPb) Reset 

func (x *WfSpecMetricsQueryPb) Reset()

func (*WfSpecMetricsQueryPb) String 

func (x *WfSpecMetricsQueryPb) String() string

type WfSpecMetricsReplyPb 

type WfSpecMetricsReplyPb struct {
	Code    LHResponseCodePb `protobuf:"varint,1,opt,name=code,proto3,enum=littlehorse.LHResponseCodePb" json:"code,omitempty"`
	Message *string          `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	Result  *WfSpecMetricsPb `protobuf:"bytes,3,opt,name=result,proto3,oneof" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*WfSpecMetricsReplyPb) Descriptor deprecated 

func (*WfSpecMetricsReplyPb) Descriptor() ([]byte, []int)

Deprecated: Use WfSpecMetricsReplyPb.ProtoReflect.Descriptor instead.

func (*WfSpecMetricsReplyPb) GetCode 

func (x *WfSpecMetricsReplyPb) GetCode() LHResponseCodePb

func (*WfSpecMetricsReplyPb) GetMessage 

func (x *WfSpecMetricsReplyPb) GetMessage() string

func (*WfSpecMetricsReplyPb) GetResult 

func (x *WfSpecMetricsReplyPb) GetResult() *WfSpecMetricsPb

func (*WfSpecMetricsReplyPb) ProtoMessage 

func (*WfSpecMetricsReplyPb) ProtoMessage()

func (*WfSpecMetricsReplyPb) ProtoReflect 

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

func (*WfSpecMetricsReplyPb) Reset 

func (x *WfSpecMetricsReplyPb) Reset()

func (*WfSpecMetricsReplyPb) String 

func (x *WfSpecMetricsReplyPb) String() string

type WfSpecPb 

type WfSpecPb struct {
	Name                 string                   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version              int32                    `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	CreatedAt            *timestamppb.Timestamp   `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	Status               LHStatusPb               `protobuf:"varint,4,opt,name=status,proto3,enum=littlehorse.LHStatusPb" json:"status,omitempty"`
	ThreadSpecs          map[string]*ThreadSpecPb `` /* 182-byte string literal not displayed */
	EntrypointThreadName string                   `protobuf:"bytes,6,opt,name=entrypoint_thread_name,json=entrypointThreadName,proto3" json:"entrypoint_thread_name,omitempty"`
	// contains filtered or unexported fields
}

func (*WfSpecPb) Descriptor deprecated 

func (*WfSpecPb) Descriptor() ([]byte, []int)

Deprecated: Use WfSpecPb.ProtoReflect.Descriptor instead.

func (*WfSpecPb) GetCreatedAt 

func (x *WfSpecPb) GetCreatedAt() *timestamppb.Timestamp

func (*WfSpecPb) GetEntrypointThreadName 

func (x *WfSpecPb) GetEntrypointThreadName() string

func (*WfSpecPb) GetName 

func (x *WfSpecPb) GetName() string

func (*WfSpecPb) GetStatus 

func (x *WfSpecPb) GetStatus() LHStatusPb

func (*WfSpecPb) GetThreadSpecs 

func (x *WfSpecPb) GetThreadSpecs() map[string]*ThreadSpecPb

func (*WfSpecPb) GetVersion 

func (x *WfSpecPb) GetVersion() int32

func (*WfSpecPb) ProtoMessage 

func (*WfSpecPb) ProtoMessage()

func (*WfSpecPb) ProtoReflect 

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

func (*WfSpecPb) Reset 

func (x *WfSpecPb) Reset()

func (*WfSpecPb) String 

func (x *WfSpecPb) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.