model

package
v0.0.0-...-0f879ca Latest Latest
Warning

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

 Go to latest Published: Jul 10, 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_PutUserTaskDef_FullMethodName         = "/littlehorse.LHPublicApi/PutUserTaskDef"
	LHPublicApi_GetUserTaskDef_FullMethodName         = "/littlehorse.LHPublicApi/GetUserTaskDef"
	LHPublicApi_GetLatestUserTaskDef_FullMethodName   = "/littlehorse.LHPublicApi/GetLatestUserTaskDef"
	LHPublicApi_RunWf_FullMethodName                  = "/littlehorse.LHPublicApi/RunWf"
	LHPublicApi_GetWfRun_FullMethodName               = "/littlehorse.LHPublicApi/GetWfRun"
	LHPublicApi_AssignUserTaskRun_FullMethodName      = "/littlehorse.LHPublicApi/AssignUserTaskRun"
	LHPublicApi_CompleteUserTaskRun_FullMethodName    = "/littlehorse.LHPublicApi/CompleteUserTaskRun"
	LHPublicApi_GetNodeRun_FullMethodName             = "/littlehorse.LHPublicApi/GetNodeRun"
	LHPublicApi_ListNodeRuns_FullMethodName           = "/littlehorse.LHPublicApi/ListNodeRuns"
	LHPublicApi_GetTaskRun_FullMethodName             = "/littlehorse.LHPublicApi/GetTaskRun"
	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_SearchUserTaskDef_FullMethodName      = "/littlehorse.LHPublicApi/SearchUserTaskDef"
	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_DeleteUserTaskDef_FullMethodName      = "/littlehorse.LHPublicApi/DeleteUserTaskDef"
	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 (
	TaskStatusPb_name = map[int32]string{
		0: "TASK_SCHEDULED",
		1: "TASK_RUNNING",
		2: "TASK_SUCCESS",
		3: "TASK_FAILED",
		4: "TASK_TIMEOUT",
		5: "TASK_OUTPUT_SERIALIZING_ERROR",
		6: "TASK_INPUT_VAR_SUB_ERROR",
	}
	TaskStatusPb_value = map[string]int32{
		"TASK_SCHEDULED":                0,
		"TASK_RUNNING":                  1,
		"TASK_SUCCESS":                  2,
		"TASK_FAILED":                   3,
		"TASK_TIMEOUT":                  4,
		"TASK_OUTPUT_SERIALIZING_ERROR": 5,
		"TASK_INPUT_VAR_SUB_ERROR":      6,
	}
)

Enum value maps for TaskStatusPb.

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 (
	UserTaskRunStatusPb_name = map[int32]string{
		0: "UNASSIGNED",
		1: "ASSIGNED_NOT_CLAIMED",
		2: "CLAIMED",
		3: "DONE",
		4: "CANCELLED",
	}
	UserTaskRunStatusPb_value = map[string]int32{
		"UNASSIGNED":           0,
		"ASSIGNED_NOT_CLAIMED": 1,
		"CLAIMED":              2,
		"DONE":                 3,
		"CANCELLED":            4,
	}
)

Enum value maps for UserTaskRunStatusPb.

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: "PutUserTaskDef",
			Handler:    _LHPublicApi_PutUserTaskDef_Handler,
		},
		{
			MethodName: "GetUserTaskDef",
			Handler:    _LHPublicApi_GetUserTaskDef_Handler,
		},
		{
			MethodName: "GetLatestUserTaskDef",
			Handler:    _LHPublicApi_GetLatestUserTaskDef_Handler,
		},
		{
			MethodName: "RunWf",
			Handler:    _LHPublicApi_RunWf_Handler,
		},
		{
			MethodName: "GetWfRun",
			Handler:    _LHPublicApi_GetWfRun_Handler,
		},
		{
			MethodName: "AssignUserTaskRun",
			Handler:    _LHPublicApi_AssignUserTaskRun_Handler,
		},
		{
			MethodName: "CompleteUserTaskRun",
			Handler:    _LHPublicApi_CompleteUserTaskRun_Handler,
		},
		{
			MethodName: "GetNodeRun",
			Handler:    _LHPublicApi_GetNodeRun_Handler,
		},
		{
			MethodName: "ListNodeRuns",
			Handler:    _LHPublicApi_ListNodeRuns_Handler,
		},
		{
			MethodName: "GetTaskRun",
			Handler:    _LHPublicApi_GetTaskRun_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: "SearchUserTaskDef",
			Handler:    _LHPublicApi_SearchUserTaskDef_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: "DeleteUserTaskDef",
			Handler:    _LHPublicApi_DeleteUserTaskDef_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 AssignUserTaskRunPb 

type AssignUserTaskRunPb 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"`
	NodeRunPosition int32  `protobuf:"varint,3,opt,name=node_run_position,json=nodeRunPosition,proto3" json:"node_run_position,omitempty"`
	OverrideClaim   bool   `protobuf:"varint,4,opt,name=override_claim,json=overrideClaim,proto3" json:"override_claim,omitempty"`
	// Types that are assignable to Assignee:
	//
	//	*AssignUserTaskRunPb_UserId
	//	*AssignUserTaskRunPb_UserGroup
	Assignee isAssignUserTaskRunPb_Assignee `protobuf_oneof:"assignee"`
	// contains filtered or unexported fields
}

