serverv1

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Aug 24, 2023 License: AGPL-3.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	TaskState_name = map[int32]string{
		0: "TASK_STATE_UNSPECIFIED",
		1: "TASK_STATE_QUEUED",
		2: "TASK_STATE_INITIALIZING",
		3: "TASK_STATE_EXECUTING",
		4: "TASK_STATE_ERROR",
		5: "TASK_STATE_SUCCESS",
	}
	TaskState_value = map[string]int32{
		"TASK_STATE_UNSPECIFIED":  0,
		"TASK_STATE_QUEUED":       1,
		"TASK_STATE_INITIALIZING": 2,
		"TASK_STATE_EXECUTING":    3,
		"TASK_STATE_ERROR":        4,
		"TASK_STATE_SUCCESS":      5,
	}
)

Enum value maps for TaskState.

View Source 
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var File_timecraft_server_v1_timecraft_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type DiscardTasksRequest 

type DiscardTasksRequest struct {
	TaskId []string `protobuf:"bytes,1,rep,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DiscardTasksRequest) Descriptor deprecated 

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

Deprecated: Use DiscardTasksRequest.ProtoReflect.Descriptor instead.

func (*DiscardTasksRequest) GetTaskId 

func (x *DiscardTasksRequest) GetTaskId() []string

func (*DiscardTasksRequest) MarshalToSizedBufferVT 

func (m *DiscardTasksRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DiscardTasksRequest) MarshalToVT 

func (m *DiscardTasksRequest) MarshalToVT(dAtA []byte) (int, error)

func (*DiscardTasksRequest) MarshalVT 

func (m *DiscardTasksRequest) MarshalVT() (dAtA []byte, err error)

func (*DiscardTasksRequest) ProtoMessage 

func (*DiscardTasksRequest) ProtoMessage()

func (*DiscardTasksRequest) ProtoReflect 

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

func (*DiscardTasksRequest) Reset 

func (x *DiscardTasksRequest) Reset()

func (*DiscardTasksRequest) SizeVT 

func (m *DiscardTasksRequest) SizeVT() (n int)

func (*DiscardTasksRequest) String 

func (x *DiscardTasksRequest) String() string

func (*DiscardTasksRequest) UnmarshalVT 

func (m *DiscardTasksRequest) UnmarshalVT(dAtA []byte) error

type DiscardTasksResponse 

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

func (*DiscardTasksResponse) Descriptor deprecated 

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

Deprecated: Use DiscardTasksResponse.ProtoReflect.Descriptor instead.

func (*DiscardTasksResponse) MarshalToSizedBufferVT 

func (m *DiscardTasksResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DiscardTasksResponse) MarshalToVT 

func (m *DiscardTasksResponse) MarshalToVT(dAtA []byte) (int, error)

func (*DiscardTasksResponse) MarshalVT 

func (m *DiscardTasksResponse) MarshalVT() (dAtA []byte, err error)

func (*DiscardTasksResponse) ProtoMessage 

func (*DiscardTasksResponse) ProtoMessage()

func (*DiscardTasksResponse) ProtoReflect 

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

func (*DiscardTasksResponse) Reset 

func (x *DiscardTasksResponse) Reset()

func (*DiscardTasksResponse) SizeVT 

func (m *DiscardTasksResponse) SizeVT() (n int)

func (*DiscardTasksResponse) String 

func (x *DiscardTasksResponse) String() string

func (*DiscardTasksResponse) UnmarshalVT 

func (m *DiscardTasksResponse) UnmarshalVT(dAtA []byte) error

type HTTPRequest 

type HTTPRequest struct {
	Method  string    `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	Path    string    `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Headers []*Header `protobuf:"bytes,3,rep,name=headers,proto3" json:"headers,omitempty"`
	Body    []byte    `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	Port    int32     `protobuf:"varint,5,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*HTTPRequest) Descriptor deprecated 

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

Deprecated: Use HTTPRequest.ProtoReflect.Descriptor instead.

func (*HTTPRequest) GetBody 

func (x *HTTPRequest) GetBody() []byte

func (*HTTPRequest) GetHeaders 

func (x *HTTPRequest) GetHeaders() []*Header

func (*HTTPRequest) GetMethod 

func (x *HTTPRequest) GetMethod() string

func (*HTTPRequest) GetPath 

func (x *HTTPRequest) GetPath() string

func (*HTTPRequest) GetPort 

func (x *HTTPRequest) GetPort() int32

func (*HTTPRequest) MarshalToSizedBufferVT 

func (m *HTTPRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*HTTPRequest) MarshalToVT 

func (m *HTTPRequest) MarshalToVT(dAtA []byte) (int, error)

func (*HTTPRequest) MarshalVT 

func (m *HTTPRequest) MarshalVT() (dAtA []byte, err error)

func (*HTTPRequest) ProtoMessage 

func (*HTTPRequest) ProtoMessage()

func (*HTTPRequest) ProtoReflect 

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

func (*HTTPRequest) Reset 

func (x *HTTPRequest) Reset()

func (*HTTPRequest) SizeVT 

func (m *HTTPRequest) SizeVT() (n int)

func (*HTTPRequest) String 

func (x *HTTPRequest) String() string

func (*HTTPRequest) UnmarshalVT 

func (m *HTTPRequest) UnmarshalVT(dAtA []byte) error

type HTTPResponse 

type HTTPResponse struct {
	StatusCode int32     `protobuf:"varint,1,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	Headers    []*Header `protobuf:"bytes,2,rep,name=headers,proto3" json:"headers,omitempty"`
	Body       []byte    `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*HTTPResponse) Descriptor deprecated 

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

Deprecated: Use HTTPResponse.ProtoReflect.Descriptor instead.

func (*HTTPResponse) GetBody 

func (x *HTTPResponse) GetBody() []byte

func (*HTTPResponse) GetHeaders 

func (x *HTTPResponse) GetHeaders() []*Header

func (*HTTPResponse) GetStatusCode 

func (x *HTTPResponse) GetStatusCode() int32

func (*HTTPResponse) MarshalToSizedBufferVT 

func (m *HTTPResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*HTTPResponse) MarshalToVT 

func (m *HTTPResponse) MarshalToVT(dAtA []byte) (int, error)

func (*HTTPResponse) MarshalVT 

func (m *HTTPResponse) MarshalVT() (dAtA []byte, err error)

func (*HTTPResponse) ProtoMessage 

func (*HTTPResponse) ProtoMessage()

func (*HTTPResponse) ProtoReflect 

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

func (*HTTPResponse) Reset 

func (x *HTTPResponse) Reset()

func (*HTTPResponse) SizeVT 

func (m *HTTPResponse) SizeVT() (n int)

func (*HTTPResponse) String 

func (x *HTTPResponse) String() string

func (*HTTPResponse) UnmarshalVT 

func (m *HTTPResponse) UnmarshalVT(dAtA []byte) error
type Header struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Header) Descriptor deprecated 

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

Deprecated: Use Header.ProtoReflect.Descriptor instead.

func (*Header) GetName 

func (x *Header) GetName() string

func (*Header) GetValue 

func (x *Header) GetValue() string

func (*Header) MarshalToSizedBufferVT 

func (m *Header) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Header) MarshalToVT 

func (m *Header) MarshalToVT(dAtA []byte) (int, error)

func (*Header) MarshalVT 

func (m *Header) MarshalVT() (dAtA []byte, err error)

func (*Header) ProtoMessage 

func (*Header) ProtoMessage()

func (*Header) ProtoReflect 

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

func (*Header) Reset 

func (x *Header) Reset()

func (*Header) SizeVT 

func (m *Header) SizeVT() (n int)

func (*Header) String 

func (x *Header) String() string

func (*Header) UnmarshalVT 

func (m *Header) UnmarshalVT(dAtA []byte) error

type KillRequest 

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

func (*KillRequest) Descriptor deprecated 

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

Deprecated: Use KillRequest.ProtoReflect.Descriptor instead.

func (*KillRequest) GetProcessId 

func (x *KillRequest) GetProcessId() string

func (*KillRequest) MarshalToSizedBufferVT 

func (m *KillRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*KillRequest) MarshalToVT 

func (m *KillRequest) MarshalToVT(dAtA []byte) (int, error)

func (*KillRequest) MarshalVT 

func (m *KillRequest) MarshalVT() (dAtA []byte, err error)

func (*KillRequest) ProtoMessage 

func (*KillRequest) ProtoMessage()

func (*KillRequest) ProtoReflect 

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

func (*KillRequest) Reset 

func (x *KillRequest) Reset()

func (*KillRequest) SizeVT 

func (m *KillRequest) SizeVT() (n int)

func (*KillRequest) String 

func (x *KillRequest) String() string

func (*KillRequest) UnmarshalVT 

func (m *KillRequest) UnmarshalVT(dAtA []byte) error

type KillResponse 

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

func (*KillResponse) Descriptor deprecated 

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

Deprecated: Use KillResponse.ProtoReflect.Descriptor instead.

func (*KillResponse) MarshalToSizedBufferVT 

func (m *KillResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*KillResponse) MarshalToVT 

func (m *KillResponse) MarshalToVT(dAtA []byte) (int, error)

func (*KillResponse) MarshalVT 

func (m *KillResponse) MarshalVT() (dAtA []byte, err error)

func (*KillResponse) ProtoMessage 

func (*KillResponse) ProtoMessage()

func (*KillResponse) ProtoReflect 

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

func (*KillResponse) Reset 

func (x *KillResponse) Reset()

func (*KillResponse) SizeVT 

func (m *KillResponse) SizeVT() (n int)

func (*KillResponse) String 

func (x *KillResponse) String() string

func (*KillResponse) UnmarshalVT 

func (m *KillResponse) UnmarshalVT(dAtA []byte) error

type LookupTasksRequest 

type LookupTasksRequest struct {
	TaskId []string `protobuf:"bytes,1,rep,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupTasksRequest) Descriptor deprecated 

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

Deprecated: Use LookupTasksRequest.ProtoReflect.Descriptor instead.

func (*LookupTasksRequest) GetTaskId 

func (x *LookupTasksRequest) GetTaskId() []string

func (*LookupTasksRequest) MarshalToSizedBufferVT 

func (m *LookupTasksRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LookupTasksRequest) MarshalToVT 

func (m *LookupTasksRequest) MarshalToVT(dAtA []byte) (int, error)

func (*LookupTasksRequest) MarshalVT 

func (m *LookupTasksRequest) MarshalVT() (dAtA []byte, err error)

func (*LookupTasksRequest) ProtoMessage 

func (*LookupTasksRequest) ProtoMessage()

func (*LookupTasksRequest) ProtoReflect 

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

func (*LookupTasksRequest) Reset 

func (x *LookupTasksRequest) Reset()

func (*LookupTasksRequest) SizeVT 

func (m *LookupTasksRequest) SizeVT() (n int)

func (*LookupTasksRequest) String 

func (x *LookupTasksRequest) String() string

func (*LookupTasksRequest) UnmarshalVT 

func (m *LookupTasksRequest) UnmarshalVT(dAtA []byte) error

type LookupTasksResponse 

type LookupTasksResponse struct {
	Responses []*TaskResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupTasksResponse) Descriptor deprecated 

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

Deprecated: Use LookupTasksResponse.ProtoReflect.Descriptor instead.

func (*LookupTasksResponse) GetResponses 

func (x *LookupTasksResponse) GetResponses() []*TaskResponse

func (*LookupTasksResponse) MarshalToSizedBufferVT 

func (m *LookupTasksResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LookupTasksResponse) MarshalToVT 

func (m *LookupTasksResponse) MarshalToVT(dAtA []byte) (int, error)

func (*LookupTasksResponse) MarshalVT 

func (m *LookupTasksResponse) MarshalVT() (dAtA []byte, err error)

func (*LookupTasksResponse) ProtoMessage 

func (*LookupTasksResponse) ProtoMessage()

func (*LookupTasksResponse) ProtoReflect 

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

func (*LookupTasksResponse) Reset 

func (x *LookupTasksResponse) Reset()

func (*LookupTasksResponse) SizeVT 

func (m *LookupTasksResponse) SizeVT() (n int)

func (*LookupTasksResponse) String 

func (x *LookupTasksResponse) String() string

func (*LookupTasksResponse) UnmarshalVT 

func (m *LookupTasksResponse) UnmarshalVT(dAtA []byte) error

type ModuleSpec 

type ModuleSpec struct {
	Path          string      `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Function      string      `protobuf:"bytes,2,opt,name=function,proto3" json:"function,omitempty"`
	Args          []string    `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
	Env           []string    `protobuf:"bytes,4,rep,name=env,proto3" json:"env,omitempty"`
	OutboundProxy *ModuleSpec `protobuf:"bytes,5,opt,name=outbound_proxy,json=outboundProxy,proto3" json:"outbound_proxy,omitempty"`
	// contains filtered or unexported fields
}

func (*ModuleSpec) Descriptor deprecated 

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

Deprecated: Use ModuleSpec.ProtoReflect.Descriptor instead.

func (*ModuleSpec) GetArgs 

func (x *ModuleSpec) GetArgs() []string

func (*ModuleSpec) GetEnv 

func (x *ModuleSpec) GetEnv() []string

func (*ModuleSpec) GetFunction 

func (x *ModuleSpec) GetFunction() string

func (*ModuleSpec) GetOutboundProxy 

func (x *ModuleSpec) GetOutboundProxy() *ModuleSpec

func (*ModuleSpec) GetPath 

func (x *ModuleSpec) GetPath() string

func (*ModuleSpec) MarshalToSizedBufferVT 

func (m *ModuleSpec) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ModuleSpec) MarshalToVT 

