api

package
v0.0.0-...-fb044b6 Latest Latest
Warning

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

Go to latest
Published: Sep 13, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	Interaction_Stream_name = map[int32]string{
		0: "NONE",
		1: "STDIN",
		2: "STDOUT",
		3: "STDERR",
		4: "SIZE",
	}
	Interaction_Stream_value = map[string]int32{
		"NONE":   0,
		"STDIN":  1,
		"STDOUT": 2,
		"STDERR": 3,
		"SIZE":   4,
	}
)

Enum value maps for Interaction_Stream.

View Source
var Agent_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "khutulun.Agent",
	HandlerType: (*AgentServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "getVersion",
			Handler:    _Agent_GetVersion_Handler,
		},
		{
			MethodName: "addHost",
			Handler:    _Agent_AddHost_Handler,
		},
		{
			MethodName: "removePackage",
			Handler:    _Agent_RemovePackage_Handler,
		},
		{
			MethodName: "deployService",
			Handler:    _Agent_DeployService_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "listHosts",
			Handler:       _Agent_ListHosts_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "listNamespaces",
			Handler:       _Agent_ListNamespaces_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "listPackages",
			Handler:       _Agent_ListPackages_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "listPackageFiles",
			Handler:       _Agent_ListPackageFiles_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "getPackageFiles",
			Handler:       _Agent_GetPackageFiles_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "setPackageFiles",
			Handler:       _Agent_SetPackageFiles_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "listResources",
			Handler:       _Agent_ListResources_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "interact",
			Handler:       _Agent_Interact_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "khutulun.proto",
}

Agent_ServiceDesc is the grpc.ServiceDesc for Agent 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 Delegate_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "khutulun.Delegate",
	HandlerType: (*DelegateServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "processService",
			Handler:    _Delegate_ProcessService_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "listResources",
			Handler:       _Delegate_ListResources_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "interact",
			Handler:       _Delegate_Interact_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "khutulun.proto",
}

Delegate_ServiceDesc is the grpc.ServiceDesc for Delegate 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_khutulun_proto protoreflect.FileDescriptor

Functions

func RegisterAgentServer

func RegisterAgentServer(s grpc.ServiceRegistrar, srv AgentServer)

func RegisterDelegateServer

func RegisterDelegateServer(s grpc.ServiceRegistrar, srv DelegateServer)

Types

type AddHost

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

func (*AddHost) Descriptor deprecated

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

Deprecated: Use AddHost.ProtoReflect.Descriptor instead.

func (*AddHost) GetGossipAddress

func (x *AddHost) GetGossipAddress() string

func (*AddHost) ProtoMessage

func (*AddHost) ProtoMessage()

func (*AddHost) ProtoReflect

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

func (*AddHost) Reset

func (x *AddHost) Reset()

func (*AddHost) String

func (x *AddHost) String() string

type AgentClient

