Versions in this module Expand all Collapse all v0 v0.1.1 Aug 24, 2023 v0.1.0 Aug 9, 2023 Changes in this version + var ErrIntOverflow = fmt.Errorf("proto: integer overflow") + var ErrInvalidLength = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group") + var File_timecraft_server_v1_timecraft_proto protoreflect.FileDescriptor + var TaskState_name = map[int32]string + var TaskState_value = map[string]int32 + type DiscardTasksRequest struct + TaskId []string + func (*DiscardTasksRequest) Descriptor() ([]byte, []int) + func (*DiscardTasksRequest) ProtoMessage() + func (m *DiscardTasksRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *DiscardTasksRequest) MarshalToVT(dAtA []byte) (int, error) + func (m *DiscardTasksRequest) MarshalVT() (dAtA []byte, err error) + func (m *DiscardTasksRequest) SizeVT() (n int) + func (m *DiscardTasksRequest) UnmarshalVT(dAtA []byte) error + func (x *DiscardTasksRequest) GetTaskId() []string + func (x *DiscardTasksRequest) ProtoReflect() protoreflect.Message + func (x *DiscardTasksRequest) Reset() + func (x *DiscardTasksRequest) String() string + type DiscardTasksResponse struct + func (*DiscardTasksResponse) Descriptor() ([]byte, []int) + func (*DiscardTasksResponse) ProtoMessage() + func (m *DiscardTasksResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *DiscardTasksResponse) MarshalToVT(dAtA []byte) (int, error) + func (m *DiscardTasksResponse) MarshalVT() (dAtA []byte, err error) + func (m *DiscardTasksResponse) SizeVT() (n int) + func (m *DiscardTasksResponse) UnmarshalVT(dAtA []byte) error + func (x *DiscardTasksResponse) ProtoReflect() protoreflect.Message + func (x *DiscardTasksResponse) Reset() + func (x *DiscardTasksResponse) String() string + type HTTPRequest struct + Body []byte + Headers []*Header + Method string + Path string + Port int32 + func (*HTTPRequest) Descriptor() ([]byte, []int) + func (*HTTPRequest) ProtoMessage() + func (m *HTTPRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *HTTPRequest) MarshalToVT(dAtA []byte) (int, error) + func (m *HTTPRequest) MarshalVT() (dAtA []byte, err error) + func (m *HTTPRequest) SizeVT() (n int) + func (m *HTTPRequest) UnmarshalVT(dAtA []byte) error + func (x *HTTPRequest) GetBody() []byte + func (x *HTTPRequest) GetHeaders() []*Header + func (x *HTTPRequest) GetMethod() string + func (x *HTTPRequest) GetPath() string + func (x *HTTPRequest) GetPort() int32 + func (x *HTTPRequest) ProtoReflect() protoreflect.Message + func (x *HTTPRequest) Reset() + func (x *HTTPRequest) String() string + type HTTPResponse struct + Body []byte + Headers []*Header + StatusCode int32 + func (*HTTPResponse) Descriptor() ([]byte, []int) + func (*HTTPResponse) ProtoMessage() + func (m *HTTPResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *HTTPResponse) MarshalToVT(dAtA []byte) (int, error) + func (m *HTTPResponse) MarshalVT() (dAtA []byte, err error) + func (m *HTTPResponse) SizeVT() (n int) + func (m *HTTPResponse) UnmarshalVT(dAtA []byte) error + func (x *HTTPResponse) GetBody() []byte + func (x *HTTPResponse) GetHeaders() []*Header + func (x *HTTPResponse) GetStatusCode() int32 + func (x *HTTPResponse) ProtoReflect() protoreflect.Message + func (x *HTTPResponse) Reset() + func (x *HTTPResponse) String() string + type Header struct + Name string + Value string + func (*Header) Descriptor() ([]byte, []int) + func (*Header) ProtoMessage() + func (m *Header) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Header) MarshalToVT(dAtA []byte) (int, error) + func (m *Header) MarshalVT() (dAtA []byte, err error) + func (m *Header) SizeVT() (n int) + func (m *Header) UnmarshalVT(dAtA []byte) error + func (x *Header) GetName() string + func (x *Header) GetValue() string + func (x *Header) ProtoReflect() protoreflect.Message + func (x *Header) Reset() + func (x *Header) String() string + type KillRequest struct + ProcessId string + func (*KillRequest) Descriptor() ([]byte, []int) + func (*KillRequest) ProtoMessage() + func (m *KillRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *KillRequest) MarshalToVT(dAtA []byte) (int, error) + func (m *KillRequest) MarshalVT() (dAtA []byte, err error) + func (m *KillRequest) SizeVT() (n int) + func (m *KillRequest) UnmarshalVT(dAtA []byte) error + func (x *KillRequest) GetProcessId() string + func (x *KillRequest) ProtoReflect() protoreflect.Message + func (x *KillRequest) Reset() + func (x *KillRequest) String() string + type KillResponse struct + func (*KillResponse) Descriptor() ([]byte, []int) + func (*KillResponse) ProtoMessage() + func (m *KillResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *KillResponse) MarshalToVT(dAtA []byte) (int, error) + func (m *KillResponse) MarshalVT() (dAtA []byte, err error) + func (m *KillResponse) SizeVT() (n int) + func (m *KillResponse) UnmarshalVT(dAtA []byte) error + func (x *KillResponse) ProtoReflect() protoreflect.Message + func (x *KillResponse) Reset() + func (x *KillResponse) String() string + type LookupTasksRequest struct + TaskId []string + func (*LookupTasksRequest) Descriptor() ([]byte, []int) + func (*LookupTasksRequest) ProtoMessage() + func (m *LookupTasksRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *LookupTasksRequest) MarshalToVT(dAtA []byte) (int, error) + func (m *LookupTasksRequest) MarshalVT() (dAtA []byte, err error) + func (m *LookupTasksRequest) SizeVT() (n int) + func (m *LookupTasksRequest) UnmarshalVT(dAtA []byte) error + func (x *LookupTasksRequest) GetTaskId() []string + func (x *LookupTasksRequest) ProtoReflect() protoreflect.Message + func (x *LookupTasksRequest) Reset() + func (x *LookupTasksRequest) String() string + type LookupTasksResponse struct + Responses []*TaskResponse + func (*LookupTasksResponse) Descriptor() ([]byte, []int) + func (*LookupTasksResponse) ProtoMessage() + func (m *LookupTasksResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *LookupTasksResponse) MarshalToVT(dAtA []byte) (int, error) + func (m *LookupTasksResponse) MarshalVT() (dAtA []byte, err error) + func (m *LookupTasksResponse) SizeVT() (n int) + func (m *LookupTasksResponse) UnmarshalVT(dAtA []byte) error + func (x *LookupTasksResponse) GetResponses() []*TaskResponse + func (x *LookupTasksResponse) ProtoReflect() protoreflect.Message + func (x *LookupTasksResponse) Reset() + func (x *LookupTasksResponse) String() string + type ModuleSpec struct + Args []string + Env []string + Function string + OutboundProxy *ModuleSpec + Path string + func (*ModuleSpec) Descriptor() ([]byte, []int) + func (*ModuleSpec) ProtoMessage() + func (m *ModuleSpec) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *ModuleSpec) MarshalToVT(dAtA []byte) (int, error) + func (m *ModuleSpec) MarshalVT() (dAtA []byte, err error) + func (m *ModuleSpec) SizeVT() (n int) + func (m *ModuleSpec) UnmarshalVT(dAtA []byte) error + func (x *ModuleSpec) GetArgs() []string + func (x *ModuleSpec) GetEnv() []string + func (x *ModuleSpec) GetFunction() string + func (x *ModuleSpec) GetOutboundProxy() *ModuleSpec + func (x *ModuleSpec) GetPath() string + func (x *ModuleSpec) ProtoReflect() protoreflect.Message + func (x *ModuleSpec) Reset() + func (x *ModuleSpec) String() string + type PollTasksRequest struct + BatchSize int32 + TimeoutNs int64 + func (*PollTasksRequest) Descriptor() ([]byte, []int) + func (*PollTasksRequest) ProtoMessage() + func (m *PollTasksRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *PollTasksRequest) MarshalToVT(dAtA []byte) (int, error) + func (m *PollTasksRequest) MarshalVT() (dAtA []byte, err error) + func (m *PollTasksRequest) SizeVT() (n int) + func (m *PollTasksRequest) UnmarshalVT(dAtA []byte) error + func (x *PollTasksRequest) GetBatchSize() int32 + func (x *PollTasksRequest) GetTimeoutNs() int64 + func (x *PollTasksRequest) ProtoReflect() protoreflect.Message + func (x *PollTasksRequest) Reset() + func (x *PollTasksRequest) String() string + type PollTasksResponse struct + Responses []*TaskResponse + func (*PollTasksResponse) Descriptor() ([]byte, []int) + func (*PollTasksResponse) ProtoMessage() + func (m *PollTasksResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *PollTasksResponse) MarshalToVT(dAtA []byte) (int, error) + func (m *PollTasksResponse) MarshalVT() (dAtA []byte, err error) + func (m *PollTasksResponse) SizeVT() (n int) + func (m *PollTasksResponse) UnmarshalVT(dAtA []byte) error + func (x *PollTasksResponse) GetResponses() []*TaskResponse + func (x *PollTasksResponse) ProtoReflect() protoreflect.Message + func (x *PollTasksResponse) Reset() + func (x *PollTasksResponse) String() string + type ProcessIDRequest struct + func (*ProcessIDRequest) Descriptor() ([]byte, []int) + func (*ProcessIDRequest) ProtoMessage() + func (m *ProcessIDRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *ProcessIDRequest) MarshalToVT(dAtA []byte) (int, error) + func (m *ProcessIDRequest) MarshalVT() (dAtA []byte, err error) + func (m *ProcessIDRequest) SizeVT() (n int) + func (m *ProcessIDRequest) UnmarshalVT(dAtA []byte) error + func (x *ProcessIDRequest) ProtoReflect() protoreflect.Message + func (x *ProcessIDRequest) Reset() + func (x *ProcessIDRequest) String() string + type ProcessIDResponse struct + ProcessId string + func (*ProcessIDResponse) Descriptor() ([]byte, []int) + func (*ProcessIDResponse) ProtoMessage() + func (m *ProcessIDResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *ProcessIDResponse) MarshalToVT(dAtA []byte) (int, error) + func (m *ProcessIDResponse) MarshalVT() (dAtA []byte, err error) + func (m *ProcessIDResponse) SizeVT() (n int) + func (m *ProcessIDResponse) UnmarshalVT(dAtA []byte) error + func (x *ProcessIDResponse) GetProcessId() string + func (x *ProcessIDResponse) ProtoReflect() protoreflect.Message + func (x *ProcessIDResponse) Reset() + func (x *ProcessIDResponse) String() string + type SpawnRequest struct + Module *ModuleSpec + func (*SpawnRequest) Descriptor() ([]byte, []int) + func (*SpawnRequest) ProtoMessage() + func (m *SpawnRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *SpawnRequest) MarshalToVT(dAtA []byte) (int, error) + func (m *SpawnRequest) MarshalVT() (dAtA []byte, err error) + func (m *SpawnRequest) SizeVT() (n int) + func (m *SpawnRequest) UnmarshalVT(dAtA []byte) error + func (x *SpawnRequest) GetModule() *ModuleSpec + func (x *SpawnRequest) ProtoReflect() protoreflect.Message + func (x *SpawnRequest) Reset() + func (x *SpawnRequest) String() string + type SpawnResponse struct + IpAddress string + ProcessId string + func (*SpawnResponse) Descriptor() ([]byte, []int) + func (*SpawnResponse) ProtoMessage() + func (m *SpawnResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *SpawnResponse) MarshalToVT(dAtA []byte) (int, error) + func (m *SpawnResponse) MarshalVT() (dAtA []byte, err error) + func (m *SpawnResponse) SizeVT() (n int) + func (m *SpawnResponse) UnmarshalVT(dAtA []byte) error + func (x *SpawnResponse) GetIpAddress() string + func (x *SpawnResponse) GetProcessId() string + func (x *SpawnResponse) ProtoReflect() protoreflect.Message + func (x *SpawnResponse) Reset() + func (x *SpawnResponse) String() string + type SubmitTasksRequest struct + Requests []*TaskRequest + func (*SubmitTasksRequest) Descriptor() ([]byte, []int) + func (*SubmitTasksRequest) ProtoMessage() + func (m *SubmitTasksRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *SubmitTasksRequest) MarshalToVT(dAtA []byte) (int, error) + func (m *SubmitTasksRequest) MarshalVT() (dAtA []byte, err error) + func (m *SubmitTasksRequest) SizeVT() (n int) + func (m *SubmitTasksRequest) UnmarshalVT(dAtA []byte) error + func (x *SubmitTasksRequest) GetRequests() []*TaskRequest + func (x *SubmitTasksRequest) ProtoReflect() protoreflect.Message + func (x *SubmitTasksRequest) Reset() + func (x *SubmitTasksRequest) String() string + type SubmitTasksResponse struct + TaskId []string + func (*SubmitTasksResponse) Descriptor() ([]byte, []int) + func (*SubmitTasksResponse) ProtoMessage() + func (m *SubmitTasksResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *SubmitTasksResponse) MarshalToVT(dAtA []byte) (int, error) + func (m *SubmitTasksResponse) MarshalVT() (dAtA []byte, err error) + func (m *SubmitTasksResponse) SizeVT() (n int) + func (m *SubmitTasksResponse) UnmarshalVT(dAtA []byte) error + func (x *SubmitTasksResponse) GetTaskId() []string + func (x *SubmitTasksResponse) ProtoReflect() protoreflect.Message + func (x *SubmitTasksResponse) Reset() + func (x *SubmitTasksResponse) String() string + type TaskRequest struct + Input isTaskRequest_Input + Module *ModuleSpec + func (*TaskRequest) Descriptor() ([]byte, []int) + func (*TaskRequest) ProtoMessage() + func (m *TaskRequest) GetInput() isTaskRequest_Input + func (m *TaskRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *TaskRequest) MarshalToVT(dAtA []byte) (int, error) + func (m *TaskRequest) MarshalVT() (dAtA []byte, err error) + func (m *TaskRequest) SizeVT() (n int) + func (m *TaskRequest) UnmarshalVT(dAtA []byte) error + func (x *TaskRequest) GetHttpRequest() *HTTPRequest + func (x *TaskRequest) GetModule() *ModuleSpec + func (x *TaskRequest) ProtoReflect() protoreflect.Message + func (x *TaskRequest) Reset() + func (x *TaskRequest) String() string + type TaskRequest_HttpRequest struct + HttpRequest *HTTPRequest + func (m *TaskRequest_HttpRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *TaskRequest_HttpRequest) MarshalToVT(dAtA []byte) (int, error) + func (m *TaskRequest_HttpRequest) SizeVT() (n int) + type TaskResponse struct + ErrorMessage string + Output isTaskResponse_Output + ProcessId string + State TaskState + TaskId string + func (*TaskResponse) Descriptor() ([]byte, []int) + func (*TaskResponse) ProtoMessage() + func (m *TaskResponse) GetOutput() isTaskResponse_Output + func (m *TaskResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *TaskResponse) MarshalToVT(dAtA []byte) (int, error) + func (m *TaskResponse) MarshalVT() (dAtA []byte, err error) + func (m *TaskResponse) SizeVT() (n int) + func (m *TaskResponse) UnmarshalVT(dAtA []byte) error + func (x *TaskResponse) GetErrorMessage() string + func (x *TaskResponse) GetHttpResponse() *HTTPResponse + func (x *TaskResponse) GetProcessId() string + func (x *TaskResponse) GetState() TaskState + func (x *TaskResponse) GetTaskId() string + func (x *TaskResponse) ProtoReflect() protoreflect.Message + func (x *TaskResponse) Reset() + func (x *TaskResponse) String() string + type TaskResponse_HttpResponse struct + HttpResponse *HTTPResponse + func (m *TaskResponse_HttpResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *TaskResponse_HttpResponse) MarshalToVT(dAtA []byte) (int, error) + func (m *TaskResponse_HttpResponse) SizeVT() (n int) + type TaskState int32 + const TaskState_TASK_STATE_ERROR + const TaskState_TASK_STATE_EXECUTING + const TaskState_TASK_STATE_INITIALIZING + const TaskState_TASK_STATE_QUEUED + const TaskState_TASK_STATE_SUCCESS + const TaskState_TASK_STATE_UNSPECIFIED + func (TaskState) Descriptor() protoreflect.EnumDescriptor + func (TaskState) EnumDescriptor() ([]byte, []int) + func (TaskState) Type() protoreflect.EnumType + func (x TaskState) Enum() *TaskState + func (x TaskState) Number() protoreflect.EnumNumber + func (x TaskState) String() string + type VersionRequest struct + func (*VersionRequest) Descriptor() ([]byte, []int) + func (*VersionRequest) ProtoMessage() + func (m *VersionRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *VersionRequest) MarshalToVT(dAtA []byte) (int, error) + func (m *VersionRequest) MarshalVT() (dAtA []byte, err error) + func (m *VersionRequest) SizeVT() (n int) + func (m *VersionRequest) UnmarshalVT(dAtA []byte) error + func (x *VersionRequest) ProtoReflect() protoreflect.Message + func (x *VersionRequest) Reset() + func (x *VersionRequest) String() string + type VersionResponse struct + Version string + func (*VersionResponse) Descriptor() ([]byte, []int) + func (*VersionResponse) ProtoMessage() + func (m *VersionResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *VersionResponse) MarshalToVT(dAtA []byte) (int, error) + func (m *VersionResponse) MarshalVT() (dAtA []byte, err error) + func (m *VersionResponse) SizeVT() (n int) + func (m *VersionResponse) UnmarshalVT(dAtA []byte) error + func (x *VersionResponse) GetVersion() string + func (x *VersionResponse) ProtoReflect() protoreflect.Message + func (x *VersionResponse) Reset() + func (x *VersionResponse) String() string