func (m *ModuleSpec) MarshalToVT(dAtA []byte) (int, error)

func (*ModuleSpec) MarshalVT 

func (m *ModuleSpec) MarshalVT() (dAtA []byte, err error)

func (*ModuleSpec) ProtoMessage 

func (*ModuleSpec) ProtoMessage()

func (*ModuleSpec) ProtoReflect 

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

func (*ModuleSpec) Reset 

func (x *ModuleSpec) Reset()

func (*ModuleSpec) SizeVT 

func (m *ModuleSpec) SizeVT() (n int)

func (*ModuleSpec) String 

func (x *ModuleSpec) String() string

func (*ModuleSpec) UnmarshalVT 

func (m *ModuleSpec) UnmarshalVT(dAtA []byte) error

type PollTasksRequest 

type PollTasksRequest struct {
	BatchSize int32 `protobuf:"varint,1,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	TimeoutNs int64 `protobuf:"varint,2,opt,name=timeout_ns,json=timeoutNs,proto3" json:"timeout_ns,omitempty"`
	// contains filtered or unexported fields
}

func (*PollTasksRequest) Descriptor deprecated 

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

Deprecated: Use PollTasksRequest.ProtoReflect.Descriptor instead.

func (*PollTasksRequest) GetBatchSize 

func (x *PollTasksRequest) GetBatchSize() int32

func (*PollTasksRequest) GetTimeoutNs 

func (x *PollTasksRequest) GetTimeoutNs() int64

func (*PollTasksRequest) MarshalToSizedBufferVT 

func (m *PollTasksRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PollTasksRequest) MarshalToVT 

func (m *PollTasksRequest) MarshalToVT(dAtA []byte) (int, error)

func (*PollTasksRequest) MarshalVT 

func (m *PollTasksRequest) MarshalVT() (dAtA []byte, err error)

func (*PollTasksRequest) ProtoMessage 

func (*PollTasksRequest) ProtoMessage()

func (*PollTasksRequest) ProtoReflect 

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

func (*PollTasksRequest) Reset 

func (x *PollTasksRequest) Reset()

func (*PollTasksRequest) SizeVT 

func (m *PollTasksRequest) SizeVT() (n int)

func (*PollTasksRequest) String 

func (x *PollTasksRequest) String() string

func (*PollTasksRequest) UnmarshalVT 

func (m *PollTasksRequest) UnmarshalVT(dAtA []byte) error

type PollTasksResponse 

type PollTasksResponse struct {
	Responses []*TaskResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*PollTasksResponse) Descriptor deprecated 

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

Deprecated: Use PollTasksResponse.ProtoReflect.Descriptor instead.

func (*PollTasksResponse) GetResponses 

func (x *PollTasksResponse) GetResponses() []*TaskResponse

func (*PollTasksResponse) MarshalToSizedBufferVT 

func (m *PollTasksResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PollTasksResponse) MarshalToVT 

func (m *PollTasksResponse) MarshalToVT(dAtA []byte) (int, error)

func (*PollTasksResponse) MarshalVT 

func (m *PollTasksResponse) MarshalVT() (dAtA []byte, err error)

func (*PollTasksResponse) ProtoMessage 

func (*PollTasksResponse) ProtoMessage()

func (*PollTasksResponse) ProtoReflect 

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

func (*PollTasksResponse) Reset 

func (x *PollTasksResponse) Reset()

func (*PollTasksResponse) SizeVT 

func (m *PollTasksResponse) SizeVT() (n int)

func (*PollTasksResponse) String 

func (x *PollTasksResponse) String() string

func (*PollTasksResponse) UnmarshalVT 

func (m *PollTasksResponse) UnmarshalVT(dAtA []byte) error

type ProcessIDRequest 

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

func (*ProcessIDRequest) Descriptor deprecated 

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

Deprecated: Use ProcessIDRequest.ProtoReflect.Descriptor instead.

func (*ProcessIDRequest) MarshalToSizedBufferVT 

func (m *ProcessIDRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ProcessIDRequest) MarshalToVT 

func (m *ProcessIDRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ProcessIDRequest) MarshalVT 

func (m *ProcessIDRequest) MarshalVT() (dAtA []byte, err error)

func (*ProcessIDRequest) ProtoMessage 

func (*ProcessIDRequest) ProtoMessage()

func (*ProcessIDRequest) ProtoReflect 

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

func (*ProcessIDRequest) Reset 

func (x *ProcessIDRequest) Reset()

func (*ProcessIDRequest) SizeVT 

func (m *ProcessIDRequest) SizeVT() (n int)

func (*ProcessIDRequest) String 

func (x *ProcessIDRequest) String() string

func (*ProcessIDRequest) UnmarshalVT 

func (m *ProcessIDRequest) UnmarshalVT(dAtA []byte) error

type ProcessIDResponse 

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

func (*ProcessIDResponse) Descriptor deprecated 

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

Deprecated: Use ProcessIDResponse.ProtoReflect.Descriptor instead.

func (*ProcessIDResponse) GetProcessId 

func (x *ProcessIDResponse) GetProcessId() string

func (*ProcessIDResponse) MarshalToSizedBufferVT 

func (m *ProcessIDResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ProcessIDResponse) MarshalToVT 

func (m *ProcessIDResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ProcessIDResponse) MarshalVT 

func (m *ProcessIDResponse) MarshalVT() (dAtA []byte, err error)

func (*ProcessIDResponse) ProtoMessage 

func (*ProcessIDResponse) ProtoMessage()

func (*ProcessIDResponse) ProtoReflect 

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

func (*ProcessIDResponse) Reset 

func (x *ProcessIDResponse) Reset()

func (*ProcessIDResponse) SizeVT 

func (m *ProcessIDResponse) SizeVT() (n int)

func (*ProcessIDResponse) String 

func (x *ProcessIDResponse) String() string

func (*ProcessIDResponse) UnmarshalVT 

func (m *ProcessIDResponse) UnmarshalVT(dAtA []byte) error

type SpawnRequest 

type SpawnRequest struct {
	Module *ModuleSpec `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	// contains filtered or unexported fields
}

