v1alpha3

package
v0.3.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	StageStatus_name = map[int32]string{
		0: "NONE",
		1: "DOWN",
		2: "UP",
	}
	StageStatus_value = map[string]int32{
		"NONE": 0,
		"DOWN": 1,
		"UP":   2,
	}
)

Enum value maps for StageStatus.

View Source 
var File_stage_v1alpha3_stage_proto protoreflect.FileDescriptor

Functions

func RegisterPluginServer 

func RegisterPluginServer(s *grpc.Server, srv PluginServer)

Types

type CreateStageRequest 

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

func (*CreateStageRequest) Descriptor deprecated 

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

Deprecated: Use CreateStageRequest.ProtoReflect.Descriptor instead.

func (*CreateStageRequest) GetName 

func (x *CreateStageRequest) GetName() string

func (*CreateStageRequest) ProtoMessage 

func (*CreateStageRequest) ProtoMessage()

func (*CreateStageRequest) ProtoReflect 

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

func (*CreateStageRequest) Reset 

func (x *CreateStageRequest) Reset()

func (*CreateStageRequest) String 

func (x *CreateStageRequest) String() string

type DeleteStageRequest 

type DeleteStageRequest struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Force   bool   `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	Volumes bool   `protobuf:"varint,3,opt,name=volumes,proto3" json:"volumes,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteStageRequest) Descriptor deprecated 

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

Deprecated: Use DeleteStageRequest.ProtoReflect.Descriptor instead.

func (*DeleteStageRequest) GetForce 

func (x *DeleteStageRequest) GetForce() bool

func (*DeleteStageRequest) GetName 

func (x *DeleteStageRequest) GetName() string

func (*DeleteStageRequest) GetVolumes 

func (x *DeleteStageRequest) GetVolumes() bool

func (*DeleteStageRequest) ProtoMessage 

func (*DeleteStageRequest) ProtoMessage()

func (*DeleteStageRequest) ProtoReflect 

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

func (*DeleteStageRequest) Reset 

func (x *DeleteStageRequest) Reset()

func (*DeleteStageRequest) String 

func (x *DeleteStageRequest) String() string

type GetStageRequest 

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

func (*GetStageRequest) Descriptor deprecated 

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

Deprecated: Use GetStageRequest.ProtoReflect.Descriptor instead.

func (*GetStageRequest) GetName 

func (x *GetStageRequest) GetName() string

func (*GetStageRequest) ProtoMessage 

func (*GetStageRequest) ProtoMessage()

func (*GetStageRequest) ProtoReflect 

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

func (*GetStageRequest) Reset 

func (x *GetStageRequest) Reset()

func (*GetStageRequest) String 

func (x *GetStageRequest) String() string

type GetStageResponse 