func (*AssignUserTaskRunPb) Descriptor deprecated 

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

Deprecated: Use AssignUserTaskRunPb.ProtoReflect.Descriptor instead.

func (*AssignUserTaskRunPb) GetAssignee 

func (m *AssignUserTaskRunPb) GetAssignee() isAssignUserTaskRunPb_Assignee

func (*AssignUserTaskRunPb) GetNodeRunPosition 

func (x *AssignUserTaskRunPb) GetNodeRunPosition() int32

func (*AssignUserTaskRunPb) GetOverrideClaim 

func (x *AssignUserTaskRunPb) GetOverrideClaim() bool

func (*AssignUserTaskRunPb) GetThreadRunNumber 

func (x *AssignUserTaskRunPb) GetThreadRunNumber() int32

func (*AssignUserTaskRunPb) GetUserGroup 

func (x *AssignUserTaskRunPb) GetUserGroup() string

func (*AssignUserTaskRunPb) GetUserId 

func (x *AssignUserTaskRunPb) GetUserId() string

func (*AssignUserTaskRunPb) GetWfRunId 

func (x *AssignUserTaskRunPb) GetWfRunId() string

func (*AssignUserTaskRunPb) ProtoMessage 

func (*AssignUserTaskRunPb) ProtoMessage()

func (*AssignUserTaskRunPb) ProtoReflect 

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

func (*AssignUserTaskRunPb) Reset 

func (x *AssignUserTaskRunPb) Reset()

func (*AssignUserTaskRunPb) String 

func (x *AssignUserTaskRunPb) String() string

type AssignUserTaskRunPb_UserGroup 

type AssignUserTaskRunPb_UserGroup struct {
	UserGroup string `protobuf:"bytes,6,opt,name=user_group,json=userGroup,proto3,oneof"`
}

type AssignUserTaskRunPb_UserId 

type AssignUserTaskRunPb_UserId struct {
	UserId string `protobuf:"bytes,5,opt,name=user_id,json=userId,proto3,oneof"`
}

type AssignUserTaskRunReplyPb 

type AssignUserTaskRunReplyPb 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 (*AssignUserTaskRunReplyPb) Descriptor deprecated 

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

Deprecated: Use AssignUserTaskRunReplyPb.ProtoReflect.Descriptor instead.

func (*AssignUserTaskRunReplyPb) GetCode 

func (x *AssignUserTaskRunReplyPb) GetCode() LHResponseCodePb

func (*AssignUserTaskRunReplyPb) GetMessage 

func (x *AssignUserTaskRunReplyPb) GetMessage() string

func (*AssignUserTaskRunReplyPb) ProtoMessage 

func (*AssignUserTaskRunReplyPb) ProtoMessage()

func (*AssignUserTaskRunReplyPb) ProtoReflect 

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

func (*AssignUserTaskRunReplyPb) Reset 

func (x *AssignUserTaskRunReplyPb) Reset()

func (*AssignUserTaskRunReplyPb) String 

func (x *AssignUserTaskRunReplyPb) String() string

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 CompleteUserTaskRunPb 