func (*SpawnRequest) Descriptor deprecated 

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

Deprecated: Use SpawnRequest.ProtoReflect.Descriptor instead.

func (*SpawnRequest) GetModule 

func (x *SpawnRequest) GetModule() *ModuleSpec

func (*SpawnRequest) MarshalToSizedBufferVT 

func (m *SpawnRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SpawnRequest) MarshalToVT 

func (m *SpawnRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SpawnRequest) MarshalVT 

func (m *SpawnRequest) MarshalVT() (dAtA []byte, err error)

func (*SpawnRequest) ProtoMessage 

func (*SpawnRequest) ProtoMessage()

func (*SpawnRequest) ProtoReflect 

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

func (*SpawnRequest) Reset 

func (x *SpawnRequest) Reset()

func (*SpawnRequest) SizeVT 

func (m *SpawnRequest) SizeVT() (n int)

func (*SpawnRequest) String 

func (x *SpawnRequest) String() string

func (*SpawnRequest) UnmarshalVT 

func (m *SpawnRequest) UnmarshalVT(dAtA []byte) error

type SpawnResponse 

type SpawnResponse struct {
	ProcessId string `protobuf:"bytes,1,opt,name=process_id,json=processId,proto3" json:"process_id,omitempty"`
	IpAddress string `protobuf:"bytes,2,opt,name=ip_address,json=ipAddress,proto3" json:"ip_address,omitempty"`
	// contains filtered or unexported fields
}

func (*SpawnResponse) Descriptor deprecated 

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

Deprecated: Use SpawnResponse.ProtoReflect.Descriptor instead.

func (*SpawnResponse) GetIpAddress 

func (x *SpawnResponse) GetIpAddress() string

func (*SpawnResponse) GetProcessId 

func (x *SpawnResponse) GetProcessId() string

func (*SpawnResponse) MarshalToSizedBufferVT 

func (m *SpawnResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SpawnResponse) MarshalToVT 

func (m *SpawnResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SpawnResponse) MarshalVT 

func (m *SpawnResponse) MarshalVT() (dAtA []byte, err error)

func (*SpawnResponse) ProtoMessage 

func (*SpawnResponse) ProtoMessage()

func (*SpawnResponse) ProtoReflect 

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

func (*SpawnResponse) Reset 

func (x *SpawnResponse) Reset()

func (*SpawnResponse) SizeVT 

func (m *SpawnResponse) SizeVT() (n int)

func (*SpawnResponse) String 

func (x *SpawnResponse) String() string

func (*SpawnResponse) UnmarshalVT 

func (m *SpawnResponse) UnmarshalVT(dAtA []byte) error

type SubmitTasksRequest 

type SubmitTasksRequest struct {
	Requests []*TaskRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

func (*SubmitTasksRequest) Descriptor deprecated 

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

Deprecated: Use SubmitTasksRequest.ProtoReflect.Descriptor instead.

func (*SubmitTasksRequest) GetRequests 

func (x *SubmitTasksRequest) GetRequests() []*TaskRequest

func (*SubmitTasksRequest) MarshalToSizedBufferVT 

func (m *SubmitTasksRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SubmitTasksRequest) MarshalToVT 

func (m *SubmitTasksRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SubmitTasksRequest) MarshalVT 

func (m *SubmitTasksRequest) MarshalVT() (dAtA []byte, err error)

func (*SubmitTasksRequest) ProtoMessage 

func (*SubmitTasksRequest) ProtoMessage()

func (*SubmitTasksRequest) ProtoReflect 

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

func (*SubmitTasksRequest) Reset 

func (x *SubmitTasksRequest) Reset()

func (*SubmitTasksRequest) SizeVT 

func (m *SubmitTasksRequest) SizeVT() (n int)

func (*SubmitTasksRequest) String 

func (x *SubmitTasksRequest) String() string

func (*SubmitTasksRequest) UnmarshalVT 

func (m *SubmitTasksRequest) UnmarshalVT(dAtA []byte) error

type SubmitTasksResponse 

type SubmitTasksResponse struct {
	TaskId []string `protobuf:"bytes,1,rep,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SubmitTasksResponse) Descriptor deprecated 

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

Deprecated: Use SubmitTasksResponse.ProtoReflect.Descriptor instead.

func (*SubmitTasksResponse) GetTaskId 

func (x *SubmitTasksResponse) GetTaskId() []string

func (*SubmitTasksResponse) MarshalToSizedBufferVT 

func (m *SubmitTasksResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SubmitTasksResponse) MarshalToVT 

func (m *SubmitTasksResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SubmitTasksResponse) MarshalVT 

func (m *SubmitTasksResponse) MarshalVT() (dAtA []byte, err error)

func (*SubmitTasksResponse) ProtoMessage 

func (*SubmitTasksResponse) ProtoMessage()

func (*SubmitTasksResponse) ProtoReflect 

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

func (*SubmitTasksResponse) Reset 

func (x *SubmitTasksResponse) Reset()

func (*SubmitTasksResponse) SizeVT 

func (m *SubmitTasksResponse) SizeVT() (n int)

func (*SubmitTasksResponse) String 

func (x *SubmitTasksResponse) String() string

func (*SubmitTasksResponse) UnmarshalVT 

func (m *SubmitTasksResponse) UnmarshalVT(dAtA []byte) error

type TaskRequest 

type TaskRequest struct {
	Module *ModuleSpec `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	// Types that are assignable to Input:
	//
	//	*TaskRequest_HttpRequest
	Input isTaskRequest_Input `protobuf_oneof:"input"`
	// contains filtered or unexported fields
}

func (*TaskRequest) Descriptor deprecated 

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

Deprecated: Use TaskRequest.ProtoReflect.Descriptor instead.

func (*TaskRequest) GetHttpRequest 

func (x *TaskRequest) GetHttpRequest() *HTTPRequest

func (*TaskRequest) GetInput 

func (m *TaskRequest) GetInput() isTaskRequest_Input

func (*TaskRequest) GetModule 

func (x *TaskRequest) GetModule() *ModuleSpec

func (*TaskRequest) MarshalToSizedBufferVT 

func (m *TaskRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TaskRequest) MarshalToVT 

func (m *TaskRequest) MarshalToVT(dAtA []byte) (int, error)

func (*TaskRequest) MarshalVT 

func (m *TaskRequest) MarshalVT() (dAtA []byte, err error)

func (*TaskRequest) ProtoMessage 

func (*TaskRequest) ProtoMessage()

func (*TaskRequest) ProtoReflect 

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

func (*TaskRequest) Reset 

func (x *TaskRequest) Reset()

func (*TaskRequest) SizeVT 

func (m *TaskRequest) SizeVT() (n int)

func (*TaskRequest) String 

func (x *TaskRequest) String() string

func (*TaskRequest) UnmarshalVT 

func (m *TaskRequest) UnmarshalVT(dAtA []byte) error

type TaskRequest_HttpRequest 

type TaskRequest_HttpRequest struct {
	HttpRequest *HTTPRequest `protobuf:"bytes,2,opt,name=http_request,json=httpRequest,proto3,oneof"`
}

func (*TaskRequest_HttpRequest) MarshalToSizedBufferVT 

func (m *TaskRequest_HttpRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TaskRequest_HttpRequest) MarshalToVT 

func (m *TaskRequest_HttpRequest) MarshalToVT(dAtA []byte) (int, error)

func (*TaskRequest_HttpRequest) SizeVT 

func (m *TaskRequest_HttpRequest) SizeVT() (n int)

type TaskResponse 

type TaskResponse struct {
	TaskId       string    `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	State        TaskState `protobuf:"varint,2,opt,name=state,proto3,enum=timecraft.server.v1.TaskState" json:"state,omitempty"`
	ProcessId    string    `protobuf:"bytes,3,opt,name=process_id,json=processId,proto3" json:"process_id,omitempty"`
	ErrorMessage string    `protobuf:"bytes,4,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// Types that are assignable to Output:
	//
	//	*TaskResponse_HttpResponse
	Output isTaskResponse_Output `protobuf_oneof:"output"`
	// contains filtered or unexported fields
}

func (*TaskResponse) Descriptor deprecated 

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

Deprecated: Use TaskResponse.ProtoReflect.Descriptor instead.

func (*TaskResponse) GetErrorMessage 

func (x *TaskResponse) GetErrorMessage() string

func (*TaskResponse) GetHttpResponse 

func (x *TaskResponse) GetHttpResponse() *HTTPResponse

func (*TaskResponse) GetOutput 

func (m *TaskResponse) GetOutput() isTaskResponse_Output

func (*TaskResponse) GetProcessId 

func (x *TaskResponse) GetProcessId() string

func (*TaskResponse) GetState 

func (x *TaskResponse) GetState() TaskState

func (*TaskResponse) GetTaskId 

func (x *TaskResponse) GetTaskId() string

func (*TaskResponse) MarshalToSizedBufferVT 

func (m *TaskResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TaskResponse) MarshalToVT 

func (m *TaskResponse) MarshalToVT(dAtA []byte) (int, error)

func (*TaskResponse) MarshalVT 

func (m *TaskResponse) MarshalVT() (dAtA []byte, err error)

func (*TaskResponse) ProtoMessage 

func (*TaskResponse) ProtoMessage()

func (*TaskResponse) ProtoReflect 

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

func (*TaskResponse) Reset 

func (x *TaskResponse) Reset()

func (*TaskResponse) SizeVT 

func (m *TaskResponse) SizeVT() (n int)

func (*TaskResponse) String 

func (x *TaskResponse) String() string

func (*TaskResponse) UnmarshalVT 

func (m *TaskResponse) UnmarshalVT(dAtA []byte) error

type TaskResponse_HttpResponse 

type TaskResponse_HttpResponse struct {
	HttpResponse *HTTPResponse `protobuf:"bytes,5,opt,name=http_response,json=httpResponse,proto3,oneof"`
}

func (*TaskResponse_HttpResponse) MarshalToSizedBufferVT 

func (m *TaskResponse_HttpResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TaskResponse_HttpResponse) MarshalToVT 

func (m *TaskResponse_HttpResponse) MarshalToVT(dAtA []byte) (int, error)

func (*TaskResponse_HttpResponse) SizeVT 

func (m *TaskResponse_HttpResponse) SizeVT() (n int)

type TaskState 

type TaskState int32
const (
	TaskState_TASK_STATE_UNSPECIFIED  TaskState = 0 // required by buf lint
	TaskState_TASK_STATE_QUEUED       TaskState = 1
	TaskState_TASK_STATE_INITIALIZING TaskState = 2
	TaskState_TASK_STATE_EXECUTING    TaskState = 3
	TaskState_TASK_STATE_ERROR        TaskState = 4
	TaskState_TASK_STATE_SUCCESS      TaskState = 5
)

func (TaskState) Descriptor 

func (TaskState) Descriptor() protoreflect.EnumDescriptor

func (TaskState) Enum 

func (x TaskState) Enum() *TaskState

func (TaskState) EnumDescriptor deprecated 

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

Deprecated: Use TaskState.Descriptor instead.

func (TaskState) Number 

func (x TaskState) Number() protoreflect.EnumNumber

func (TaskState) String 

func (x TaskState) String() string

func (TaskState) Type 

func (TaskState) Type() protoreflect.EnumType

type VersionRequest 

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

func (*VersionRequest) Descriptor deprecated 

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

Deprecated: Use VersionRequest.ProtoReflect.Descriptor instead.

func (*VersionRequest) MarshalToSizedBufferVT 

func (m *VersionRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VersionRequest) MarshalToVT 

func (m *VersionRequest) MarshalToVT(dAtA []byte) (int, error)

func (*VersionRequest) MarshalVT 

func (m *VersionRequest) MarshalVT() (dAtA []byte, err error)

func (*VersionRequest) ProtoMessage 

func (*VersionRequest) ProtoMessage()

func (*VersionRequest) ProtoReflect 

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

func (*VersionRequest) Reset 

func (x *VersionRequest) Reset()

func (*VersionRequest) SizeVT 

func (m *VersionRequest) SizeVT() (n int)

func (*VersionRequest) String 

func (x *VersionRequest) String() string

func (*VersionRequest) UnmarshalVT 

func (m *VersionRequest) UnmarshalVT(dAtA []byte) error

type VersionResponse 

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

func (*VersionResponse) Descriptor deprecated 

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

Deprecated: Use VersionResponse.ProtoReflect.Descriptor instead.

func (*VersionResponse) GetVersion 

func (x *VersionResponse) GetVersion() string

func (*VersionResponse) MarshalToSizedBufferVT 

func (m *VersionResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VersionResponse) MarshalToVT 

func (m *VersionResponse) MarshalToVT(dAtA []byte) (int, error)

func (*VersionResponse) MarshalVT 

func (m *VersionResponse) MarshalVT() (dAtA []byte, err error)

func (*VersionResponse) ProtoMessage 

func (*VersionResponse) ProtoMessage()

func (*VersionResponse) ProtoReflect 

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

func (*VersionResponse) Reset 

func (x *VersionResponse) Reset()

func (*VersionResponse) SizeVT 

func (m *VersionResponse) SizeVT() (n int)

func (*VersionResponse) String 

func (x *VersionResponse) String() string

func (*VersionResponse) UnmarshalVT 

func (m *VersionResponse) UnmarshalVT(dAtA []byte) error

Source Files

View all Source files

Directories

Path Synopsis

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.