type GetStageResponse struct {
	Info       *StageInfo  `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	SshOptions *SSHOptions `protobuf:"bytes,2,opt,name=ssh_options,json=sshOptions,proto3" json:"ssh_options,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStageResponse) Descriptor deprecated 

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

Deprecated: Use GetStageResponse.ProtoReflect.Descriptor instead.

func (*GetStageResponse) GetInfo 

func (x *GetStageResponse) GetInfo() *StageInfo

func (*GetStageResponse) GetSshOptions 

func (x *GetStageResponse) GetSshOptions() *SSHOptions

func (*GetStageResponse) ProtoMessage 

func (*GetStageResponse) ProtoMessage()

func (*GetStageResponse) ProtoReflect 

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

func (*GetStageResponse) Reset 

func (x *GetStageResponse) Reset()

func (*GetStageResponse) String 

func (x *GetStageResponse) String() string

type PluginClient 

type PluginClient interface {
	GetPluginInfo(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*v1alpha5.PluginInfo, error)
	InitPlugin(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*v1alpha5.InitPluginResponse, error)
	ResetPlugin(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	GetStage(ctx context.Context, in *GetStageRequest, opts ...grpc.CallOption) (*GetStageResponse, error)
	CreateStage(ctx context.Context, in *CreateStageRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	DeleteStage(ctx context.Context, in *DeleteStageRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	StartStage(ctx context.Context, in *StartStageRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	StopStage(ctx context.Context, in *StopStageRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

PluginClient is the client API for Plugin service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPluginClient 

func NewPluginClient(cc grpc.ClientConnInterface) PluginClient

type PluginServer 

type PluginServer interface {
	GetPluginInfo(context.Context, *empty.Empty) (*v1alpha5.PluginInfo, error)
	InitPlugin(context.Context, *empty.Empty) (*v1alpha5.InitPluginResponse, error)
	ResetPlugin(context.Context, *empty.Empty) (*empty.Empty, error)
	GetStage(context.Context, *GetStageRequest) (*GetStageResponse, error)
	CreateStage(context.Context, *CreateStageRequest) (*empty.Empty, error)
	DeleteStage(context.Context, *DeleteStageRequest) (*empty.Empty, error)
	StartStage(context.Context, *StartStageRequest) (*empty.Empty, error)
	StopStage(context.Context, *StopStageRequest) (*empty.Empty, error)
}

PluginServer is the server API for Plugin service.

type SSHOptions 

type SSHOptions struct {
	Hostname       string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Port           int32  `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	Username       string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
	PrivateKeyFile string `protobuf:"bytes,4,opt,name=private_key_file,json=privateKeyFile,proto3" json:"private_key_file,omitempty"`
	// contains filtered or unexported fields
}

func (*SSHOptions) Descriptor deprecated 

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

Deprecated: Use SSHOptions.ProtoReflect.Descriptor instead.

func (*SSHOptions) GetHostname 

func (x *SSHOptions) GetHostname() string

func (*SSHOptions) GetPort 

func (x *SSHOptions) GetPort() int32

func (*SSHOptions) GetPrivateKeyFile 

func (x *SSHOptions) GetPrivateKeyFile() string

func (*SSHOptions) GetUsername 

func (x *SSHOptions) GetUsername() string

func (*SSHOptions) ProtoMessage 

func (*SSHOptions) ProtoMessage()

func (*SSHOptions) ProtoReflect 

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

func (*SSHOptions) Reset 

func (x *SSHOptions) Reset()

func (*SSHOptions) String 

func (x *SSHOptions) String() string

type StageInfo 

type StageInfo struct {
	Name     string      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Hostname string      `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Status   StageStatus `protobuf:"varint,3,opt,name=status,proto3,enum=com.wabenet.dodo.stage.v1alpha3.StageStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*StageInfo) Descriptor deprecated 

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

Deprecated: Use StageInfo.ProtoReflect.Descriptor instead.

func (*StageInfo) GetHostname 

func (x *StageInfo) GetHostname() string

func (*StageInfo) GetName 

func (x *StageInfo) GetName() string

func (*StageInfo) GetStatus 

func (x *StageInfo) GetStatus() StageStatus

func (*StageInfo) ProtoMessage 

func (*StageInfo) ProtoMessage()

func (*StageInfo) ProtoReflect 

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

func (*StageInfo) Reset 

func (x *StageInfo) Reset()

func (*StageInfo) String 

func (x *StageInfo) String() string

type StageStatus 

type StageStatus int32
const (
	StageStatus_NONE StageStatus = 0
	StageStatus_DOWN StageStatus = 1
	StageStatus_UP   StageStatus = 2
)

func (StageStatus) Descriptor 

func (StageStatus) Descriptor() protoreflect.EnumDescriptor

func (StageStatus) Enum 

func (x StageStatus) Enum() *StageStatus

func (StageStatus) EnumDescriptor deprecated 

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

Deprecated: Use StageStatus.Descriptor instead.

func (StageStatus) Number 

func (x StageStatus) Number() protoreflect.EnumNumber

func (StageStatus) String 

func (x StageStatus) String() string

func (StageStatus) Type 

func (StageStatus) Type() protoreflect.EnumType

type StartStageRequest 

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

func (*StartStageRequest) Descriptor deprecated 

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

Deprecated: Use StartStageRequest.ProtoReflect.Descriptor instead.

func (*StartStageRequest) GetName 

func (x *StartStageRequest) GetName() string

func (*StartStageRequest) ProtoMessage 

func (*StartStageRequest) ProtoMessage()

func (*StartStageRequest) ProtoReflect 

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

func (*StartStageRequest) Reset 

func (x *StartStageRequest) Reset()

func (*StartStageRequest) String 

func (x *StartStageRequest) String() string

type StopStageRequest 

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

func (*StopStageRequest) Descriptor deprecated 

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

Deprecated: Use StopStageRequest.ProtoReflect.Descriptor instead.

func (*StopStageRequest) GetName 

func (x *StopStageRequest) GetName() string

func (*StopStageRequest) ProtoMessage 

func (*StopStageRequest) ProtoMessage()

func (*StopStageRequest) ProtoReflect 

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

func (*StopStageRequest) Reset 

func (x *StopStageRequest) Reset()

func (*StopStageRequest) String 

func (x *StopStageRequest) String() string

type UnimplementedPluginServer 

type UnimplementedPluginServer struct {
}

UnimplementedPluginServer can be embedded to have forward compatible implementations.

func (*UnimplementedPluginServer) CreateStage 

func (*UnimplementedPluginServer) CreateStage(context.Context, *CreateStageRequest) (*empty.Empty, error)

func (*UnimplementedPluginServer) DeleteStage 

func (*UnimplementedPluginServer) DeleteStage(context.Context, *DeleteStageRequest) (*empty.Empty, error)

func (*UnimplementedPluginServer) GetPluginInfo 

func (*UnimplementedPluginServer) GetPluginInfo(context.Context, *empty.Empty) (*v1alpha5.PluginInfo, error)

func (*UnimplementedPluginServer) GetStage 

func (*UnimplementedPluginServer) GetStage(context.Context, *GetStageRequest) (*GetStageResponse, error)

func (*UnimplementedPluginServer) InitPlugin 

func (*UnimplementedPluginServer) InitPlugin(context.Context, *empty.Empty) (*v1alpha5.InitPluginResponse, error)

func (*UnimplementedPluginServer) ResetPlugin 

func (*UnimplementedPluginServer) ResetPlugin(context.Context, *empty.Empty) (*empty.Empty, error)

func (*UnimplementedPluginServer) StartStage 

func (*UnimplementedPluginServer) StartStage(context.Context, *StartStageRequest) (*empty.Empty, error)

func (*UnimplementedPluginServer) StopStage 

func (*UnimplementedPluginServer) StopStage(context.Context, *StopStageRequest) (*empty.Empty, error)

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.