type AgentClient interface {
	GetVersion(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Version, error)
	ListHosts(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (Agent_ListHostsClient, error)
	AddHost(ctx context.Context, in *AddHost, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ListNamespaces(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (Agent_ListNamespacesClient, error)
	ListPackages(ctx context.Context, in *ListPackages, opts ...grpc.CallOption) (Agent_ListPackagesClient, error)
	ListPackageFiles(ctx context.Context, in *PackageIdentifier, opts ...grpc.CallOption) (Agent_ListPackageFilesClient, error)
	GetPackageFiles(ctx context.Context, in *GetPackageFiles, opts ...grpc.CallOption) (Agent_GetPackageFilesClient, error)
	SetPackageFiles(ctx context.Context, opts ...grpc.CallOption) (Agent_SetPackageFilesClient, error)
	RemovePackage(ctx context.Context, in *PackageIdentifier, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DeployService(ctx context.Context, in *DeployService, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ListResources(ctx context.Context, in *ListResources, opts ...grpc.CallOption) (Agent_ListResourcesClient, error)
	Interact(ctx context.Context, opts ...grpc.CallOption) (Agent_InteractClient, error)
}

AgentClient is the client API for Agent 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 NewAgentClient

func NewAgentClient(cc grpc.ClientConnInterface) AgentClient

type AgentServer

type AgentServer interface {
	GetVersion(context.Context, *emptypb.Empty) (*Version, error)
	ListHosts(*emptypb.Empty, Agent_ListHostsServer) error
	AddHost(context.Context, *AddHost) (*emptypb.Empty, error)
	ListNamespaces(*emptypb.Empty, Agent_ListNamespacesServer) error
	ListPackages(*ListPackages, Agent_ListPackagesServer) error
	ListPackageFiles(*PackageIdentifier, Agent_ListPackageFilesServer) error
	GetPackageFiles(*GetPackageFiles, Agent_GetPackageFilesServer) error
	SetPackageFiles(Agent_SetPackageFilesServer) error
	RemovePackage(context.Context, *PackageIdentifier) (*emptypb.Empty, error)
	DeployService(context.Context, *DeployService) (*emptypb.Empty, error)
	ListResources(*ListResources, Agent_ListResourcesServer) error
	Interact(Agent_InteractServer) error
	// contains filtered or unexported methods
}

AgentServer is the server API for Agent service. All implementations must embed UnimplementedAgentServer for forward compatibility

type Agent_GetPackageFilesClient

type Agent_GetPackageFilesClient interface {
	Recv() (*PackageContent, error)
	grpc.ClientStream
}

type Agent_GetPackageFilesServer

type Agent_GetPackageFilesServer interface {
	Send(*PackageContent) error
	grpc.ServerStream
}

type Agent_InteractClient

type Agent_InteractClient interface {
	Send(*Interaction) error
	Recv() (*Interaction, error)
	grpc.ClientStream
}

type Agent_InteractServer

type Agent_InteractServer interface {
	Send(*Interaction) error
	Recv() (*Interaction, error)
	grpc.ServerStream
}

type Agent_ListHostsClient

type Agent_ListHostsClient interface {
	Recv() (*HostIdentifier, error)
	grpc.ClientStream
}

type Agent_ListHostsServer

type Agent_ListHostsServer interface {
	Send(*HostIdentifier) error
	grpc.ServerStream
}

type Agent_ListNamespacesClient

type Agent_ListNamespacesClient interface {
	Recv() (*Namespace, error)
	grpc.ClientStream
}

type Agent_ListNamespacesServer

type Agent_ListNamespacesServer interface {
	Send(*Namespace) error
	grpc.ServerStream
}

type Agent_ListPackageFilesClient

type Agent_ListPackageFilesClient interface {
	Recv() (*PackageFile, error)
	grpc.ClientStream
}

type Agent_ListPackageFilesServer

type Agent_ListPackageFilesServer interface {
	Send(*PackageFile) error
	grpc.ServerStream
}

type Agent_ListPackagesClient

type Agent_ListPackagesClient interface {
	Recv() (*PackageIdentifier, error)
	grpc.ClientStream
}

type Agent_ListPackagesServer

type Agent_ListPackagesServer interface {
	Send(*PackageIdentifier) error
	grpc.ServerStream
}

type Agent_ListResourcesClient

type Agent_ListResourcesClient interface {
	Recv() (*ResourceIdentifier, error)
	grpc.ClientStream
}

type Agent_ListResourcesServer

type Agent_ListResourcesServer interface {
	Send(*ResourceIdentifier) error
	grpc.ServerStream
}

type Agent_SetPackageFilesClient

type Agent_SetPackageFilesClient interface {
	Send(*PackageContent) error
	CloseAndRecv() (*emptypb.Empty, error)
	grpc.ClientStream
}

type Agent_SetPackageFilesServer

type Agent_SetPackageFilesServer interface {
	SendAndClose(*emptypb.Empty) error
	Recv() (*PackageContent, error)
	grpc.ServerStream
}

type Clout

type Clout struct {
	Cbor []byte `protobuf:"bytes,1,opt,name=cbor,proto3" json:"cbor,omitempty"`
	Yaml string `protobuf:"bytes,2,opt,name=yaml,proto3" json:"yaml,omitempty"`
	// contains filtered or unexported fields
}

func (*Clout) Descriptor deprecated

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

Deprecated: Use Clout.ProtoReflect.Descriptor instead.

func (*Clout) GetCbor

func (x *Clout) GetCbor() []byte

func (*Clout) GetYaml

func (x *Clout) GetYaml() string

func (*Clout) ProtoMessage

func (*Clout) ProtoMessage()

func (*Clout) ProtoReflect

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

func (*Clout) Reset

func (x *Clout) Reset()

func (*Clout) String

func (x *Clout) String() string

type Config

type Config struct {
	Config *structpb.Struct `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*Config) Descriptor deprecated

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

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetConfig

func (x *Config) GetConfig() *structpb.Struct

func (*Config) ProtoMessage

func (*Config) ProtoMessage()

func (*Config) ProtoReflect

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

func (*Config) Reset

func (x *Config) Reset()

func (*Config) String

func (x *Config) String() string

type DelegateClient

type DelegateClient interface {
	ListResources(ctx context.Context, in *DelegateListResources, opts ...grpc.CallOption) (Delegate_ListResourcesClient, error)
	ProcessService(ctx context.Context, in *ProcessService, opts ...grpc.CallOption) (*ProcessServiceResult, error)
	Interact(ctx context.Context, opts ...grpc.CallOption) (Delegate_InteractClient, error)
}

DelegateClient is the client API for Delegate 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 NewDelegateClient

func NewDelegateClient(cc grpc.ClientConnInterface) DelegateClient

type DelegateListResources

type DelegateListResources struct {
	Service      *ServiceIdentifier `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	CoercedClout *Clout             `protobuf:"bytes,2,opt,name=coercedClout,proto3" json:"coercedClout,omitempty"`
	// contains filtered or unexported fields
}

func (*DelegateListResources) Descriptor deprecated

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

Deprecated: Use DelegateListResources.ProtoReflect.Descriptor instead.

func (*DelegateListResources) GetCoercedClout

func (x *DelegateListResources) GetCoercedClout() *Clout

func (*DelegateListResources) GetService

func (x *DelegateListResources) GetService() *ServiceIdentifier

func (*DelegateListResources) ProtoMessage

func (*DelegateListResources) ProtoMessage()

func (*DelegateListResources) ProtoReflect

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

func (*DelegateListResources) Reset

func (x *DelegateListResources) Reset()

func (*DelegateListResources) String

func (x *DelegateListResources) String() string

type DelegateServer

type DelegateServer interface {
	ListResources(*DelegateListResources, Delegate_ListResourcesServer) error
	ProcessService(context.Context, *ProcessService) (*ProcessServiceResult, error)
	Interact(Delegate_InteractServer) error
	// contains filtered or unexported methods
}

DelegateServer is the server API for Delegate service. All implementations must embed UnimplementedDelegateServer for forward compatibility

type Delegate_InteractClient

type Delegate_InteractClient interface {
	Send(*Interaction) error
	Recv() (*Interaction, error)
	grpc.ClientStream
}

type Delegate_InteractServer

type Delegate_InteractServer interface {
	Send(*Interaction) error
	Recv() (*Interaction, error)
	grpc.ServerStream
}

type Delegate_ListResourcesClient

type Delegate_ListResourcesClient interface {
	Recv() (*ResourceIdentifier, error)
	grpc.ClientStream
}

type Delegate_ListResourcesServer

type Delegate_ListResourcesServer interface {
	Send(*ResourceIdentifier) error
	grpc.ServerStream
}

type DeployService

type DeployService struct {
	Template *PackageIdentifier `protobuf:"bytes,1,opt,name=template,proto3" json:"template,omitempty"`
	Service  *ServiceIdentifier `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	Async    bool               `protobuf:"varint,3,opt,name=async,proto3" json:"async,omitempty"`
	// contains filtered or unexported fields
}

func (*DeployService) Descriptor deprecated

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

Deprecated: Use DeployService.ProtoReflect.Descriptor instead.

func (*DeployService) GetAsync

func (x *DeployService) GetAsync() bool

func (*DeployService) GetService

func (x *DeployService) GetService() *ServiceIdentifier

func (*DeployService) GetTemplate

func (x *DeployService) GetTemplate() *PackageIdentifier

func (*DeployService) ProtoMessage

func (*DeployService) ProtoMessage()

func (*DeployService) ProtoReflect

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

func (*DeployService) Reset

func (x *DeployService) Reset()

func (*DeployService) String

func (x *DeployService) String() string

type GetPackageFiles

type GetPackageFiles struct {
	Identifier *PackageIdentifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
	Coerce     bool               `protobuf:"varint,2,opt,name=coerce,proto3" json:"coerce,omitempty"`
	Paths      []string           `protobuf:"bytes,3,rep,name=paths,proto3" json:"paths,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPackageFiles) Descriptor deprecated

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

Deprecated: Use GetPackageFiles.ProtoReflect.Descriptor instead.

func (*GetPackageFiles) GetCoerce

func (x *GetPackageFiles) GetCoerce() bool

func (*GetPackageFiles) GetIdentifier

func (x *GetPackageFiles) GetIdentifier() *PackageIdentifier

func (*GetPackageFiles) GetPaths

func (x *GetPackageFiles) GetPaths() []string

func (*GetPackageFiles) ProtoMessage

func (*GetPackageFiles) ProtoMessage()

func (*GetPackageFiles) ProtoReflect

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

func (*GetPackageFiles) Reset

func (x *GetPackageFiles) Reset()

func (*GetPackageFiles) String

func (x *GetPackageFiles) String() string

type HostIdentifier

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

func (*HostIdentifier) Descriptor deprecated

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

Deprecated: Use HostIdentifier.ProtoReflect.Descriptor instead.

func (*HostIdentifier) GetGrpcAddress

func (x *HostIdentifier) GetGrpcAddress() string

func (*HostIdentifier) GetName

func (x *HostIdentifier) GetName() string

func (*HostIdentifier) ProtoMessage

func (*HostIdentifier) ProtoMessage()

func (*HostIdentifier) ProtoReflect

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

func (*HostIdentifier) Reset

func (x *HostIdentifier) Reset()

func (*HostIdentifier) String

func (x *HostIdentifier) String() string

type Interaction

type Interaction struct {
	Start  *Interaction_Start `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	Stream Interaction_Stream `protobuf:"varint,2,opt,name=stream,proto3,enum=khutulun.Interaction_Stream" json:"stream,omitempty"`
	Bytes  []byte             `protobuf:"bytes,3,opt,name=bytes,proto3" json:"bytes,omitempty"`
	Size   *Interaction_Size  `protobuf:"bytes,4,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*Interaction) Descriptor deprecated

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

Deprecated: Use Interaction.ProtoReflect.Descriptor instead.

func (*Interaction) GetBytes

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

func (*Interaction) GetSize

func (x *Interaction) GetSize() *Interaction_Size

func (*Interaction) GetStart

func (x *Interaction) GetStart() *Interaction_Start

func (*Interaction) GetStream

func (x *Interaction) GetStream() Interaction_Stream

func (*Interaction) ProtoMessage

func (*Interaction) ProtoMessage()

func (*Interaction) ProtoReflect

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

func (*Interaction) Reset

func (x *Interaction) Reset()

func (*Interaction) String

func (x *Interaction) String() string

type InteractionErrorDetails

type InteractionErrorDetails struct {
	ExitCode int32  `protobuf:"varint,1,opt,name=exitCode,proto3" json:"exitCode,omitempty"`
	Stderr   []byte `protobuf:"bytes,2,opt,name=stderr,proto3" json:"stderr,omitempty"`
	// contains filtered or unexported fields
}

func (*InteractionErrorDetails) Descriptor deprecated

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

Deprecated: Use InteractionErrorDetails.ProtoReflect.Descriptor instead.

func (*InteractionErrorDetails) GetExitCode

func (x *InteractionErrorDetails) GetExitCode() int32

func (*InteractionErrorDetails) GetStderr

func (x *InteractionErrorDetails) GetStderr() []byte

func (*InteractionErrorDetails) ProtoMessage

func (*InteractionErrorDetails) ProtoMessage()

func (*InteractionErrorDetails) ProtoReflect

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

func (*InteractionErrorDetails) Reset

func (x *InteractionErrorDetails) Reset()

func (*InteractionErrorDetails) String

func (x *InteractionErrorDetails) String() string

type Interaction_Size

type Interaction_Size struct {
	Width  uint32 `protobuf:"varint,5,opt,name=width,proto3" json:"width,omitempty"`
	Height uint32 `protobuf:"varint,6,opt,name=height,proto3" json:"height,omitempty"`
	// contains filtered or unexported fields
}

func (*Interaction_Size) Descriptor deprecated

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

Deprecated: Use Interaction_Size.ProtoReflect.Descriptor instead.

func (*Interaction_Size) GetHeight

func (x *Interaction_Size) GetHeight() uint32

func (*Interaction_Size) GetWidth

func (x *Interaction_Size) GetWidth() uint32

func (*Interaction_Size) ProtoMessage

func (*Interaction_Size) ProtoMessage()

func (*Interaction_Size) ProtoReflect

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

func (*Interaction_Size) Reset

func (x *Interaction_Size) Reset()

func (*Interaction_Size) String

func (x *Interaction_Size) String() string

type Interaction_Start

type Interaction_Start struct {
	Identifier     []string          `protobuf:"bytes,1,rep,name=identifier,proto3" json:"identifier,omitempty"`
	Command        []string          `protobuf:"bytes,2,rep,name=command,proto3" json:"command,omitempty"`
	Environment    map[string]string `` /* 163-byte string literal not displayed */
	PseudoTerminal bool              `protobuf:"varint,4,opt,name=pseudoTerminal,proto3" json:"pseudoTerminal,omitempty"`
	InitialSize    *Interaction_Size `protobuf:"bytes,5,opt,name=initialSize,proto3" json:"initialSize,omitempty"`
	// contains filtered or unexported fields
}

func (*Interaction_Start) Descriptor deprecated

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

Deprecated: Use Interaction_Start.ProtoReflect.Descriptor instead.

func (*Interaction_Start) GetCommand

func (x *Interaction_Start) GetCommand() []string

func (*Interaction_Start) GetEnvironment

func (x *Interaction_Start) GetEnvironment() map[string]string

func (*Interaction_Start) GetIdentifier

func (x *Interaction_Start) GetIdentifier() []string

func (*Interaction_Start) GetInitialSize

func (x *Interaction_Start) GetInitialSize() *Interaction_Size

func (*Interaction_Start) GetPseudoTerminal

func (x *Interaction_Start) GetPseudoTerminal() bool

func (*Interaction_Start) ProtoMessage

func (*Interaction_Start) ProtoMessage()

func (*Interaction_Start) ProtoReflect

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

func (*Interaction_Start) Reset

func (x *Interaction_Start) Reset()

func (*Interaction_Start) String

func (x *Interaction_Start) String() string

type Interaction_Stream

type Interaction_Stream int32
const (
	Interaction_NONE   Interaction_Stream = 0
	Interaction_STDIN  Interaction_Stream = 1
	Interaction_STDOUT Interaction_Stream = 2
	Interaction_STDERR Interaction_Stream = 3
	Interaction_SIZE   Interaction_Stream = 4
)

func (Interaction_Stream) Descriptor

func (Interaction_Stream) Enum

func (Interaction_Stream) EnumDescriptor deprecated

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

Deprecated: Use Interaction_Stream.Descriptor instead.

func (Interaction_Stream) Number

func (Interaction_Stream) String

func (x Interaction_Stream) String() string

func (Interaction_Stream) Type

type ListPackages

type ListPackages struct {
	Type      *PackageType `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Namespace string       `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPackages) Descriptor deprecated

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

Deprecated: Use ListPackages.ProtoReflect.Descriptor instead.

func (*ListPackages) GetNamespace

func (x *ListPackages) GetNamespace() string

func (*ListPackages) GetType

func (x *ListPackages) GetType() *PackageType

func (*ListPackages) ProtoMessage

func (*ListPackages) ProtoMessage()

func (*ListPackages) ProtoReflect

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

func (*ListPackages) Reset

func (x *ListPackages) Reset()

func (*ListPackages) String

func (x *ListPackages) String() string

type ListResources

type ListResources struct {
	Service *ServiceIdentifier `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Type    string             `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*ListResources) Descriptor deprecated

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

Deprecated: Use ListResources.ProtoReflect.Descriptor instead.

func (*ListResources) GetService

func (x *ListResources) GetService() *ServiceIdentifier

func (*ListResources) GetType

func (x *ListResources) GetType() string

func (*ListResources) ProtoMessage

func (*ListResources) ProtoMessage()

func (*ListResources) ProtoReflect

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

func (*ListResources) Reset

func (x *ListResources) Reset()

func (*ListResources) String

func (x *ListResources) String() string

type ListServices

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

func (*ListServices) Descriptor deprecated

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

Deprecated: Use ListServices.ProtoReflect.Descriptor instead.

func (*ListServices) GetNamespace

func (x *ListServices) GetNamespace() string

func (*ListServices) ProtoMessage

func (*ListServices) ProtoMessage()

func (*ListServices) ProtoReflect

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

func (*ListServices) Reset

func (x *ListServices) Reset()

func (*ListServices) String

func (x *ListServices) String() string

type Namespace

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

func (*Namespace) Descriptor deprecated

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

Deprecated: Use Namespace.ProtoReflect.Descriptor instead.

func (*Namespace) GetName

func (x *Namespace) GetName() string

func (*Namespace) ProtoMessage

func (*Namespace) ProtoMessage()

func (*Namespace) ProtoReflect

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

func (*Namespace) Reset

func (x *Namespace) Reset()

func (*Namespace) String

func (x *Namespace) String() string

type NextService

type NextService struct {
	Host    string             `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Service *ServiceIdentifier `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	Phase   string             `protobuf:"bytes,3,opt,name=phase,proto3" json:"phase,omitempty"`
	// contains filtered or unexported fields
}

func (*NextService) Descriptor deprecated

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

Deprecated: Use NextService.ProtoReflect.Descriptor instead.

func (*NextService) GetHost

func (x *NextService) GetHost() string

func (*NextService) GetPhase

func (x *NextService) GetPhase() string

func (*NextService) GetService

func (x *NextService) GetService() *ServiceIdentifier

func (*NextService) ProtoMessage

func (*NextService) ProtoMessage()

func (*NextService) ProtoReflect

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

func (*NextService) Reset

func (x *NextService) Reset()

func (*NextService) String

func (x *NextService) String() string

type PackageContent

type PackageContent struct {
	Start *PackageContent_Start `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	File  *PackageFile          `protobuf:"bytes,2,opt,name=file,proto3" json:"file,omitempty"`
	Bytes []byte                `protobuf:"bytes,3,opt,name=bytes,proto3" json:"bytes,omitempty"`
	// contains filtered or unexported fields
}

func (*PackageContent) Descriptor deprecated

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

Deprecated: Use PackageContent.ProtoReflect.Descriptor instead.

func (*PackageContent) GetBytes

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

func (*PackageContent) GetFile

func (x *PackageContent) GetFile() *PackageFile

func (*PackageContent) GetStart

func (x *PackageContent) GetStart() *PackageContent_Start

func (*PackageContent) ProtoMessage

func (*PackageContent) ProtoMessage()

func (*PackageContent) ProtoReflect

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

func (*PackageContent) Reset

func (x *PackageContent) Reset()

func (*PackageContent) String

func (x *PackageContent) String() string

type PackageContent_Start

type PackageContent_Start struct {
	Identifier *PackageIdentifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
	// contains filtered or unexported fields
}

func (*PackageContent_Start) Descriptor deprecated

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

Deprecated: Use PackageContent_Start.ProtoReflect.Descriptor instead.

func (*PackageContent_Start) GetIdentifier

func (x *PackageContent_Start) GetIdentifier() *PackageIdentifier

func (*PackageContent_Start) ProtoMessage

func (*PackageContent_Start) ProtoMessage()

func (*PackageContent_Start) ProtoReflect

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

func (*PackageContent_Start) Reset

func (x *PackageContent_Start) Reset()

func (*PackageContent_Start) String

func (x *PackageContent_Start) String() string

type PackageFile

type PackageFile struct {
	Path       string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Executable bool   `protobuf:"varint,2,opt,name=executable,proto3" json:"executable,omitempty"`
	// contains filtered or unexported fields
}

func (*PackageFile) Descriptor deprecated

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

Deprecated: Use PackageFile.ProtoReflect.Descriptor instead.

func (*PackageFile) GetExecutable

func (x *PackageFile) GetExecutable() bool

func (*PackageFile) GetPath

func (x *PackageFile) GetPath() string

func (*PackageFile) ProtoMessage

func (*PackageFile) ProtoMessage()

func (*PackageFile) ProtoReflect

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

func (*PackageFile) Reset

func (x *PackageFile) Reset()

func (*PackageFile) String

func (x *PackageFile) String() string

type PackageIdentifier

type PackageIdentifier struct {
	Type      *PackageType `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Namespace string       `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name      string       `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*PackageIdentifier) Descriptor deprecated

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

Deprecated: Use PackageIdentifier.ProtoReflect.Descriptor instead.

func (*PackageIdentifier) GetName

func (x *PackageIdentifier) GetName() string

func (*PackageIdentifier) GetNamespace

func (x *PackageIdentifier) GetNamespace() string

func (*PackageIdentifier) GetType

func (x *PackageIdentifier) GetType() *PackageType

func (*PackageIdentifier) ProtoMessage

func (*PackageIdentifier) ProtoMessage()

func (*PackageIdentifier) ProtoReflect

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

func (*PackageIdentifier) Reset

func (x *PackageIdentifier) Reset()

func (*PackageIdentifier) String

func (x *PackageIdentifier) String() string

type PackageType

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

func (*PackageType) Descriptor deprecated

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

Deprecated: Use PackageType.ProtoReflect.Descriptor instead.

func (*PackageType) GetName

func (x *PackageType) GetName() string

func (*PackageType) ProtoMessage

func (*PackageType) ProtoMessage()

func (*PackageType) ProtoReflect

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

func (*PackageType) Reset

func (x *PackageType) Reset()

func (*PackageType) String

func (x *PackageType) String() string

type ProcessService

type ProcessService struct {
	Service      *ServiceIdentifier `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Phase        string             `protobuf:"bytes,2,opt,name=phase,proto3" json:"phase,omitempty"`
	Clout        *Clout             `protobuf:"bytes,3,opt,name=clout,proto3" json:"clout,omitempty"`
	CoercedClout *Clout             `protobuf:"bytes,4,opt,name=coercedClout,proto3" json:"coercedClout,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessService) Descriptor deprecated

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

Deprecated: Use ProcessService.ProtoReflect.Descriptor instead.

func (*ProcessService) GetClout

func (x *ProcessService) GetClout() *Clout

func (*ProcessService) GetCoercedClout

func (x *ProcessService) GetCoercedClout() *Clout

func (*ProcessService) GetPhase

func (x *ProcessService) GetPhase() string

func (*ProcessService) GetService

func (x *ProcessService) GetService() *ServiceIdentifier

func (*ProcessService) ProtoMessage

func (*ProcessService) ProtoMessage()

func (*ProcessService) ProtoReflect

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

func (*ProcessService) Reset

func (x *ProcessService) Reset()

func (*ProcessService) String

func (x *ProcessService) String() string

type ProcessServiceResult

type ProcessServiceResult struct {
	Clout *Clout         `protobuf:"bytes,1,opt,name=clout,proto3" json:"clout,omitempty"`
	Next  []*NextService `protobuf:"bytes,2,rep,name=next,proto3" json:"next,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessServiceResult) Descriptor deprecated

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

Deprecated: Use ProcessServiceResult.ProtoReflect.Descriptor instead.

func (*ProcessServiceResult) GetClout

func (x *ProcessServiceResult) GetClout() *Clout

func (*ProcessServiceResult) GetNext

func (x *ProcessServiceResult) GetNext() []*NextService

func (*ProcessServiceResult) ProtoMessage

func (*ProcessServiceResult) ProtoMessage()

func (*ProcessServiceResult) ProtoReflect

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

func (*ProcessServiceResult) Reset

func (x *ProcessServiceResult) Reset()

func (*ProcessServiceResult) String

func (x *ProcessServiceResult) String() string

type ResourceIdentifier

type ResourceIdentifier struct {
	Service *ServiceIdentifier `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Type    string             `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Name    string             `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Host    string             `protobuf:"bytes,4,opt,name=host,proto3" json:"host,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceIdentifier) Descriptor deprecated

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

Deprecated: Use ResourceIdentifier.ProtoReflect.Descriptor instead.

func (*ResourceIdentifier) GetHost

func (x *ResourceIdentifier) GetHost() string

func (*ResourceIdentifier) GetName

func (x *ResourceIdentifier) GetName() string

func (*ResourceIdentifier) GetService

func (x *ResourceIdentifier) GetService() *ServiceIdentifier

func (*ResourceIdentifier) GetType

func (x *ResourceIdentifier) GetType() string

func (*ResourceIdentifier) ProtoMessage

func (*ResourceIdentifier) ProtoMessage()

func (*ResourceIdentifier) ProtoReflect

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

func (*ResourceIdentifier) Reset

func (x *ResourceIdentifier) Reset()

func (*ResourceIdentifier) String

func (x *ResourceIdentifier) String() string

type ServiceIdentifier

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

func (*ServiceIdentifier) Descriptor deprecated

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

Deprecated: Use ServiceIdentifier.ProtoReflect.Descriptor instead.

func (*ServiceIdentifier) GetName

func (x *ServiceIdentifier) GetName() string

func (*ServiceIdentifier) GetNamespace

func (x *ServiceIdentifier) GetNamespace() string

func (*ServiceIdentifier) ProtoMessage

func (*ServiceIdentifier) ProtoMessage()

func (*ServiceIdentifier) ProtoReflect

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

func (*ServiceIdentifier) Reset

func (x *ServiceIdentifier) Reset()

func (*ServiceIdentifier) String

func (x *ServiceIdentifier) String() string

type UnimplementedAgentServer

type UnimplementedAgentServer struct {
}

UnimplementedAgentServer must be embedded to have forward compatible implementations.

func (UnimplementedAgentServer) AddHost

func (UnimplementedAgentServer) DeployService

func (UnimplementedAgentServer) GetPackageFiles

func (UnimplementedAgentServer) GetVersion

func (UnimplementedAgentServer) Interact

func (UnimplementedAgentServer) ListHosts

func (UnimplementedAgentServer) ListNamespaces

func (UnimplementedAgentServer) ListPackageFiles

func (UnimplementedAgentServer) ListPackages

func (UnimplementedAgentServer) ListResources

func (UnimplementedAgentServer) RemovePackage

func (UnimplementedAgentServer) SetPackageFiles

type UnimplementedDelegateServer

type UnimplementedDelegateServer struct {
}

UnimplementedDelegateServer must be embedded to have forward compatible implementations.

func (UnimplementedDelegateServer) Interact

func (UnimplementedDelegateServer) ListResources

func (UnimplementedDelegateServer) ProcessService

type UnsafeAgentServer

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

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

type UnsafeDelegateServer

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

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

type Version

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

func (*Version) Descriptor deprecated

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

Deprecated: Use Version.ProtoReflect.Descriptor instead.

func (*Version) GetVersion

func (x *Version) GetVersion() string

func (*Version) ProtoMessage

func (*Version) ProtoMessage()

func (*Version) ProtoReflect

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

func (*Version) Reset

func (x *Version) Reset()

func (*Version) String

func (x *Version) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL