types

package
v0.0.0-...-f65cdbb Latest Latest
Warning

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

 Go to latest Published: Apr 2, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Control_Tenants_FullMethodName                = "/Control/Tenants"
	Control_AddTenant_FullMethodName              = "/Control/AddTenant"
	Control_AddPackage_FullMethodName             = "/Control/AddPackage"
	Control_AllPackages_FullMethodName            = "/Control/AllPackages"
	Control_Packages_FullMethodName               = "/Control/Packages"
	Control_UpdatePackage_FullMethodName          = "/Control/UpdatePackage"
	Control_DeletePackage_FullMethodName          = "/Control/DeletePackage"
	Control_UpdateToPackagesStr_FullMethodName    = "/Control/UpdateToPackagesStr"
	Control_Environment_FullMethodName            = "/Control/Environment"
	Control_UpdateToEnvironmentStr_FullMethodName = "/Control/UpdateToEnvironmentStr"
	Control_AddEnvironment_FullMethodName         = "/Control/AddEnvironment"
	Control_UpdateEnvironment_FullMethodName      = "/Control/UpdateEnvironment"
)
View Source 
const (
	SrvListener  = "listener"
	SrvQueue     = "queue"
	SrvExecutors = "executors"
)
View Source 
const (
	Queue_Queue_FullMethodName   = "/Queue/Queue"
	Queue_Dequeue_FullMethodName = "/Queue/Dequeue"
)
View Source 
const (
	Recorder_GetJobExecutionsStr_FullMethodName = "/Recorder/GetJobExecutionsStr"
	Recorder_JobExecutions_FullMethodName       = "/Recorder/JobExecutions"
	Recorder_AddJobExecution_FullMethodName     = "/Recorder/AddJobExecution"
)
View Source 
const (
	Repo_File_FullMethodName            = "/Repo/File"
	Repo_AddFile_FullMethodName         = "/Repo/AddFile"
	Repo_UpdateToFileStr_FullMethodName = "/Repo/UpdateToFileStr"
	Repo_AllFileNames_FullMethodName    = "/Repo/AllFileNames"
)

Variables

View Source 
var (
	UpdateType_name = map[int32]string{
		0: "New",
		1: "Update",
		2: "Delete",
	}
	UpdateType_value = map[string]int32{
		"New":    0,
		"Update": 1,
		"Delete": 2,
	}
)

Enum value maps for UpdateType.

View Source 
var (
	Host_ServerType_name = map[int32]string{
		0: "Undefined",
		1: "Grpc",
		2: "Http",
		3: "Headless",
	}
	Host_ServerType_value = map[string]int32{
		"Undefined": 0,
		"Grpc":      1,
		"Http":      2,
		"Headless":  3,
	}
)

Enum value maps for Host_ServerType.

View Source 
var (
	StorageType_name = map[int32]string{
		0: "LocalDirectory",
	}
	StorageType_value = map[string]int32{
		"LocalDirectory": 0,
	}
)

Enum value maps for StorageType.

View Source 
var (
	RuntimeType_name = map[int32]string{
		0: "Wasm10",
		1: "Go",
	}
	RuntimeType_value = map[string]int32{
		"Wasm10": 0,
		"Go":     1,
	}
)

Enum value maps for RuntimeType.

View Source 
var (
	Platform_name = map[int32]string{
		0: "TinyGO",
	}
	Platform_value = map[string]int32{
		"TinyGO": 0,
	}
)

Enum value maps for Platform.

View Source 
var (
	DataType_name = map[int32]string{
		0: "Json",
	}
	DataType_value = map[string]int32{
		"Json": 0,
	}
)

Enum value maps for DataType.

View Source 
var (
	JobResult_Type_name = map[int32]string{
		0: "Result",
		1: "Log",
	}
	JobResult_Type_value = map[string]int32{
		"Result": 0,
		"Log":    1,
	}
)

Enum value maps for JobResult_Type.

View Source 
var (
	File_FileType_name = map[int32]string{
		0: "NoType",
		1: "JsonSchema",
		2: "Wasm",
	}
	File_FileType_value = map[string]int32{
		"NoType":     0,
		"JsonSchema": 1,
		"Wasm":       2,
	}
)

Enum value maps for File_FileType.

View Source 
var Control_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Control",
	HandlerType: (*ControlServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Tenants",
			Handler:    _Control_Tenants_Handler,
		},
		{
			MethodName: "AddTenant",
			Handler:    _Control_AddTenant_Handler,
		},
		{
			MethodName: "AddPackage",
			Handler:    _Control_AddPackage_Handler,
		},
		{
			MethodName: "AllPackages",
			Handler:    _Control_AllPackages_Handler,
		},
		{
			MethodName: "Packages",
			Handler:    _Control_Packages_Handler,
		},
		{
			MethodName: "UpdatePackage",
			Handler:    _Control_UpdatePackage_Handler,
		},
		{
			MethodName: "DeletePackage",
			Handler:    _Control_DeletePackage_Handler,
		},
		{
			MethodName: "Environment",
			Handler:    _Control_Environment_Handler,
		},
		{
			MethodName: "AddEnvironment",
			Handler:    _Control_AddEnvironment_Handler,
		},
		{
			MethodName: "UpdateEnvironment",
			Handler:    _Control_UpdateEnvironment_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "UpdateToPackagesStr",
			Handler:       _Control_UpdateToPackagesStr_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "UpdateToEnvironmentStr",
			Handler:       _Control_UpdateToEnvironmentStr_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "control.proto",
}

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

View Source 
var File_common_proto protoreflect.FileDescriptor
View Source 
var File_control_proto protoreflect.FileDescriptor
View Source 
var File_queue_proto protoreflect.FileDescriptor
View Source 
var File_recorder_proto protoreflect.FileDescriptor
View Source 
var File_repo_proto protoreflect.FileDescriptor
View Source 
var Queue_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Queue",
	HandlerType: (*QueueServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Queue",
			Handler:    _Queue_Queue_Handler,
		},
		{
			MethodName: "Dequeue",
			Handler:    _Queue_Dequeue_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "queue.proto",
}

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

View Source 
var Recorder_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Recorder",
	HandlerType: (*RecorderServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "JobExecutions",
			Handler:    _Recorder_JobExecutions_Handler,
		},
		{
			MethodName: "AddJobExecution",
			Handler:    _Recorder_AddJobExecution_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetJobExecutionsStr",
			Handler:       _Recorder_GetJobExecutionsStr_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "recorder.proto",
}

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

View Source 
var Repo_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Repo",
	HandlerType: (*RepoServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "File",
			Handler:    _Repo_File_Handler,
		},
		{
			MethodName: "AddFile",
			Handler:    _Repo_AddFile_Handler,
		},
		{
			MethodName: "AllFileNames",
			Handler:    _Repo_AllFileNames_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "UpdateToFileStr",
			Handler:       _Repo_UpdateToFileStr_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "repo.proto",
}

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

Functions

func RegisterControlServer 

func RegisterControlServer(s grpc.ServiceRegistrar, srv ControlServer)

func RegisterQueueServer 

func RegisterQueueServer(s grpc.ServiceRegistrar, srv QueueServer)

func RegisterRecorderServer 

func RegisterRecorderServer(s grpc.ServiceRegistrar, srv RecorderServer)

func RegisterRepoServer 

func RegisterRepoServer(s grpc.ServiceRegistrar, srv RepoServer)

Types

type AddEnvironmentReply 

type AddEnvironmentReply struct {
	Environment *Environment `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"`
	// contains filtered or unexported fields
}

func (*AddEnvironmentReply) Descriptor deprecated 

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

Deprecated: Use AddEnvironmentReply.ProtoReflect.Descriptor instead.

func (*AddEnvironmentReply) GetEnvironment 

func (x *AddEnvironmentReply) GetEnvironment() *Environment

func (*AddEnvironmentReply) ProtoMessage 

func (*AddEnvironmentReply) ProtoMessage()

func (*AddEnvironmentReply) ProtoReflect 

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

func (*AddEnvironmentReply) Reset 

func (x *AddEnvironmentReply) Reset()

func (*AddEnvironmentReply) String 

func (x *AddEnvironmentReply) String() string

type AddEnvironmentRequest 

type AddEnvironmentRequest struct {
	Environment *Environment `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"`
	// contains filtered or unexported fields
}

func (*AddEnvironmentRequest) Descriptor deprecated 

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

Deprecated: Use AddEnvironmentRequest.ProtoReflect.Descriptor instead.

func (*AddEnvironmentRequest) GetEnvironment 

func (x *AddEnvironmentRequest) GetEnvironment() *Environment

func (*AddEnvironmentRequest) ProtoMessage 

func (*AddEnvironmentRequest) ProtoMessage()

func (*AddEnvironmentRequest) ProtoReflect 

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

func (*AddEnvironmentRequest) Reset 

func (x *AddEnvironmentRequest) Reset()

func (*AddEnvironmentRequest) String 

func (x *AddEnvironmentRequest) String() string

type AddFileReply 

type AddFileReply struct {
	Content []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*AddFileReply) Descriptor deprecated 

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

Deprecated: Use AddFileReply.ProtoReflect.Descriptor instead.

func (*AddFileReply) GetContent 

func (x *AddFileReply) GetContent() []byte

func (*AddFileReply) ProtoMessage 

func (*AddFileReply) ProtoMessage()

func (*AddFileReply) ProtoReflect 

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

func (*AddFileReply) Reset 

func (x *AddFileReply) Reset()

func (*AddFileReply) String 

func (x *AddFileReply) String() string

type AddFileRequest 

type AddFileRequest struct {
	TenantFile *TenantFile `protobuf:"bytes,1,opt,name=tenantFile,proto3" json:"tenantFile,omitempty"`
	// contains filtered or unexported fields
}

func (*AddFileRequest) Descriptor deprecated 

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

Deprecated: Use AddFileRequest.ProtoReflect.Descriptor instead.

func (*AddFileRequest) GetTenantFile 

func (x *AddFileRequest) GetTenantFile() *TenantFile

func (*AddFileRequest) ProtoMessage 

func (*AddFileRequest) ProtoMessage()

func (*AddFileRequest) ProtoReflect 

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

func (*AddFileRequest) Reset 

func (x *AddFileRequest) Reset()

func (*AddFileRequest) String 

func (x *AddFileRequest) String() string

type AddJobExecutionRequest 

type AddJobExecutionRequest struct {
	Execution *JobExecution `protobuf:"bytes,1,opt,name=execution,proto3" json:"execution,omitempty"`
	// contains filtered or unexported fields
}

func (*AddJobExecutionRequest) Descriptor deprecated 

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

Deprecated: Use AddJobExecutionRequest.ProtoReflect.Descriptor instead.

func (*AddJobExecutionRequest) GetExecution 

func (x *AddJobExecutionRequest) GetExecution() *JobExecution

func (*AddJobExecutionRequest) ProtoMessage 

func (*AddJobExecutionRequest) ProtoMessage()

func (*AddJobExecutionRequest) ProtoReflect 

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

func (*AddJobExecutionRequest) Reset 

func (x *AddJobExecutionRequest) Reset()

func (*AddJobExecutionRequest) String 

func (x *AddJobExecutionRequest) String() string

type AddPackageReply 

type AddPackageReply struct {
	Package *JobPackage `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	// contains filtered or unexported fields
}

func (*AddPackageReply) Descriptor deprecated 

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

Deprecated: Use AddPackageReply.ProtoReflect.Descriptor instead.

func (*AddPackageReply) GetPackage 

func (x *AddPackageReply) GetPackage() *JobPackage

func (*AddPackageReply) ProtoMessage 

func (*AddPackageReply) ProtoMessage()

func (*AddPackageReply) ProtoReflect 

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

func (*AddPackageReply) Reset 

func (x *AddPackageReply) Reset()

func (*AddPackageReply) String 

func (x *AddPackageReply) String() string

type AddPackageRequest 

type AddPackageRequest struct {
	Package *JobPackage `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	// contains filtered or unexported fields
}

func (*AddPackageRequest) Descriptor deprecated 

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

Deprecated: Use AddPackageRequest.ProtoReflect.Descriptor instead.

func (*AddPackageRequest) GetPackage 

func (x *AddPackageRequest) GetPackage() *JobPackage

func (*AddPackageRequest) ProtoMessage 

func (*AddPackageRequest) ProtoMessage()

func (*AddPackageRequest) ProtoReflect 

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

func (*AddPackageRequest) Reset 

func (x *AddPackageRequest) Reset()

func (*AddPackageRequest) String 

func (x *AddPackageRequest) String() string

type AddTenantReply 

type AddTenantReply struct {
	Tenant *Tenant `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	// contains filtered or unexported fields
}

func (*AddTenantReply) Descriptor deprecated 

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

Deprecated: Use AddTenantReply.ProtoReflect.Descriptor instead.

func (*AddTenantReply) GetTenant 

func (x *AddTenantReply) GetTenant() *Tenant

func (*AddTenantReply) ProtoMessage 

func (*AddTenantReply) ProtoMessage()

func (*AddTenantReply) ProtoReflect 

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

func (*AddTenantReply) Reset 

func (x *AddTenantReply) Reset()

func (*AddTenantReply) String 

func (x *AddTenantReply) String() string

type AddTenantRequest 

type AddTenantRequest struct {
	Tenant *Tenant `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	// contains filtered or unexported fields
}

func (*AddTenantRequest) Descriptor deprecated 

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

Deprecated: Use AddTenantRequest.ProtoReflect.Descriptor instead.

func (*AddTenantRequest) GetTenant 

func (x *AddTenantRequest) GetTenant() *Tenant

func (*AddTenantRequest) ProtoMessage 

func (*AddTenantRequest) ProtoMessage()

func (*AddTenantRequest) ProtoReflect 

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

func (*AddTenantRequest) Reset 

func (x *AddTenantRequest) Reset()

func (*AddTenantRequest) String 

func (x *AddTenantRequest) String() string

type AllFileNamesReply 

type AllFileNamesReply struct {
	TenantFiles []*TenantFiles `protobuf:"bytes,1,rep,name=tenantFiles,proto3" json:"tenantFiles,omitempty"`
	// contains filtered or unexported fields
}

func (*AllFileNamesReply) Descriptor deprecated 

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

Deprecated: Use AllFileNamesReply.ProtoReflect.Descriptor instead.

func (*AllFileNamesReply) GetTenantFiles 

func (x *AllFileNamesReply) GetTenantFiles() []*TenantFiles

func (*AllFileNamesReply) ProtoMessage 

func (*AllFileNamesReply) ProtoMessage()

func (*AllFileNamesReply) ProtoReflect 

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

func (*AllFileNamesReply) Reset 

func (x *AllFileNamesReply) Reset()

func (*AllFileNamesReply) String 

func (x *AllFileNamesReply) String() string

type AllPackagesReply 

type AllPackagesReply struct {
	Packages []*JobPackage `protobuf:"bytes,1,rep,name=packages,proto3" json:"packages,omitempty"`
	// contains filtered or unexported fields
}

func (*AllPackagesReply) Descriptor deprecated 

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

Deprecated: Use AllPackagesReply.ProtoReflect.Descriptor instead.

func (*AllPackagesReply) GetPackages 

func (x *AllPackagesReply) GetPackages() []*JobPackage

func (*AllPackagesReply) ProtoMessage 

func (*AllPackagesReply) ProtoMessage()

func (*AllPackagesReply) ProtoReflect 

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

func (*AllPackagesReply) Reset 

func (x *AllPackagesReply) Reset()

func (*AllPackagesReply) String 

func (x *AllPackagesReply) String() string

type ControlClient 

type ControlClient interface {
	Tenants(ctx context.Context, in *TenantsRequest, opts ...grpc.CallOption) (*TenantsReply, error)
	AddTenant(ctx context.Context, in *AddTenantRequest, opts ...grpc.CallOption) (*AddTenantReply, error)
	AddPackage(ctx context.Context, in *AddPackageRequest, opts ...grpc.CallOption) (*AddPackageReply, error)
	AllPackages(ctx context.Context, in *Void, opts ...grpc.CallOption) (*AllPackagesReply, error)
	Packages(ctx context.Context, in *PackagesRequest, opts ...grpc.CallOption) (*PackagesReply, error)
	UpdatePackage(ctx context.Context, in *UpdatePackageRequest, opts ...grpc.CallOption) (*Void, error)
	DeletePackage(ctx context.Context, in *DeletePackageRequest, opts ...grpc.CallOption) (*Void, error)
	UpdateToPackagesStr(ctx context.Context, in *UpdateToPackagesStrRequest, opts ...grpc.CallOption) (Control_UpdateToPackagesStrClient, error)
	Environment(ctx context.Context, in *Void, opts ...grpc.CallOption) (*EnvironmentReply, error)
	UpdateToEnvironmentStr(ctx context.Context, in *Void, opts ...grpc.CallOption) (Control_UpdateToEnvironmentStrClient, error)
	AddEnvironment(ctx context.Context, in *AddEnvironmentRequest, opts ...grpc.CallOption) (*AddEnvironmentReply, error)
	UpdateEnvironment(ctx context.Context, in *UpdateEnvironmentRequest, opts ...grpc.CallOption) (*Void, error)
}