type CompleteUserTaskRunPb 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"`
	NodeRunPosition int32             `protobuf:"varint,3,opt,name=node_run_position,json=nodeRunPosition,proto3" json:"node_run_position,omitempty"`
	Result          *UserTaskResultPb `protobuf:"bytes,4,opt,name=result,proto3" json:"result,omitempty"`
	UserId          string            `protobuf:"bytes,5,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CompleteUserTaskRunPb) Descriptor deprecated 

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

Deprecated: Use CompleteUserTaskRunPb.ProtoReflect.Descriptor instead.

func (*CompleteUserTaskRunPb) GetNodeRunPosition 

func (x *CompleteUserTaskRunPb) GetNodeRunPosition() int32

func (*CompleteUserTaskRunPb) GetResult 

func (x *CompleteUserTaskRunPb) GetResult() *UserTaskResultPb

func (*CompleteUserTaskRunPb) GetThreadRunNumber 

func (x *CompleteUserTaskRunPb) GetThreadRunNumber() int32

func (*CompleteUserTaskRunPb) GetUserId 

func (x *CompleteUserTaskRunPb) GetUserId() string

func (*CompleteUserTaskRunPb) GetWfRunId 

func (x *CompleteUserTaskRunPb) GetWfRunId() string

func (*CompleteUserTaskRunPb) ProtoMessage 

func (*CompleteUserTaskRunPb) ProtoMessage()

func (*CompleteUserTaskRunPb) ProtoReflect 

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

func (*CompleteUserTaskRunPb) Reset 

func (x *CompleteUserTaskRunPb) Reset()

func (*CompleteUserTaskRunPb) String 

func (x *CompleteUserTaskRunPb) String() string

type CompleteUserTaskRunReplyPb 

type CompleteUserTaskRunReplyPb 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 (*CompleteUserTaskRunReplyPb) Descriptor deprecated 

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

Deprecated: Use CompleteUserTaskRunReplyPb.ProtoReflect.Descriptor instead.

func (*CompleteUserTaskRunReplyPb) GetCode 

func (x *CompleteUserTaskRunReplyPb) GetCode() LHResponseCodePb

func (*CompleteUserTaskRunReplyPb) GetMessage 

func (x *CompleteUserTaskRunReplyPb) GetMessage() string

func (*CompleteUserTaskRunReplyPb) ProtoMessage 

func (*CompleteUserTaskRunReplyPb) ProtoMessage()

func (*CompleteUserTaskRunReplyPb) ProtoReflect 

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

func (*CompleteUserTaskRunReplyPb) Reset 

func (x *CompleteUserTaskRunReplyPb) Reset()

func (*CompleteUserTaskRunReplyPb) String 

func (x *CompleteUserTaskRunReplyPb) String() string

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 DeleteExternalEventPb 

type DeleteExternalEventPb 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
}

func (*DeleteExternalEventPb) Descriptor deprecated 

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

Deprecated: Use DeleteExternalEventPb.ProtoReflect.Descriptor instead.

func (*DeleteExternalEventPb) GetExternalEventDefName 

func (x *DeleteExternalEventPb) GetExternalEventDefName() string

func (*DeleteExternalEventPb) GetGuid 

func (x *DeleteExternalEventPb) GetGuid() string

func (*DeleteExternalEventPb) GetWfRunId 

func (x *DeleteExternalEventPb) GetWfRunId() string

func (*DeleteExternalEventPb) ProtoMessage 

func (*DeleteExternalEventPb) ProtoMessage()

func (*DeleteExternalEventPb) ProtoReflect 

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

func (*DeleteExternalEventPb) Reset 

func (x *DeleteExternalEventPb) Reset()

func (*DeleteExternalEventPb) String 

func (x *DeleteExternalEventPb) 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 DeleteUserTaskDefPb 

type DeleteUserTaskDefPb 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 (*DeleteUserTaskDefPb) Descriptor deprecated 

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

Deprecated: Use DeleteUserTaskDefPb.ProtoReflect.Descriptor instead.

func (*DeleteUserTaskDefPb) GetName 

func (x *DeleteUserTaskDefPb) GetName() string

func (*DeleteUserTaskDefPb) GetVersion 

func (x *DeleteUserTaskDefPb) GetVersion() int32

func (*DeleteUserTaskDefPb) ProtoMessage 

func (*DeleteUserTaskDefPb) ProtoMessage()

func (*DeleteUserTaskDefPb) ProtoReflect 

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

func (*DeleteUserTaskDefPb) Reset 

func (x *DeleteUserTaskDefPb) Reset()

func (*DeleteUserTaskDefPb) String 

func (x *DeleteUserTaskDefPb) 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 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"`
	RetentionHours int32                  `protobuf:"varint,3,opt,name=retention_hours,json=retentionHours,proto3" json:"retention_hours,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) GetRetentionHours 

func (x *ExternalEventDefPb) GetRetentionHours() int32

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"`
	Message     string                `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Content     *VariableAssignmentPb `protobuf:"bytes,3,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) 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"`
	Message     string           `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Content     *VariableValuePb `protobuf:"bytes,3,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) 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 GetLatestUserTaskDefPb 

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

func (*GetLatestUserTaskDefPb) Descriptor deprecated 

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

Deprecated: Use GetLatestUserTaskDefPb.ProtoReflect.Descriptor instead.

func (*GetLatestUserTaskDefPb) GetName 

func (x *GetLatestUserTaskDefPb) GetName() string

func (*GetLatestUserTaskDefPb) ProtoMessage 

func (*GetLatestUserTaskDefPb) ProtoMessage()

func (*GetLatestUserTaskDefPb) ProtoReflect 

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

func (*GetLatestUserTaskDefPb) Reset 

func (x *GetLatestUserTaskDefPb) Reset()

func (*GetLatestUserTaskDefPb) String 

func (x *GetLatestUserTaskDefPb) 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)