ControlClient is the client API for Control service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewControlClient 

func NewControlClient(cc grpc.ClientConnInterface) ControlClient

type ControlServer 

type ControlServer interface {
	Tenants(context.Context, *TenantsRequest) (*TenantsReply, error)
	AddTenant(context.Context, *AddTenantRequest) (*AddTenantReply, error)
	AddPackage(context.Context, *AddPackageRequest) (*AddPackageReply, error)
	AllPackages(context.Context, *Void) (*AllPackagesReply, error)
	Packages(context.Context, *PackagesRequest) (*PackagesReply, error)
	UpdatePackage(context.Context, *UpdatePackageRequest) (*Void, error)
	DeletePackage(context.Context, *DeletePackageRequest) (*Void, error)
	UpdateToPackagesStr(*UpdateToPackagesStrRequest, Control_UpdateToPackagesStrServer) error
	Environment(context.Context, *Void) (*EnvironmentReply, error)
	UpdateToEnvironmentStr(*Void, Control_UpdateToEnvironmentStrServer) error
	AddEnvironment(context.Context, *AddEnvironmentRequest) (*AddEnvironmentReply, error)
	UpdateEnvironment(context.Context, *UpdateEnvironmentRequest) (*Void, error)
	// contains filtered or unexported methods
}

ControlServer is the server API for Control service. All implementations must embed UnimplementedControlServer for forward compatibility

type Control_UpdateToEnvironmentStrClient 

type Control_UpdateToEnvironmentStrClient interface {
	Recv() (*UpdateToEnvironmentStrReply, error)
	grpc.ClientStream
}

type Control_UpdateToEnvironmentStrServer 

type Control_UpdateToEnvironmentStrServer interface {
	Send(*UpdateToEnvironmentStrReply) error
	grpc.ServerStream
}

type Control_UpdateToPackagesStrClient 

type Control_UpdateToPackagesStrClient interface {
	Recv() (*UpdateToPackagesStrReply, error)
	grpc.ClientStream
}

type Control_UpdateToPackagesStrServer 

type Control_UpdateToPackagesStrServer interface {
	Send(*UpdateToPackagesStrReply) error
	grpc.ServerStream
}

type DataType 

type DataType int32
const (
	DataType_Json DataType = 0
)

func (DataType) Descriptor 

func (DataType) Descriptor() protoreflect.EnumDescriptor

func (DataType) Enum 

func (x DataType) Enum() *DataType

func (DataType) EnumDescriptor deprecated 

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

Deprecated: Use DataType.Descriptor instead.

func (DataType) Number 

func (x DataType) Number() protoreflect.EnumNumber

func (DataType) String 

func (x DataType) String() string

func (DataType) Type 

func (DataType) Type() protoreflect.EnumType

type DeletePackageRequest 

type DeletePackageRequest struct {
	Package *JobPackage `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	// contains filtered or unexported fields
}

func (*DeletePackageRequest) Descriptor deprecated 

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

Deprecated: Use DeletePackageRequest.ProtoReflect.Descriptor instead.

func (*DeletePackageRequest) GetPackage 

func (x *DeletePackageRequest) GetPackage() *JobPackage

func (*DeletePackageRequest) ProtoMessage 

func (*DeletePackageRequest) ProtoMessage()

func (*DeletePackageRequest) ProtoReflect 

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

func (*DeletePackageRequest) Reset 

func (x *DeletePackageRequest) Reset()

func (*DeletePackageRequest) String 

func (x *DeletePackageRequest) String() string

type DequeueReply 

type DequeueReply struct {
	Items []*QueueItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*DequeueReply) Descriptor deprecated 

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

Deprecated: Use DequeueReply.ProtoReflect.Descriptor instead.

func (*DequeueReply) GetItems 

func (x *DequeueReply) GetItems() []*QueueItem

func (*DequeueReply) ProtoMessage 

func (*DequeueReply) ProtoMessage()

func (*DequeueReply) ProtoReflect 

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

func (*DequeueReply) Reset 

func (x *DequeueReply) Reset()

func (*DequeueReply) String 

func (x *DequeueReply) String() string

type DequeueRequest 

type DequeueRequest struct {
	Tenant string       `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Queue  string       `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
	Items  []*QueueItem `protobuf:"bytes,3,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*DequeueRequest) Descriptor deprecated 

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

Deprecated: Use DequeueRequest.ProtoReflect.Descriptor instead.

func (*DequeueRequest) GetItems 

func (x *DequeueRequest) GetItems() []*QueueItem

func (*DequeueRequest) GetQueue 

func (x *DequeueRequest) GetQueue() string

func (*DequeueRequest) GetTenant 

func (x *DequeueRequest) GetTenant() string

func (*DequeueRequest) ProtoMessage 

func (*DequeueRequest) ProtoMessage()

func (*DequeueRequest) ProtoReflect 

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

func (*DequeueRequest) Reset 

func (x *DequeueRequest) Reset()

func (*DequeueRequest) String 

func (x *DequeueRequest) String() string

type Environment 

type Environment struct {
	ID       string     `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Services []*Service `protobuf:"bytes,2,rep,name=services,proto3" json:"services,omitempty"`
	Tenant   *Tenant    `protobuf:"bytes,3,opt,name=tenant,proto3,oneof" json:"tenant,omitempty"` // for future
	// contains filtered or unexported fields
}

func (*Environment) Descriptor deprecated 

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

Deprecated: Use Environment.ProtoReflect.Descriptor instead.

func (*Environment) GetID 

func (x *Environment) GetID() string

func (*Environment) GetServices 

func (x *Environment) GetServices() []*Service

func (*Environment) GetTenant 

func (x *Environment) GetTenant() *Tenant

func (*Environment) ProtoMessage 

func (*Environment) ProtoMessage()

func (*Environment) ProtoReflect 

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

func (*Environment) Reset 

func (x *Environment) Reset()

func (*Environment) String 

func (x *Environment) String() string

type EnvironmentReply 

type EnvironmentReply struct {
	Environment *Environment `protobuf:"bytes,1,opt,name=environment,proto3,oneof" json:"environment,omitempty"`
	// contains filtered or unexported fields
}

func (*EnvironmentReply) Descriptor deprecated 

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

Deprecated: Use EnvironmentReply.ProtoReflect.Descriptor instead.

func (*EnvironmentReply) GetEnvironment 

func (x *EnvironmentReply) GetEnvironment() *Environment

func (*EnvironmentReply) ProtoMessage 

func (*EnvironmentReply) ProtoMessage()

func (*EnvironmentReply) ProtoReflect 

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

func (*EnvironmentReply) Reset 

func (x *EnvironmentReply) Reset()

func (*EnvironmentReply) String 

func (x *EnvironmentReply) String() string

type EventDef 

type EventDef struct {
	ID            string     `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Name          *string    `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"`
	DataType      DataType   `protobuf:"varint,3,opt,name=dataType,proto3,enum=DataType" json:"dataType,omitempty"`
	Schema        *SchemaDef `protobuf:"bytes,4,opt,name=schema,proto3,oneof" json:"schema,omitempty"`
	SupplierQueue string     `protobuf:"bytes,5,opt,name=supplierQueue,proto3" json:"supplierQueue,omitempty"`
	Runtime       string     `protobuf:"bytes,6,opt,name=runtime,proto3" json:"runtime,omitempty"`
	// contains filtered or unexported fields
}

func (*EventDef) Descriptor deprecated 

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

Deprecated: Use EventDef.ProtoReflect.Descriptor instead.

func (*EventDef) GetDataType 

func (x *EventDef) GetDataType() DataType

func (*EventDef) GetID 

func (x *EventDef) GetID() string

func (*EventDef) GetName 

func (x *EventDef) GetName() string

func (*EventDef) GetRuntime 

func (x *EventDef) GetRuntime() string

func (*EventDef) GetSchema 

func (x *EventDef) GetSchema() *SchemaDef

func (*EventDef) GetSupplierQueue 

func (x *EventDef) GetSupplierQueue() string

func (*EventDef) ProtoMessage 

func (*EventDef) ProtoMessage()

func (*EventDef) ProtoReflect 

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

func (*EventDef) Reset 

func (x *EventDef) Reset()

func (*EventDef) String 

func (x *EventDef) String() string

type File 

type File struct {
	Type    File_FileType `protobuf:"varint,1,opt,name=type,proto3,enum=File_FileType" json:"type,omitempty"`
	Name    string        `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Content []byte        `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*File) Descriptor deprecated 

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

Deprecated: Use File.ProtoReflect.Descriptor instead.

func (*File) GetContent 

func (x *File) GetContent() []byte

func (*File) GetName 

func (x *File) GetName() string

func (*File) GetType 

func (x *File) GetType() File_FileType

func (*File) ProtoMessage 

func (*File) ProtoMessage()

func (*File) ProtoReflect 

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

func (*File) Reset 

func (x *File) Reset()

func (*File) String 

func (x *File) String() string

type FileReply 

type FileReply struct {
	File *File `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	// contains filtered or unexported fields
}

func (*FileReply) Descriptor deprecated 

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

Deprecated: Use FileReply.ProtoReflect.Descriptor instead.

func (*FileReply) GetFile 

func (x *FileReply) GetFile() *File

func (*FileReply) ProtoMessage 

func (*FileReply) ProtoMessage()

func (*FileReply) ProtoReflect 

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

func (*FileReply) Reset 

func (x *FileReply) Reset()

func (*FileReply) String 

func (x *FileReply) String() string

type FileRequest 

type FileRequest struct {
	TenantFile *TenantFile `protobuf:"bytes,1,opt,name=tenantFile,proto3" json:"tenantFile,omitempty"`
	// contains filtered or unexported fields
}

func (*FileRequest) Descriptor deprecated 

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

Deprecated: Use FileRequest.ProtoReflect.Descriptor instead.

func (*FileRequest) GetTenantFile 

func (x *FileRequest) GetTenantFile() *TenantFile

func (*FileRequest) ProtoMessage 

func (*FileRequest) ProtoMessage()

func (*FileRequest) ProtoReflect 

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

func (*FileRequest) Reset 

func (x *FileRequest) Reset()

func (*FileRequest) String 

func (x *FileRequest) String() string

type File_FileType 

type File_FileType int32
const (
	File_NoType     File_FileType = 0
	File_JsonSchema File_FileType = 1
	File_Wasm       File_FileType = 2
)

func (File_FileType) Descriptor 

func (File_FileType) Descriptor() protoreflect.EnumDescriptor

func (File_FileType) Enum 

func (x File_FileType) Enum() *File_FileType

func (File_FileType) EnumDescriptor deprecated 

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

Deprecated: Use File_FileType.Descriptor instead.

func (File_FileType) Number 

func (x File_FileType) Number() protoreflect.EnumNumber

func (File_FileType) String 

func (x File_FileType) String() string

func (File_FileType) Type 

func (File_FileType) Type() protoreflect.EnumType

type Host 

type Host struct {
	Ip   string          `protobuf:"bytes,1,opt,name=Ip,proto3" json:"Ip,omitempty"`
	Port uint32          `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	Type Host_ServerType `protobuf:"varint,3,opt,name=type,proto3,enum=Host_ServerType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*Host) Descriptor deprecated 

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

Deprecated: Use Host.ProtoReflect.Descriptor instead.

func (*Host) GetIp 

func (x *Host) GetIp() string

func (*Host) GetPort 

func (x *Host) GetPort() uint32

func (*Host) GetType 

func (x *Host) GetType() Host_ServerType

func (*Host) ProtoMessage 

func (*Host) ProtoMessage()

func (*Host) ProtoReflect 

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

func (*Host) Reset 

func (x *Host) Reset()

func (*Host) String 

func (x *Host) String() string

type Host_ServerType 

type Host_ServerType int32
const (
	Host_Undefined Host_ServerType = 0
	Host_Grpc      Host_ServerType = 1
	Host_Http      Host_ServerType = 2
	Host_Headless  Host_ServerType = 3
)

func (Host_ServerType) Descriptor 

func (Host_ServerType) Descriptor() protoreflect.EnumDescriptor

func (Host_ServerType) Enum 

func (x Host_ServerType) Enum() *Host_ServerType

func (Host_ServerType) EnumDescriptor deprecated 

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

Deprecated: Use Host_ServerType.Descriptor instead.

func (Host_ServerType) Number 

func (x Host_ServerType) Number() protoreflect.EnumNumber

func (Host_ServerType) String 

func (x Host_ServerType) String() string

func (Host_ServerType) Type 

func (Host_ServerType) Type() protoreflect.EnumType

type JobDef 

type JobDef struct {
	Event  *EventDef  `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	Result *ResultDef `protobuf:"bytes,2,opt,name=result,proto3,oneof" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*JobDef) Descriptor deprecated 

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

Deprecated: Use JobDef.ProtoReflect.Descriptor instead.

func (*JobDef) GetEvent 

func (x *JobDef) GetEvent() *EventDef

func (*JobDef) GetResult 

func (x *JobDef) GetResult() *ResultDef

func (*JobDef) ProtoMessage 

func (*JobDef) ProtoMessage()

func (*JobDef) ProtoReflect 

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

func (*JobDef) Reset 

func (x *JobDef) Reset()

func (*JobDef) String 

func (x *JobDef) String() string

type JobExecution 

type JobExecution struct {
	Event  string                 `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	Tenant string                 `protobuf:"bytes,2,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Queue  string                 `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"`
	Date   *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=date,proto3" json:"date,omitempty"`
	Server string                 `protobuf:"bytes,5,opt,name=server,proto3" json:"server,omitempty"`
	Result *JobResult             `protobuf:"bytes,6,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*JobExecution) Descriptor deprecated 

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

Deprecated: Use JobExecution.ProtoReflect.Descriptor instead.

func (*JobExecution) GetDate 

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

func (*JobExecution) GetEvent 

func (x *JobExecution) GetEvent() string

func (*JobExecution) GetQueue 

func (x *JobExecution) GetQueue() string

func (*JobExecution) GetResult 

func (x *JobExecution) GetResult() *JobResult

func (*JobExecution) GetServer 

func (x *JobExecution) GetServer() string

func (*JobExecution) GetTenant 

func (x *JobExecution) GetTenant() string

func (*JobExecution) ProtoMessage 

func (*JobExecution) ProtoMessage()

func (*JobExecution) ProtoReflect 

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

func (*JobExecution) Reset 

func (x *JobExecution) Reset()

func (*JobExecution) String 

func (x *JobExecution) String() string

type JobExecutionsReply 

type JobExecutionsReply struct {
	Result []string `protobuf:"bytes,1,rep,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*JobExecutionsReply) Descriptor deprecated 

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

Deprecated: Use JobExecutionsReply.ProtoReflect.Descriptor instead.

func (*JobExecutionsReply) GetResult 

func (x *JobExecutionsReply) GetResult() []string

func (*JobExecutionsReply) ProtoMessage 

func (*JobExecutionsReply) ProtoMessage()

func (*JobExecutionsReply) ProtoReflect 

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

func (*JobExecutionsReply) Reset 

func (x *JobExecutionsReply) Reset()

func (*JobExecutionsReply) String 

func (x *JobExecutionsReply) String() string

type JobExecutionsRequest 

type JobExecutionsRequest struct {
	Tenant *string `protobuf:"bytes,1,opt,name=tenant,proto3,oneof" json:"tenant,omitempty"`
	Lines  *int32  `protobuf:"varint,2,opt,name=lines,proto3,oneof" json:"lines,omitempty"`
	// contains filtered or unexported fields
}

func (*JobExecutionsRequest) Descriptor deprecated 

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

Deprecated: Use JobExecutionsRequest.ProtoReflect.Descriptor instead.

func (*JobExecutionsRequest) GetLines 

func (x *JobExecutionsRequest) GetLines() int32

func (*JobExecutionsRequest) GetTenant 

func (x *JobExecutionsRequest) GetTenant() string

func (*JobExecutionsRequest) ProtoMessage 

func (*JobExecutionsRequest) ProtoMessage()

func (*JobExecutionsRequest) ProtoReflect 

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

func (*JobExecutionsRequest) Reset 

func (x *JobExecutionsRequest) Reset()

func (*JobExecutionsRequest) String 

func (x *JobExecutionsRequest) String() string

type JobPackage 

type JobPackage struct {
	ID       string        `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Name     *string       `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"`
	Tenant   string        `protobuf:"bytes,3,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Queues   []*QueueDef   `protobuf:"bytes,4,rep,name=queues,proto3" json:"queues,omitempty"`
	Jobs     []*JobDef     `protobuf:"bytes,5,rep,name=jobs,proto3" json:"jobs,omitempty"`
	Runtimes []*RuntimeDef `protobuf:"bytes,6,rep,name=runtimes,proto3" json:"runtimes,omitempty"`
	// contains filtered or unexported fields
}

func (*JobPackage) Descriptor deprecated 

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

Deprecated: Use JobPackage.ProtoReflect.Descriptor instead.

func (*JobPackage) GetID 

func (x *JobPackage) GetID() string

func (*JobPackage) GetJobs 

func (x *JobPackage) GetJobs() []*JobDef

func (*JobPackage) GetName 

func (x *JobPackage) GetName() string

func (*JobPackage) GetQueues 

func (x *JobPackage) GetQueues() []*QueueDef

func (*JobPackage) GetRuntimes 

func (x *JobPackage) GetRuntimes() []*RuntimeDef

func (*JobPackage) GetTenant 

func (x *JobPackage) GetTenant() string

func (*JobPackage) ProtoMessage 

func (*JobPackage) ProtoMessage()

func (*JobPackage) ProtoReflect 

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

func (*JobPackage) Reset 

func (x *JobPackage) Reset()

func (*JobPackage) String 

func (x *JobPackage) String() string

type JobResult 

type JobResult struct {
	Code     uint64         `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message  string         `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Type     JobResult_Type `protobuf:"varint,3,opt,name=type,proto3,enum=JobResult_Type" json:"type,omitempty"`
	TypeDesc string         `protobuf:"bytes,4,opt,name=typeDesc,proto3" json:"typeDesc,omitempty"`
	// contains filtered or unexported fields
}

func (*JobResult) Descriptor deprecated 

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

Deprecated: Use JobResult.ProtoReflect.Descriptor instead.

func (*JobResult) GetCode 

func (x *JobResult) GetCode() uint64

func (*JobResult) GetMessage 

func (x *JobResult) GetMessage() string

func (*JobResult) GetType 

func (x *JobResult) GetType() JobResult_Type

func (*JobResult) GetTypeDesc 

func (x *JobResult) GetTypeDesc() string

func (*JobResult) ProtoMessage 

func (*JobResult) ProtoMessage()

func (*JobResult) ProtoReflect 

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

func (*JobResult) Reset 

func (x *JobResult) Reset()

func (*JobResult) String 

func (x *JobResult) String() string

type JobResult_Type 

type JobResult_Type int32
const (
	JobResult_Result JobResult_Type = 0
	JobResult_Log    JobResult_Type = 1
)

func (JobResult_Type) Descriptor 

func (JobResult_Type) Descriptor() protoreflect.EnumDescriptor

func (JobResult_Type) Enum 

func (x JobResult_Type) Enum() *JobResult_Type

func (JobResult_Type) EnumDescriptor deprecated 

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

Deprecated: Use JobResult_Type.Descriptor instead.

func (JobResult_Type) Number 

func (x JobResult_Type) Number() protoreflect.EnumNumber

func (JobResult_Type) String 

func (x JobResult_Type) String() string

func (JobResult_Type) Type 

func (JobResult_Type) Type() protoreflect.EnumType

type MerchantData 

type MerchantData struct {
	Data []interface{}
}

type PackagesReply 

type PackagesReply struct {
	Packages []*JobPackage `protobuf:"bytes,1,rep,name=packages,proto3" json:"packages,omitempty"`
	// contains filtered or unexported fields
}

func (*PackagesReply) Descriptor deprecated 

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

Deprecated: Use PackagesReply.ProtoReflect.Descriptor instead.

func (*PackagesReply) GetPackages 

func (x *PackagesReply) GetPackages() []*JobPackage

func (*PackagesReply) ProtoMessage 

func (*PackagesReply) ProtoMessage()

func (*PackagesReply) ProtoReflect 

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

func (*PackagesReply) Reset 

func (x *PackagesReply) Reset()

func (*PackagesReply) String 

func (x *PackagesReply) String() string

type PackagesRequest 

type PackagesRequest struct {
	Tenant string  `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	ID     *string `protobuf:"bytes,2,opt,name=ID,proto3,oneof" json:"ID,omitempty"`
	// contains filtered or unexported fields
}

func (*PackagesRequest) Descriptor deprecated 

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

Deprecated: Use PackagesRequest.ProtoReflect.Descriptor instead.

func (*PackagesRequest) GetID 

func (x *PackagesRequest) GetID() string

func (*PackagesRequest) GetTenant 

func (x *PackagesRequest) GetTenant() string

func (*PackagesRequest) ProtoMessage 

func (*PackagesRequest) ProtoMessage()

func (*PackagesRequest) ProtoReflect 

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

func (*PackagesRequest) Reset 

func (x *PackagesRequest) Reset()

func (*PackagesRequest) String 

func (x *PackagesRequest) String() string

type Platform 

type Platform int32
const (
	Platform_TinyGO Platform = 0
)

func (Platform) Descriptor 

func (Platform) Descriptor() protoreflect.EnumDescriptor

func (Platform) Enum 

func (x Platform) Enum() *Platform

func (Platform) EnumDescriptor deprecated 

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

Deprecated: Use Platform.Descriptor instead.

func (Platform) Number 

func (x Platform) Number() protoreflect.EnumNumber

func (Platform) String 

func (x Platform) String() string

func (Platform) Type 

func (Platform) Type() protoreflect.EnumType

type QueueClient 

type QueueClient interface {
	Queue(ctx context.Context, in *QueueRequest, opts ...grpc.CallOption) (*Void, error)
	Dequeue(ctx context.Context, in *DequeueRequest, opts ...grpc.CallOption) (*DequeueReply, error)
}

QueueClient is the client API for Queue service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewQueueClient 

func NewQueueClient(cc grpc.ClientConnInterface) QueueClient

type QueueDef 

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

func (*QueueDef) Descriptor deprecated 

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

Deprecated: Use QueueDef.ProtoReflect.Descriptor instead.

func (*QueueDef) GetID 

func (x *QueueDef) GetID() string

func (*QueueDef) GetName 

func (x *QueueDef) GetName() string

func (*QueueDef) ProtoMessage 

func (*QueueDef) ProtoMessage()

func (*QueueDef) ProtoReflect 

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

func (*QueueDef) Reset 

func (x *QueueDef) Reset()

func (*QueueDef) String 

func (x *QueueDef) String() string

type QueueItem 

type QueueItem struct {
	Event string `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	Data  []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*QueueItem) Descriptor deprecated 

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

Deprecated: Use QueueItem.ProtoReflect.Descriptor instead.

func (*QueueItem) GetData 

func (x *QueueItem) GetData() []byte

func (*QueueItem) GetEvent 

func (x *QueueItem) GetEvent() string

func (*QueueItem) ProtoMessage 

func (*QueueItem) ProtoMessage()

func (*QueueItem) ProtoReflect 

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

func (*QueueItem) Reset 

func (x *QueueItem) Reset()

func (*QueueItem) String 

func (x *QueueItem) String() string

type QueueRequest 

type QueueRequest struct {
	Tenant string       `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Queue  string       `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
	Items  []*QueueItem `protobuf:"bytes,3,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

Idea: add loadtype, and it will processed by any queue that supports that loadtype.

func (*QueueRequest) Descriptor deprecated 

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

Deprecated: Use QueueRequest.ProtoReflect.Descriptor instead.

func (*QueueRequest) GetItems 

func (x *QueueRequest) GetItems() []*QueueItem

func (*QueueRequest) GetQueue 

func (x *QueueRequest) GetQueue() string

func (*QueueRequest) GetTenant 

func (x *QueueRequest) GetTenant() string

func (*QueueRequest) ProtoMessage 

func (*QueueRequest) ProtoMessage()

func (*QueueRequest) ProtoReflect 

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

func (*QueueRequest) Reset 

func (x *QueueRequest) Reset()

func (*QueueRequest) String 

func (x *QueueRequest) String() string

type QueueServer 

type QueueServer interface {
	Queue(context.Context, *QueueRequest) (*Void, error)
	Dequeue(context.Context, *DequeueRequest) (*DequeueReply, error)
	// contains filtered or unexported methods
}

QueueServer is the server API for Queue service. All implementations must embed UnimplementedQueueServer for forward compatibility

type RecorderClient 

type RecorderClient interface {
	GetJobExecutionsStr(ctx context.Context, in *JobExecutionsRequest, opts ...grpc.CallOption) (Recorder_GetJobExecutionsStrClient, error)
	JobExecutions(ctx context.Context, in *JobExecutionsRequest, opts ...grpc.CallOption) (*JobExecutionsReply, error)
	AddJobExecution(ctx context.Context, in *AddJobExecutionRequest, opts ...grpc.CallOption) (*Void, error)
}

RecorderClient is the client API for Recorder service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewRecorderClient 

func NewRecorderClient(cc grpc.ClientConnInterface) RecorderClient

type RecorderServer 

type RecorderServer interface {
	GetJobExecutionsStr(*JobExecutionsRequest, Recorder_GetJobExecutionsStrServer) error
	JobExecutions(context.Context, *JobExecutionsRequest) (*JobExecutionsReply, error)
	AddJobExecution(context.Context, *AddJobExecutionRequest) (*Void, error)
	// contains filtered or unexported methods
}

RecorderServer is the server API for Recorder service. All implementations must embed UnimplementedRecorderServer for forward compatibility

type Recorder_GetJobExecutionsStrClient 

type Recorder_GetJobExecutionsStrClient interface {
	Recv() (*JobExecutionsReply, error)
	grpc.ClientStream
}

type Recorder_GetJobExecutionsStrServer 

type Recorder_GetJobExecutionsStrServer interface {
	Send(*JobExecutionsReply) error
	grpc.ServerStream
}

type RepoClient 

type RepoClient interface {
	File(ctx context.Context, in *FileRequest, opts ...grpc.CallOption) (*FileReply, error)
	AddFile(ctx context.Context, in *AddFileRequest, opts ...grpc.CallOption) (*AddFileReply, error)
	UpdateToFileStr(ctx context.Context, in *UpdateToFileStrRequest, opts ...grpc.CallOption) (Repo_UpdateToFileStrClient, error)
	AllFileNames(ctx context.Context, in *Void, opts ...grpc.CallOption) (*AllFileNamesReply, error)
}

RepoClient is the client API for Repo service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewRepoClient 

func NewRepoClient(cc grpc.ClientConnInterface) RepoClient

type RepoServer 

type RepoServer interface {
	File(context.Context, *FileRequest) (*FileReply, error)
	AddFile(context.Context, *AddFileRequest) (*AddFileReply, error)
	UpdateToFileStr(*UpdateToFileStrRequest, Repo_UpdateToFileStrServer) error
	AllFileNames(context.Context, *Void) (*AllFileNamesReply, error)
	// contains filtered or unexported methods
}

RepoServer is the server API for Repo service. All implementations must embed UnimplementedRepoServer for forward compatibility

type Repo_UpdateToFileStrClient 

type Repo_UpdateToFileStrClient interface {
	Recv() (*UpdateToFileStrReply, error)
	grpc.ClientStream
}

type Repo_UpdateToFileStrServer 

type Repo_UpdateToFileStrServer interface {
	Send(*UpdateToFileStrReply) error
	grpc.ServerStream
}

type ResultDef 

type ResultDef struct {
	Ok    *EventDef `protobuf:"bytes,1,opt,name=ok,proto3,oneof" json:"ok,omitempty"`
	Error *EventDef `protobuf:"bytes,2,opt,name=error,proto3,oneof" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ResultDef) Descriptor deprecated 

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

Deprecated: Use ResultDef.ProtoReflect.Descriptor instead.

func (*ResultDef) GetError 

func (x *ResultDef) GetError() *EventDef

func (*ResultDef) GetOk 

func (x *ResultDef) GetOk() *EventDef

func (*ResultDef) ProtoMessage 

func (*ResultDef) ProtoMessage()

func (*ResultDef) ProtoReflect 

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

func (*ResultDef) Reset 

func (x *ResultDef) Reset()

func (*ResultDef) String 

func (x *ResultDef) String() string

type RuntimeDef 

type RuntimeDef struct {
	ID           string      `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Name         *string     `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"`
	ModuleRef    string      `protobuf:"bytes,3,opt,name=moduleRef,proto3" json:"moduleRef,omitempty"`
	MainFuncName *string     `protobuf:"bytes,4,opt,name=mainFuncName,proto3,oneof" json:"mainFuncName,omitempty"`
	Type         RuntimeType `protobuf:"varint,5,opt,name=type,proto3,enum=RuntimeType" json:"type,omitempty"`
	Platform     *Platform   `protobuf:"varint,6,opt,name=platform,proto3,enum=Platform,oneof" json:"platform,omitempty"`
	// contains filtered or unexported fields
}

func (*RuntimeDef) Descriptor deprecated 

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

Deprecated: Use RuntimeDef.ProtoReflect.Descriptor instead.

func (*RuntimeDef) GetID 

func (x *RuntimeDef) GetID() string

func (*RuntimeDef) GetMainFuncName 

func (x *RuntimeDef) GetMainFuncName() string

func (*RuntimeDef) GetModuleRef 

func (x *RuntimeDef) GetModuleRef() string

func (*RuntimeDef) GetName 

func (x *RuntimeDef) GetName() string

func (*RuntimeDef) GetPlatform 

func (x *RuntimeDef) GetPlatform() Platform

func (*RuntimeDef) GetType 

func (x *RuntimeDef) GetType() RuntimeType

func (*RuntimeDef) ProtoMessage 

func (*RuntimeDef) ProtoMessage()

func (*RuntimeDef) ProtoReflect 

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

func (*RuntimeDef) Reset 

func (x *RuntimeDef) Reset()

func (*RuntimeDef) String 

func (x *RuntimeDef) String() string

type RuntimeType 

type RuntimeType int32
const (
	RuntimeType_Wasm10 RuntimeType = 0
	RuntimeType_Go     RuntimeType = 1
)

func (RuntimeType) Descriptor 

func (RuntimeType) Descriptor() protoreflect.EnumDescriptor

func (RuntimeType) Enum 

func (x RuntimeType) Enum() *RuntimeType

func (RuntimeType) EnumDescriptor deprecated 

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

Deprecated: Use RuntimeType.Descriptor instead.

func (RuntimeType) Number 

func (x RuntimeType) Number() protoreflect.EnumNumber

func (RuntimeType) String 

func (x RuntimeType) String() string

func (RuntimeType) Type 

func (RuntimeType) Type() protoreflect.EnumType

type SchemaDef 

type SchemaDef struct {
	ID        string  `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Name      *string `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"`
	SchemaRef string  `protobuf:"bytes,3,opt,name=schemaRef,proto3" json:"schemaRef,omitempty"`
	// contains filtered or unexported fields
}

func (*SchemaDef) Descriptor deprecated 

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

Deprecated: Use SchemaDef.ProtoReflect.Descriptor instead.

func (*SchemaDef) GetID 

func (x *SchemaDef) GetID() string

func (*SchemaDef) GetName 

func (x *SchemaDef) GetName() string

func (*SchemaDef) GetSchemaRef 

func (x *SchemaDef) GetSchemaRef() string

func (*SchemaDef) ProtoMessage 

func (*SchemaDef) ProtoMessage()

func (*SchemaDef) ProtoReflect 

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

func (*SchemaDef) Reset 

func (x *SchemaDef) Reset()

func (*SchemaDef) String 

func (x *SchemaDef) String() string

type Service 

type Service struct {
	ID       string     `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Name     *string    `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"`
	Servers  []*Host    `protobuf:"bytes,3,rep,name=servers,proto3" json:"servers,omitempty"`
	Storages []*Storage `protobuf:"bytes,4,rep,name=storages,proto3" json:"storages,omitempty"`
	// contains filtered or unexported fields
}

func (*Service) Descriptor deprecated 

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

Deprecated: Use Service.ProtoReflect.Descriptor instead.

func (*Service) GetID 

func (x *Service) GetID() string

func (*Service) GetName 

func (x *Service) GetName() string

func (*Service) GetServers 

func (x *Service) GetServers() []*Host

func (*Service) GetStorages 

func (x *Service) GetStorages() []*Storage

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) ProtoReflect 

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

func (*Service) Reset 

func (x *Service) Reset()

func (*Service) String 

func (x *Service) String() string

type Storage 

type Storage struct {
	ID        string      `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Name      *string     `protobuf:"bytes,2,opt,name=Name,proto3,oneof" json:"Name,omitempty"`
	Reference string      `protobuf:"bytes,3,opt,name=reference,proto3" json:"reference,omitempty"`
	Type      StorageType `protobuf:"varint,4,opt,name=type,proto3,enum=StorageType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*Storage) Descriptor deprecated 

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

Deprecated: Use Storage.ProtoReflect.Descriptor instead.

func (*Storage) GetID 

func (x *Storage) GetID() string

func (*Storage) GetName 

func (x *Storage) GetName() string

func (*Storage) GetReference 

func (x *Storage) GetReference() string

func (*Storage) GetType 

func (x *Storage) GetType() StorageType

func (*Storage) ProtoMessage 

func (*Storage) ProtoMessage()

func (*Storage) ProtoReflect 

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

func (*Storage) Reset 

func (x *Storage) Reset()

func (*Storage) String 

func (x *Storage) String() string

type StorageType 

type StorageType int32
const (
	StorageType_LocalDirectory StorageType = 0
)

func (StorageType) Descriptor 

func (StorageType) Descriptor() protoreflect.EnumDescriptor

func (StorageType) Enum 

func (x StorageType) Enum() *StorageType

func (StorageType) EnumDescriptor deprecated 

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

Deprecated: Use StorageType.Descriptor instead.

func (StorageType) Number 

func (x StorageType) Number() protoreflect.EnumNumber

func (StorageType) String 

func (x StorageType) String() string

func (StorageType) Type 

func (StorageType) Type() protoreflect.EnumType

type Tenant 

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

func (*Tenant) Descriptor deprecated 

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

Deprecated: Use Tenant.ProtoReflect.Descriptor instead.

func (*Tenant) GetID 

func (x *Tenant) GetID() string

func (*Tenant) GetName 

func (x *Tenant) GetName() string

func (*Tenant) ProtoMessage 

func (*Tenant) ProtoMessage()

func (*Tenant) ProtoReflect 

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

func (*Tenant) Reset 

func (x *Tenant) Reset()

func (*Tenant) String 

func (x *Tenant) String() string

type TenantFile 

type TenantFile struct {
	Tenant string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	File   *File  `protobuf:"bytes,2,opt,name=file,proto3" json:"file,omitempty"`
	// contains filtered or unexported fields
}

func (*TenantFile) Descriptor deprecated 

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

Deprecated: Use TenantFile.ProtoReflect.Descriptor instead.

func (*TenantFile) GetFile 

func (x *TenantFile) GetFile() *File

func (*TenantFile) GetTenant 

func (x *TenantFile) GetTenant() string

func (*TenantFile) ProtoMessage 

func (*TenantFile) ProtoMessage()

func (*TenantFile) ProtoReflect 

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

func (*TenantFile) Reset 

func (x *TenantFile) Reset()

func (*TenantFile) String 

func (x *TenantFile) String() string

type TenantFiles 

type TenantFiles struct {
	Tenant string  `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Files  []*File `protobuf:"bytes,2,rep,name=files,proto3" json:"files,omitempty"`
	// contains filtered or unexported fields
}

func (*TenantFiles) Descriptor deprecated 

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

Deprecated: Use TenantFiles.ProtoReflect.Descriptor instead.

func (*TenantFiles) GetFiles 

func (x *TenantFiles) GetFiles() []*File

func (*TenantFiles) GetTenant 

func (x *TenantFiles) GetTenant() string

func (*TenantFiles) ProtoMessage 

func (*TenantFiles) ProtoMessage()

func (*TenantFiles) ProtoReflect 

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

func (*TenantFiles) Reset 

func (x *TenantFiles) Reset()

func (*TenantFiles) String 

func (x *TenantFiles) String() string

type TenantsReply 

type TenantsReply struct {
	Tenants []*Tenant `protobuf:"bytes,1,rep,name=Tenants,proto3" json:"Tenants,omitempty"`
	// contains filtered or unexported fields
}

func (*TenantsReply) Descriptor deprecated 

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

Deprecated: Use TenantsReply.ProtoReflect.Descriptor instead.

func (*TenantsReply) GetTenants 

func (x *TenantsReply) GetTenants() []*Tenant

func (*TenantsReply) ProtoMessage 

func (*TenantsReply) ProtoMessage()

func (*TenantsReply) ProtoReflect 

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

func (*TenantsReply) Reset 

func (x *TenantsReply) Reset()

func (*TenantsReply) String 

func (x *TenantsReply) String() string

type TenantsRequest 

type TenantsRequest struct {
	ID     *string `protobuf:"bytes,1,opt,name=ID,proto3,oneof" json:"ID,omitempty"`
	Tenant *string `protobuf:"bytes,2,opt,name=tenant,proto3,oneof" json:"tenant,omitempty"`
	// contains filtered or unexported fields
}

func (*TenantsRequest) Descriptor deprecated 

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

Deprecated: Use TenantsRequest.ProtoReflect.Descriptor instead.

func (*TenantsRequest) GetID 

func (x *TenantsRequest) GetID() string

func (*TenantsRequest) GetTenant 

func (x *TenantsRequest) GetTenant() string

func (*TenantsRequest) ProtoMessage 

func (*TenantsRequest) ProtoMessage()

func (*TenantsRequest) ProtoReflect 

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

func (*TenantsRequest) Reset 

func (x *TenantsRequest) Reset()

func (*TenantsRequest) String 

func (x *TenantsRequest) String() string

type UnimplementedControlServer 

type UnimplementedControlServer struct {
}

UnimplementedControlServer must be embedded to have forward compatible implementations.

func (UnimplementedControlServer) AddEnvironment 

func (UnimplementedControlServer) AddEnvironment(context.Context, *AddEnvironmentRequest) (*AddEnvironmentReply, error)

func (UnimplementedControlServer) AddPackage 

func (UnimplementedControlServer) AddPackage(context.Context, *AddPackageRequest) (*AddPackageReply, error)

func (UnimplementedControlServer) AddTenant 

func (UnimplementedControlServer) AddTenant(context.Context, *AddTenantRequest) (*AddTenantReply, error)

func (UnimplementedControlServer) AllPackages 

func (UnimplementedControlServer) AllPackages(context.Context, *Void) (*AllPackagesReply, error)

func (UnimplementedControlServer) DeletePackage 

func (UnimplementedControlServer) DeletePackage(context.Context, *DeletePackageRequest) (*Void, error)

func (UnimplementedControlServer) Environment 

func (UnimplementedControlServer) Environment(context.Context, *Void) (*EnvironmentReply, error)

func (UnimplementedControlServer) Packages 

func (UnimplementedControlServer) Packages(context.Context, *PackagesRequest) (*PackagesReply, error)

func (UnimplementedControlServer) Tenants 

func (UnimplementedControlServer) Tenants(context.Context, *TenantsRequest) (*TenantsReply, error)

func (UnimplementedControlServer) UpdateEnvironment 

func (UnimplementedControlServer) UpdateEnvironment(context.Context, *UpdateEnvironmentRequest) (*Void, error)

func (UnimplementedControlServer) UpdatePackage 

func (UnimplementedControlServer) UpdatePackage(context.Context, *UpdatePackageRequest) (*Void, error)

func (UnimplementedControlServer) UpdateToEnvironmentStr 

func (UnimplementedControlServer) UpdateToEnvironmentStr(*Void, Control_UpdateToEnvironmentStrServer) error

func (UnimplementedControlServer) UpdateToPackagesStr 

func (UnimplementedControlServer) UpdateToPackagesStr(*UpdateToPackagesStrRequest, Control_UpdateToPackagesStrServer) error

type UnimplementedQueueServer 

type UnimplementedQueueServer struct {
}

UnimplementedQueueServer must be embedded to have forward compatible implementations.

func (UnimplementedQueueServer) Dequeue 

func (UnimplementedQueueServer) Dequeue(context.Context, *DequeueRequest) (*DequeueReply, error)

func (UnimplementedQueueServer) Queue 

func (UnimplementedQueueServer) Queue(context.Context, *QueueRequest) (*Void, error)

type UnimplementedRecorderServer 

type UnimplementedRecorderServer struct {
}

UnimplementedRecorderServer must be embedded to have forward compatible implementations.

func (UnimplementedRecorderServer) AddJobExecution 

func (UnimplementedRecorderServer) AddJobExecution(context.Context, *AddJobExecutionRequest) (*Void, error)

func (UnimplementedRecorderServer) GetJobExecutionsStr 

func (UnimplementedRecorderServer) GetJobExecutionsStr(*JobExecutionsRequest, Recorder_GetJobExecutionsStrServer) error

func (UnimplementedRecorderServer) JobExecutions 

func (UnimplementedRecorderServer) JobExecutions(context.Context, *JobExecutionsRequest) (*JobExecutionsReply, error)

type UnimplementedRepoServer 

type UnimplementedRepoServer struct {
}

UnimplementedRepoServer must be embedded to have forward compatible implementations.

func (UnimplementedRepoServer) AddFile 

func (UnimplementedRepoServer) AddFile(context.Context, *AddFileRequest) (*AddFileReply, error)

func (UnimplementedRepoServer) AllFileNames 

func (UnimplementedRepoServer) AllFileNames(context.Context, *Void) (*AllFileNamesReply, error)

func (UnimplementedRepoServer) File 

func (UnimplementedRepoServer) File(context.Context, *FileRequest) (*FileReply, error)

func (UnimplementedRepoServer) UpdateToFileStr 

func (UnimplementedRepoServer) UpdateToFileStr(*UpdateToFileStrRequest, Repo_UpdateToFileStrServer) error

type UnsafeControlServer 

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

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

type UnsafeQueueServer 

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

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

type UnsafeRecorderServer 

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

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

type UnsafeRepoServer 

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

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

type UpdateEnvironmentRequest 

type UpdateEnvironmentRequest struct {
	Environment *Environment `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateEnvironmentRequest) Descriptor deprecated 

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

Deprecated: Use UpdateEnvironmentRequest.ProtoReflect.Descriptor instead.

func (*UpdateEnvironmentRequest) GetEnvironment 

func (x *UpdateEnvironmentRequest) GetEnvironment() *Environment

func (*UpdateEnvironmentRequest) ProtoMessage 

func (*UpdateEnvironmentRequest) ProtoMessage()

func (*UpdateEnvironmentRequest) ProtoReflect 

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

func (*UpdateEnvironmentRequest) Reset 

func (x *UpdateEnvironmentRequest) Reset()

func (*UpdateEnvironmentRequest) String 

func (x *UpdateEnvironmentRequest) String() string

type UpdatePackageRequest 

type UpdatePackageRequest struct {
	Package *JobPackage `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdatePackageRequest) Descriptor deprecated 

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

Deprecated: Use UpdatePackageRequest.ProtoReflect.Descriptor instead.

func (*UpdatePackageRequest) GetPackage 

func (x *UpdatePackageRequest) GetPackage() *JobPackage

func (*UpdatePackageRequest) ProtoMessage 

func (*UpdatePackageRequest) ProtoMessage()

func (*UpdatePackageRequest) ProtoReflect 

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

func (*UpdatePackageRequest) Reset 

func (x *UpdatePackageRequest) Reset()

func (*UpdatePackageRequest) String 

func (x *UpdatePackageRequest) String() string

type UpdateToEnvironmentStrReply 

type UpdateToEnvironmentStrReply struct {
	Type   UpdateType   `protobuf:"varint,1,opt,name=type,proto3,enum=UpdateType" json:"type,omitempty"`
	Object *Environment `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateToEnvironmentStrReply) Descriptor deprecated 

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

Deprecated: Use UpdateToEnvironmentStrReply.ProtoReflect.Descriptor instead.

func (*UpdateToEnvironmentStrReply) GetObject 

func (x *UpdateToEnvironmentStrReply) GetObject() *Environment

func (*UpdateToEnvironmentStrReply) GetType 

func (x *UpdateToEnvironmentStrReply) GetType() UpdateType

func (*UpdateToEnvironmentStrReply) ProtoMessage 

func (*UpdateToEnvironmentStrReply) ProtoMessage()

func (*UpdateToEnvironmentStrReply) ProtoReflect 

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

func (*UpdateToEnvironmentStrReply) Reset 

func (x *UpdateToEnvironmentStrReply) Reset()

func (*UpdateToEnvironmentStrReply) String 

func (x *UpdateToEnvironmentStrReply) String() string

type UpdateToFileStrReply 

type UpdateToFileStrReply struct {
	Type   UpdateType  `protobuf:"varint,1,opt,name=type,proto3,enum=UpdateType" json:"type,omitempty"`
	Object *TenantFile `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateToFileStrReply) Descriptor deprecated 

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

Deprecated: Use UpdateToFileStrReply.ProtoReflect.Descriptor instead.

func (*UpdateToFileStrReply) GetObject 

func (x *UpdateToFileStrReply) GetObject() *TenantFile

func (*UpdateToFileStrReply) GetType 

func (x *UpdateToFileStrReply) GetType() UpdateType

func (*UpdateToFileStrReply) ProtoMessage 

func (*UpdateToFileStrReply) ProtoMessage()

func (*UpdateToFileStrReply) ProtoReflect 

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

func (*UpdateToFileStrReply) Reset 

func (x *UpdateToFileStrReply) Reset()

func (*UpdateToFileStrReply) String 

func (x *UpdateToFileStrReply) String() string

type UpdateToFileStrRequest 

type UpdateToFileStrRequest struct {
	Tenant string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"` //not used
	// contains filtered or unexported fields
}

func (*UpdateToFileStrRequest) Descriptor deprecated 

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

Deprecated: Use UpdateToFileStrRequest.ProtoReflect.Descriptor instead.

func (*UpdateToFileStrRequest) GetTenant 

func (x *UpdateToFileStrRequest) GetTenant() string

func (*UpdateToFileStrRequest) ProtoMessage 

func (*UpdateToFileStrRequest) ProtoMessage()

func (*UpdateToFileStrRequest) ProtoReflect 

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

func (*UpdateToFileStrRequest) Reset 

func (x *UpdateToFileStrRequest) Reset()

func (*UpdateToFileStrRequest) String 

func (x *UpdateToFileStrRequest) String() string

type UpdateToPackagesStrReply 

type UpdateToPackagesStrReply struct {
	Type   UpdateType  `protobuf:"varint,1,opt,name=type,proto3,enum=UpdateType" json:"type,omitempty"`
	Object *JobPackage `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateToPackagesStrReply) Descriptor deprecated 

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

Deprecated: Use UpdateToPackagesStrReply.ProtoReflect.Descriptor instead.

func (*UpdateToPackagesStrReply) GetObject 

func (x *UpdateToPackagesStrReply) GetObject() *JobPackage

func (*UpdateToPackagesStrReply) GetType 

func (x *UpdateToPackagesStrReply) GetType() UpdateType

func (*UpdateToPackagesStrReply) ProtoMessage 

func (*UpdateToPackagesStrReply) ProtoMessage()

func (*UpdateToPackagesStrReply) ProtoReflect 

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

func (*UpdateToPackagesStrReply) Reset 

func (x *UpdateToPackagesStrReply) Reset()

func (*UpdateToPackagesStrReply) String 

func (x *UpdateToPackagesStrReply) String() string

type UpdateToPackagesStrRequest 

type UpdateToPackagesStrRequest struct {
	Tenant string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"` //  not supported
	// contains filtered or unexported fields
}

func (*UpdateToPackagesStrRequest) Descriptor deprecated 

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

Deprecated: Use UpdateToPackagesStrRequest.ProtoReflect.Descriptor instead.

func (*UpdateToPackagesStrRequest) GetTenant 

func (x *UpdateToPackagesStrRequest) GetTenant() string

func (*UpdateToPackagesStrRequest) ProtoMessage 

func (*UpdateToPackagesStrRequest) ProtoMessage()

func (*UpdateToPackagesStrRequest) ProtoReflect 

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

func (*UpdateToPackagesStrRequest) Reset 

func (x *UpdateToPackagesStrRequest) Reset()

func (*UpdateToPackagesStrRequest) String 

func (x *UpdateToPackagesStrRequest) String() string

type UpdateType 

type UpdateType int32
const (
	UpdateType_New    UpdateType = 0
	UpdateType_Update UpdateType = 1
	UpdateType_Delete UpdateType = 2
)

func (UpdateType) Descriptor 

func (UpdateType) Descriptor() protoreflect.EnumDescriptor

func (UpdateType) Enum 

func (x UpdateType) Enum() *UpdateType

func (UpdateType) EnumDescriptor deprecated 

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

Deprecated: Use UpdateType.Descriptor instead.

func (UpdateType) Number 

func (x UpdateType) Number() protoreflect.EnumNumber

func (UpdateType) String 

func (x UpdateType) String() string

func (UpdateType) Type 

func (UpdateType) Type() protoreflect.EnumType

type Void 

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

func (*Void) Descriptor deprecated 

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

Deprecated: Use Void.ProtoReflect.Descriptor instead.

func (*Void) ProtoMessage 

func (*Void) ProtoMessage()

func (*Void) ProtoReflect 

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

func (*Void) Reset 

func (x *Void) Reset()

func (*Void) String 

func (x *Void) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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