v1

package
v0.0.1-0...-8535732 Latest Latest
Warning

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

Go to latest
Published: Dec 6, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Overview

Package v1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source
var FlavorAvailability_name = map[int32]string{
	0: "alpha",
	1: "beta",
	2: "stable",
	3: "default",
}
View Source
var FlavorAvailability_value = map[string]int32{
	"alpha":   0,
	"beta":    1,
	"stable":  2,
	"default": 3,
}
View Source
var LifespanRequest_Method_name = map[int32]string{
	0: "REPLACE",
	1: "ADD",
	2: "SUBTRACT",
}
View Source
var LifespanRequest_Method_value = map[string]int32{
	"REPLACE":  0,
	"ADD":      1,
	"SUBTRACT": 2,
}
View Source
var Status_name = map[int32]string{
	0: "FAILED",
	1: "CREATING",
	2: "READY",
	3: "DESTROYING",
	4: "FINISHED",
}
View Source
var Status_value = map[string]int32{
	"FAILED":     0,
	"CREATING":   1,
	"READY":      2,
	"DESTROYING": 3,
	"FINISHED":   4,
}

Functions

func RegisterCliServiceHandler

func RegisterCliServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterCliServiceHandler registers the http handlers for service CliService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterCliServiceHandlerClient

func RegisterCliServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client CliServiceClient) error

RegisterCliServiceHandlerClient registers the http handlers for service CliService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "CliServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "CliServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "CliServiceClient" to call the correct interceptors.

func RegisterCliServiceHandlerFromEndpoint

func RegisterCliServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterCliServiceHandlerFromEndpoint is same as RegisterCliServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterCliServiceHandlerServer

func RegisterCliServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server CliServiceServer) error

RegisterCliServiceHandlerServer registers the http handlers for service CliService to "mux". UnaryRPC :call CliServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterCliServiceServer

func RegisterCliServiceServer(s *grpc.Server, srv CliServiceServer)

func RegisterClusterServiceHandler

func RegisterClusterServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterClusterServiceHandler registers the http handlers for service ClusterService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterClusterServiceHandlerClient

func RegisterClusterServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ClusterServiceClient) error

RegisterClusterServiceHandlerClient registers the http handlers for service ClusterService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ClusterServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ClusterServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ClusterServiceClient" to call the correct interceptors.

func RegisterClusterServiceHandlerFromEndpoint

func RegisterClusterServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterClusterServiceHandlerFromEndpoint is same as RegisterClusterServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterClusterServiceHandlerServer

func RegisterClusterServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ClusterServiceServer) error

RegisterClusterServiceHandlerServer registers the http handlers for service ClusterService to "mux". UnaryRPC :call ClusterServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterClusterServiceServer

func RegisterClusterServiceServer(s *grpc.Server, srv ClusterServiceServer)

func RegisterFlavorServiceHandler

func RegisterFlavorServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterFlavorServiceHandler registers the http handlers for service FlavorService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterFlavorServiceHandlerClient

func RegisterFlavorServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client FlavorServiceClient) error

RegisterFlavorServiceHandlerClient registers the http handlers for service FlavorService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "FlavorServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "FlavorServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "FlavorServiceClient" to call the correct interceptors.

func RegisterFlavorServiceHandlerFromEndpoint

func RegisterFlavorServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterFlavorServiceHandlerFromEndpoint is same as RegisterFlavorServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterFlavorServiceHandlerServer

func RegisterFlavorServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server FlavorServiceServer) error

RegisterFlavorServiceHandlerServer registers the http handlers for service FlavorService to "mux". UnaryRPC :call FlavorServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterFlavorServiceServer

func RegisterFlavorServiceServer(s *grpc.Server, srv FlavorServiceServer)

func RegisterInfraStatusServiceHandler

func RegisterInfraStatusServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterInfraStatusServiceHandler registers the http handlers for service InfraStatusService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterInfraStatusServiceHandlerClient

func RegisterInfraStatusServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client InfraStatusServiceClient) error

RegisterInfraStatusServiceHandlerClient registers the http handlers for service InfraStatusService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "InfraStatusServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "InfraStatusServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "InfraStatusServiceClient" to call the correct interceptors.

func RegisterInfraStatusServiceHandlerFromEndpoint

func RegisterInfraStatusServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterInfraStatusServiceHandlerFromEndpoint is same as RegisterInfraStatusServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterInfraStatusServiceHandlerServer

func RegisterInfraStatusServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server InfraStatusServiceServer) error

RegisterInfraStatusServiceHandlerServer registers the http handlers for service InfraStatusService to "mux". UnaryRPC :call InfraStatusServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterInfraStatusServiceServer

func RegisterInfraStatusServiceServer(s *grpc.Server, srv InfraStatusServiceServer)

func RegisterUserServiceHandler

func RegisterUserServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterUserServiceHandler registers the http handlers for service UserService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterUserServiceHandlerClient

func RegisterUserServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client UserServiceClient) error

RegisterUserServiceHandlerClient registers the http handlers for service UserService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "UserServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "UserServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "UserServiceClient" to call the correct interceptors.

func RegisterUserServiceHandlerFromEndpoint

func RegisterUserServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterUserServiceHandlerFromEndpoint is same as RegisterUserServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterUserServiceHandlerServer

func RegisterUserServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server UserServiceServer) error

RegisterUserServiceHandlerServer registers the http handlers for service UserService to "mux". UnaryRPC :call UserServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterUserServiceServer

func RegisterUserServiceServer(s *grpc.Server, srv UserServiceServer)

func RegisterVersionServiceHandler

func RegisterVersionServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterVersionServiceHandler registers the http handlers for service VersionService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterVersionServiceHandlerClient

func RegisterVersionServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client VersionServiceClient) error

RegisterVersionServiceHandlerClient registers the http handlers for service VersionService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "VersionServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "VersionServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "VersionServiceClient" to call the correct interceptors.

func RegisterVersionServiceHandlerFromEndpoint

func RegisterVersionServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterVersionServiceHandlerFromEndpoint is same as RegisterVersionServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterVersionServiceHandlerServer

func RegisterVersionServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server VersionServiceServer) error

RegisterVersionServiceHandlerServer registers the http handlers for service VersionService to "mux". UnaryRPC :call VersionServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterVersionServiceServer

func RegisterVersionServiceServer(s *grpc.Server, srv VersionServiceServer)

Types

type Artifact

type Artifact struct {
	Name                 string   `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Description          string   `protobuf:"bytes,2,opt,name=Description,proto3" json:"Description,omitempty"`
	URL                  string   `protobuf:"bytes,3,opt,name=URL,proto3" json:"URL,omitempty"`
	Mode                 int32    `protobuf:"varint,4,opt,name=Mode,proto3" json:"Mode,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Artifact) Descriptor

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

func (*Artifact) GetDescription

func (m *Artifact) GetDescription() string

func (*Artifact) GetMode

func (m *Artifact) GetMode() int32

func (*Artifact) GetName

func (m *Artifact) GetName() string

func (*Artifact) GetURL

func (m *Artifact) GetURL() string

func (*Artifact) ProtoMessage

func (*Artifact) ProtoMessage()

func (*Artifact) Reset

func (m *Artifact) Reset()

func (*Artifact) String

func (m *Artifact) String() string

func (*Artifact) XXX_DiscardUnknown

func (m *Artifact) XXX_DiscardUnknown()

func (*Artifact) XXX_Marshal

func (m *Artifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Artifact) XXX_Merge

func (m *Artifact) XXX_Merge(src proto.Message)

func (*Artifact) XXX_Size

func (m *Artifact) XXX_Size() int

func (*Artifact) XXX_Unmarshal

func (m *Artifact) XXX_Unmarshal(b []byte) error

type CliServiceClient

type CliServiceClient interface {
	// Upgrade - gets an updated binary if it exists.
	Upgrade(ctx context.Context, in *CliUpgradeRequest, opts ...grpc.CallOption) (CliService_UpgradeClient, error)
}

CliServiceClient is the client API for CliService service.

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

func NewCliServiceClient

func NewCliServiceClient(cc *grpc.ClientConn) CliServiceClient

type CliServiceServer

type CliServiceServer interface {
	// Upgrade - gets an updated binary if it exists.
	Upgrade(*CliUpgradeRequest, CliService_UpgradeServer) error
}

CliServiceServer is the server API for CliService service.

type CliService_UpgradeClient

type CliService_UpgradeClient interface {
	Recv() (*CliUpgradeResponse, error)
	grpc.ClientStream
}

type CliService_UpgradeServer

type CliService_UpgradeServer interface {
	Send(*CliUpgradeResponse) error
	grpc.ServerStream
}

type CliUpgradeRequest

type CliUpgradeRequest struct {
	Os                   string   `protobuf:"bytes,1,opt,name=os,proto3" json:"os,omitempty"`
	Arch                 string   `protobuf:"bytes,2,opt,name=arch,proto3" json:"arch,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CliUpgradeRequest) Descriptor

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

func (*CliUpgradeRequest) GetArch

func (m *CliUpgradeRequest) GetArch() string

func (*CliUpgradeRequest) GetOs

func (m *CliUpgradeRequest) GetOs() string

func (*CliUpgradeRequest) ProtoMessage

func (*CliUpgradeRequest) ProtoMessage()

func (*CliUpgradeRequest) Reset

func (m *CliUpgradeRequest) Reset()

func (*CliUpgradeRequest) String

func (m *CliUpgradeRequest) String() string

func (*CliUpgradeRequest) XXX_DiscardUnknown

func (m *CliUpgradeRequest) XXX_DiscardUnknown()

func (*CliUpgradeRequest) XXX_Marshal

func (m *CliUpgradeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CliUpgradeRequest) XXX_Merge

func (m *CliUpgradeRequest) XXX_Merge(src proto.Message)

func (*CliUpgradeRequest) XXX_Size

func (m *CliUpgradeRequest) XXX_Size() int

func (*CliUpgradeRequest) XXX_Unmarshal

func (m *CliUpgradeRequest) XXX_Unmarshal(b []byte) error

type CliUpgradeResponse

type CliUpgradeResponse struct {
	FileChunk            []byte   `protobuf:"bytes,1,opt,name=fileChunk,proto3" json:"fileChunk,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CliUpgradeResponse) Descriptor

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

func (*CliUpgradeResponse) GetFileChunk

func (m *CliUpgradeResponse) GetFileChunk() []byte

func (*CliUpgradeResponse) ProtoMessage

func (*CliUpgradeResponse) ProtoMessage()

func (*CliUpgradeResponse) Reset

func (m *CliUpgradeResponse) Reset()

func (*CliUpgradeResponse) String

func (m *CliUpgradeResponse) String() string

func (*CliUpgradeResponse) XXX_DiscardUnknown

func (m *CliUpgradeResponse) XXX_DiscardUnknown()

func (*CliUpgradeResponse) XXX_Marshal

func (m *CliUpgradeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CliUpgradeResponse) XXX_Merge

func (m *CliUpgradeResponse) XXX_Merge(src proto.Message)

func (*CliUpgradeResponse) XXX_Size

func (m *CliUpgradeResponse) XXX_Size() int

func (*CliUpgradeResponse) XXX_Unmarshal

func (m *CliUpgradeResponse) XXX_Unmarshal(b []byte) error

type Cluster

type Cluster struct {
	// ID is the unique ID for the cluster.
	ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// Status is the current status for the cluster.
	Status Status `protobuf:"varint,2,opt,name=Status,proto3,enum=v1.Status" json:"Status,omitempty"`
	// Flavor is the original flavor ID that launched this cluster.
	Flavor string `protobuf:"bytes,3,opt,name=Flavor,proto3" json:"Flavor,omitempty"`
	// Owner is the email address for the cluster owner.
	Owner string `protobuf:"bytes,4,opt,name=Owner,proto3" json:"Owner,omitempty"`
	// CreatedOn is the timestamp on which the cluster started being created.
	CreatedOn *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=CreatedOn,proto3" json:"CreatedOn,omitempty"`
	// DestroyedOn is the timestamp on which the cluster finished being
	// destroyed.
	DestroyedOn *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=DestroyedOn,proto3" json:"DestroyedOn,omitempty"`
	// Lifespan is the duration for which the cluster should be kept alive.
	Lifespan *durationpb.Duration `protobuf:"bytes,7,opt,name=Lifespan,proto3" json:"Lifespan,omitempty"`
	// Description is a human readable description for the cluster.
	Description string `protobuf:"bytes,8,opt,name=Description,proto3" json:"Description,omitempty"`
	// URL is an optional URL for this cluster.
	URL string `protobuf:"bytes,9,opt,name=URL,proto3" json:"URL,omitempty"`
	// Connect is a command to add kube connection information to kubeconfig.
	Connect string `protobuf:"bytes,10,opt,name=Connect,proto3" json:"Connect,omitempty"`
	// Parameters is a list of options to configure the cluster creation.
	Parameters           []*Parameter `protobuf:"bytes,11,rep,name=Parameters,proto3" json:"Parameters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Cluster represents a single cluster.

func (*Cluster) Descriptor

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

func (*Cluster) GetConnect

func (m *Cluster) GetConnect() string

func (*Cluster) GetCreatedOn

func (m *Cluster) GetCreatedOn() *timestamppb.Timestamp

func (*Cluster) GetDescription

func (m *Cluster) GetDescription() string

func (*Cluster) GetDestroyedOn

func (m *Cluster) GetDestroyedOn() *timestamppb.Timestamp

func (*Cluster) GetFlavor

func (m *Cluster) GetFlavor() string

func (*Cluster) GetID

func (m *Cluster) GetID() string

func (*Cluster) GetLifespan

func (m *Cluster) GetLifespan() *durationpb.Duration

func (*Cluster) GetOwner

func (m *Cluster) GetOwner() string

func (*Cluster) GetParameters

func (m *Cluster) GetParameters() []*Parameter

func (*Cluster) GetStatus

func (m *Cluster) GetStatus() Status

func (*Cluster) GetURL

func (m *Cluster) GetURL() string

func (*Cluster) ProtoMessage

func (*Cluster) ProtoMessage()

func (*Cluster) Reset

func (m *Cluster) Reset()

func (*Cluster) String

func (m *Cluster) String() string

func (*Cluster) XXX_DiscardUnknown

func (m *Cluster) XXX_DiscardUnknown()

func (*Cluster) XXX_Marshal

func (m *Cluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Cluster) XXX_Merge

func (m *Cluster) XXX_Merge(src proto.Message)

func (*Cluster) XXX_Size

func (m *Cluster) XXX_Size() int

func (*Cluster) XXX_Unmarshal

func (m *Cluster) XXX_Unmarshal(b []byte) error

type ClusterArtifacts

type ClusterArtifacts struct {
	Artifacts            []*Artifact `protobuf:"bytes,1,rep,name=Artifacts,proto3" json:"Artifacts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ClusterArtifacts) Descriptor

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

func (*ClusterArtifacts) GetArtifacts

func (m *ClusterArtifacts) GetArtifacts() []*Artifact

func (*ClusterArtifacts) ProtoMessage

func (*ClusterArtifacts) ProtoMessage()

func (*ClusterArtifacts) Reset

func (m *ClusterArtifacts) Reset()

func (*ClusterArtifacts) String

func (m *ClusterArtifacts) String() string

func (*ClusterArtifacts) XXX_DiscardUnknown

func (m *ClusterArtifacts) XXX_DiscardUnknown()

func (*ClusterArtifacts) XXX_Marshal

func (m *ClusterArtifacts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterArtifacts) XXX_Merge

func (m *ClusterArtifacts) XXX_Merge(src proto.Message)

func (*ClusterArtifacts) XXX_Size

func (m *ClusterArtifacts) XXX_Size() int

func (*ClusterArtifacts) XXX_Unmarshal

func (m *ClusterArtifacts) XXX_Unmarshal(b []byte) error

type ClusterListRequest

type ClusterListRequest struct {
	// all indicates that all clusters should be returned, not just the ones
	// owned by the user.
	All bool `protobuf:"varint,1,opt,name=all,proto3" json:"all,omitempty"`
	// expired indicates that expired clusters should be returned, not just the
	// ones that are launching/ready.
	Expired bool `protobuf:"varint,2,opt,name=expired,proto3" json:"expired,omitempty"`
	// list clusters whose ID matches this prefix.
	Prefix               string   `protobuf:"bytes,3,opt,name=prefix,proto3" json:"prefix,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ClusterListRequest represents a request to ClusterService.List.

func (*ClusterListRequest) Descriptor

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

func (*ClusterListRequest) GetAll

func (m *ClusterListRequest) GetAll() bool

func (*ClusterListRequest) GetExpired

func (m *ClusterListRequest) GetExpired() bool

func (*ClusterListRequest) GetPrefix

func (m *ClusterListRequest) GetPrefix() string

func (*ClusterListRequest) ProtoMessage

func (*ClusterListRequest) ProtoMessage()

func (*ClusterListRequest) Reset

func (m *ClusterListRequest) Reset()

func (*ClusterListRequest) String

func (m *ClusterListRequest) String() string

func (*ClusterListRequest) XXX_DiscardUnknown

func (m *ClusterListRequest) XXX_DiscardUnknown()

func (*ClusterListRequest) XXX_Marshal

func (m *ClusterListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterListRequest) XXX_Merge

func (m *ClusterListRequest) XXX_Merge(src proto.Message)

func (*ClusterListRequest) XXX_Size

func (m *ClusterListRequest) XXX_Size() int

func (*ClusterListRequest) XXX_Unmarshal

func (m *ClusterListRequest) XXX_Unmarshal(b []byte) error

type ClusterListResponse

type ClusterListResponse struct {
	// Clusters is a list of all clusters.
	Clusters             []*Cluster `protobuf:"bytes,1,rep,name=Clusters,proto3" json:"Clusters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

ClusterListResponse represents details about all clusters.

func (*ClusterListResponse) Descriptor

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

func (*ClusterListResponse) GetClusters

func (m *ClusterListResponse) GetClusters() []*Cluster

func (*ClusterListResponse) ProtoMessage

func (*ClusterListResponse) ProtoMessage()

func (*ClusterListResponse) Reset

func (m *ClusterListResponse) Reset()

func (*ClusterListResponse) String

func (m *ClusterListResponse) String() string

func (*ClusterListResponse) XXX_DiscardUnknown

func (m *ClusterListResponse) XXX_DiscardUnknown()

func (*ClusterListResponse) XXX_Marshal

func (m *ClusterListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterListResponse) XXX_Merge

func (m *ClusterListResponse) XXX_Merge(src proto.Message)

func (*ClusterListResponse) XXX_Size

func (m *ClusterListResponse) XXX_Size() int

func (*ClusterListResponse) XXX_Unmarshal

func (m *ClusterListResponse) XXX_Unmarshal(b []byte) error

type ClusterServiceClient

type ClusterServiceClient interface {
	// Info provides information about a specific cluster.
	Info(ctx context.Context, in *ResourceByID, opts ...grpc.CallOption) (*Cluster, error)
	// List provides information about the available clusters.
	List(ctx context.Context, in *ClusterListRequest, opts ...grpc.CallOption) (*ClusterListResponse, error)
	// Lifespan updates the lifespan for a specific cluster.
	Lifespan(ctx context.Context, in *LifespanRequest, opts ...grpc.CallOption) (*durationpb.Duration, error)
	// Create launches a new cluster.
	Create(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*ResourceByID, error)
	// Artifacts returns the artifacts for a specific cluster.
	Artifacts(ctx context.Context, in *ResourceByID, opts ...grpc.CallOption) (*ClusterArtifacts, error)
	// Delete deletes an existing cluster.
	Delete(ctx context.Context, in *ResourceByID, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Logs returns the logs for a specific cluster.
	Logs(ctx context.Context, in *ResourceByID, opts ...grpc.CallOption) (*LogsResponse, error)
}

ClusterServiceClient is the client API for ClusterService service.

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

func NewClusterServiceClient

func NewClusterServiceClient(cc *grpc.ClientConn) ClusterServiceClient

type ClusterServiceServer

type ClusterServiceServer interface {
	// Info provides information about a specific cluster.
	Info(context.Context, *ResourceByID) (*Cluster, error)
	// List provides information about the available clusters.
	List(context.Context, *ClusterListRequest) (*ClusterListResponse, error)
	// Lifespan updates the lifespan for a specific cluster.
	Lifespan(context.Context, *LifespanRequest) (*durationpb.Duration, error)
	// Create launches a new cluster.
	Create(context.Context, *CreateClusterRequest) (*ResourceByID, error)
	// Artifacts returns the artifacts for a specific cluster.
	Artifacts(context.Context, *ResourceByID) (*ClusterArtifacts, error)
	// Delete deletes an existing cluster.
	Delete(context.Context, *ResourceByID) (*emptypb.Empty, error)
	// Logs returns the logs for a specific cluster.
	Logs(context.Context, *ResourceByID) (*LogsResponse, error)
}

ClusterServiceServer is the server API for ClusterService service.

type CreateClusterRequest

type CreateClusterRequest struct {
	// ID is the flavor ID to launch.
	ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// Lifespan is the initial cluster lifespan.
	Lifespan *durationpb.Duration `protobuf:"bytes,2,opt,name=Lifespan,proto3" json:"Lifespan,omitempty"`
	// Parameters is a map of launch parameter names to values.
	Parameters map[string]string `` /* 161-byte string literal not displayed */
	// Description is a human readable description for the cluster.
	Description string `protobuf:"bytes,4,opt,name=Description,proto3" json:"Description,omitempty"`
	// NoSlack is used to skip sending Slack messages for cluster lifecycle
	// events.
	NoSlack bool `protobuf:"varint,5,opt,name=NoSlack,proto3" json:"NoSlack,omitempty"`
	// SlackDM is used to choose direct messages for cluster lifecycle
	// events.
	SlackDM              bool     `protobuf:"varint,6,opt,name=SlackDM,proto3" json:"SlackDM,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CreateClusterRequest represents details for launching a new cluster.

func (*CreateClusterRequest) Descriptor

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

func (*CreateClusterRequest) GetDescription

func (m *CreateClusterRequest) GetDescription() string

func (*CreateClusterRequest) GetID

func (m *CreateClusterRequest) GetID() string

func (*CreateClusterRequest) GetLifespan

func (m *CreateClusterRequest) GetLifespan() *durationpb.Duration

func (*CreateClusterRequest) GetNoSlack

func (m *CreateClusterRequest) GetNoSlack() bool

func (*CreateClusterRequest) GetParameters

func (m *CreateClusterRequest) GetParameters() map[string]string

func (*CreateClusterRequest) GetSlackDM

func (m *CreateClusterRequest) GetSlackDM() bool

func (*CreateClusterRequest) ProtoMessage

func (*CreateClusterRequest) ProtoMessage()

func (*CreateClusterRequest) Reset

func (m *CreateClusterRequest) Reset()

func (*CreateClusterRequest) String

func (m *CreateClusterRequest) String() string

func (*CreateClusterRequest) XXX_DiscardUnknown

func (m *CreateClusterRequest) XXX_DiscardUnknown()

func (*CreateClusterRequest) XXX_Marshal

func (m *CreateClusterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateClusterRequest) XXX_Merge

func (m *CreateClusterRequest) XXX_Merge(src proto.Message)

func (*CreateClusterRequest) XXX_Size

func (m *CreateClusterRequest) XXX_Size() int

func (*CreateClusterRequest) XXX_Unmarshal

func (m *CreateClusterRequest) XXX_Unmarshal(b []byte) error

type Flavor

type Flavor struct {
	// ID is the unique, human type-able, ID for the flavor.
	ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// Name is a human readable name for the flavor.
	Name string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
	// Description is a human readable description for the flavor.
	Description string `protobuf:"bytes,3,opt,name=Description,proto3" json:"Description,omitempty"`
	// Description is an availability classification for the flavor.
	Availability FlavorAvailability `protobuf:"varint,4,opt,name=Availability,proto3,enum=v1.FlavorAvailability" json:"Availability,omitempty"`
	// Parameters is a map of parameters required for launching this flavor.
	Parameters map[string]*Parameter `` /* 161-byte string literal not displayed */
	// Artifacts is a map of artifacts produced by this flavor.
	Artifacts map[string]*FlavorArtifact `` /* 159-byte string literal not displayed */
	// Aliases are alternative IDs of the flavor.
	Aliases              []string `protobuf:"bytes,7,rep,name=Aliases,proto3" json:"Aliases,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Flavor represents a configured cluster flavor.

func (*Flavor) Descriptor

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

func (*Flavor) GetAliases

func (m *Flavor) GetAliases() []string

func (*Flavor) GetArtifacts

func (m *Flavor) GetArtifacts() map[string]*FlavorArtifact

func (*Flavor) GetAvailability

func (m *Flavor) GetAvailability() FlavorAvailability

func (*Flavor) GetDescription

func (m *Flavor) GetDescription() string

func (*Flavor) GetID

func (m *Flavor) GetID() string

func (*Flavor) GetName

func (m *Flavor) GetName() string

func (*Flavor) GetParameters

func (m *Flavor) GetParameters() map[string]*Parameter

func (*Flavor) ProtoMessage

func (*Flavor) ProtoMessage()

func (*Flavor) Reset

func (m *Flavor) Reset()

func (*Flavor) String

func (m *Flavor) String() string

func (*Flavor) XXX_DiscardUnknown

func (m *Flavor) XXX_DiscardUnknown()

func (*Flavor) XXX_Marshal

func (m *Flavor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Flavor) XXX_Merge

func (m *Flavor) XXX_Merge(src proto.Message)

func (*Flavor) XXX_Size

func (m *Flavor) XXX_Size() int

func (*Flavor) XXX_Unmarshal

func (m *Flavor) XXX_Unmarshal(b []byte) error

type FlavorArtifact

type FlavorArtifact struct {
	// Name is the unique name of the artifact.
	Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	// Description is a human readable description for the artifact.
	Description string `protobuf:"bytes,2,opt,name=Description,proto3" json:"Description,omitempty"`
	// Tags is a set of artifact tags.
	Tags                 map[string]*emptypb.Empty `` /* 149-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

FlavorArtifact represents a single artifact that is produced by a flavor.

func (*FlavorArtifact) Descriptor

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

func (*FlavorArtifact) GetDescription

func (m *FlavorArtifact) GetDescription() string

func (*FlavorArtifact) GetName

func (m *FlavorArtifact) GetName() string

func (*FlavorArtifact) GetTags

func (m *FlavorArtifact) GetTags() map[string]*emptypb.Empty

func (*FlavorArtifact) ProtoMessage

func (*FlavorArtifact) ProtoMessage()

func (*FlavorArtifact) Reset

func (m *FlavorArtifact) Reset()

func (*FlavorArtifact) String

func (m *FlavorArtifact) String() string

func (*FlavorArtifact) XXX_DiscardUnknown

func (m *FlavorArtifact) XXX_DiscardUnknown()

func (*FlavorArtifact) XXX_Marshal

func (m *FlavorArtifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlavorArtifact) XXX_Merge

func (m *FlavorArtifact) XXX_Merge(src proto.Message)

func (*FlavorArtifact) XXX_Size

func (m *FlavorArtifact) XXX_Size() int

func (*FlavorArtifact) XXX_Unmarshal

func (m *FlavorArtifact) XXX_Unmarshal(b []byte) error

type FlavorAvailability

type FlavorAvailability int32

availability represents the availability classification levels.

const (
	// alpha is completely experemental, and is not expected to work in any way.
	Flavor_alpha FlavorAvailability = 0
	// beta is being tested, and is expected to work with minor issues.
	Flavor_beta FlavorAvailability = 1
	// stable is available for public consumption, and works without issue.
	Flavor_stable FlavorAvailability = 2
	// default is stable, and available for customer demo consumption.
	// Exactly 1 flavor should be configured as default.
	Flavor_default FlavorAvailability = 3
)

func (FlavorAvailability) EnumDescriptor

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

func (FlavorAvailability) String

func (x FlavorAvailability) String() string

type FlavorListRequest

type FlavorListRequest struct {
	// all indicates that all flavors should be returned, by default
	// availability alpha clusters are excluded.
	All                  bool     `protobuf:"varint,1,opt,name=all,proto3" json:"all,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

FlavorListRequest represents a request to FlavorService.List.

func (*FlavorListRequest) Descriptor

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

func (*FlavorListRequest) GetAll

func (m *FlavorListRequest) GetAll() bool

func (*FlavorListRequest) ProtoMessage

func (*FlavorListRequest) ProtoMessage()

func (*FlavorListRequest) Reset

func (m *FlavorListRequest) Reset()

func (*FlavorListRequest) String

func (m *FlavorListRequest) String() string

func (*FlavorListRequest) XXX_DiscardUnknown

func (m *FlavorListRequest) XXX_DiscardUnknown()

func (*FlavorListRequest) XXX_Marshal

func (m *FlavorListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlavorListRequest) XXX_Merge

func (m *FlavorListRequest) XXX_Merge(src proto.Message)

func (*FlavorListRequest) XXX_Size

func (m *FlavorListRequest) XXX_Size() int

func (*FlavorListRequest) XXX_Unmarshal

func (m *FlavorListRequest) XXX_Unmarshal(b []byte) error

type FlavorListResponse

type FlavorListResponse struct {
	// Default is the flavor ID of the default cluster flavor.
	Default string `protobuf:"bytes,1,opt,name=Default,proto3" json:"Default,omitempty"`
	// Flavors is a list of all available cluster flavors.
	Flavors              []*Flavor `protobuf:"bytes,2,rep,name=Flavors,proto3" json:"Flavors,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

FlavorListResponse represents details about the available cluster flavors.

func (*FlavorListResponse) Descriptor

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

func (*FlavorListResponse) GetDefault

func (m *FlavorListResponse) GetDefault() string

func (*FlavorListResponse) GetFlavors

func (m *FlavorListResponse) GetFlavors() []*Flavor

func (*FlavorListResponse) ProtoMessage

func (*FlavorListResponse) ProtoMessage()

func (*FlavorListResponse) Reset

func (m *FlavorListResponse) Reset()

func (*FlavorListResponse) String

func (m *FlavorListResponse) String() string

func (*FlavorListResponse) XXX_DiscardUnknown

func (m *FlavorListResponse) XXX_DiscardUnknown()

func (*FlavorListResponse) XXX_Marshal

func (m *FlavorListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlavorListResponse) XXX_Merge

func (m *FlavorListResponse) XXX_Merge(src proto.Message)

func (*FlavorListResponse) XXX_Size

func (m *FlavorListResponse) XXX_Size() int

func (*FlavorListResponse) XXX_Unmarshal

func (m *FlavorListResponse) XXX_Unmarshal(b []byte) error

type FlavorServiceClient

type FlavorServiceClient interface {
	// List provides information about the available flavors.
	List(ctx context.Context, in *FlavorListRequest, opts ...grpc.CallOption) (*FlavorListResponse, error)
	// Info provides information about a specific flavor.
	Info(ctx context.Context, in *ResourceByID, opts ...grpc.CallOption) (*Flavor, error)
}

FlavorServiceClient is the client API for FlavorService service.

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

func NewFlavorServiceClient

func NewFlavorServiceClient(cc *grpc.ClientConn) FlavorServiceClient

type FlavorServiceServer

type FlavorServiceServer interface {
	// List provides information about the available flavors.
	List(context.Context, *FlavorListRequest) (*FlavorListResponse, error)
	// Info provides information about a specific flavor.
	Info(context.Context, *ResourceByID) (*Flavor, error)
}

FlavorServiceServer is the server API for FlavorService service.

type InfraStatus

type InfraStatus struct {
	// MaintenanceActive is an indicator whether a maintenance is ongoing.
	MaintenanceActive bool `protobuf:"varint,1,opt,name=MaintenanceActive,proto3" json:"MaintenanceActive,omitempty"`
	// Maintainer is the email of the person currently doing maintenance.
	Maintainer           string   `protobuf:"bytes,2,opt,name=Maintainer,proto3" json:"Maintainer,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InfraStatus) Descriptor

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

func (*InfraStatus) GetMaintainer

func (m *InfraStatus) GetMaintainer() string

func (*InfraStatus) GetMaintenanceActive

func (m *InfraStatus) GetMaintenanceActive() bool

func (*InfraStatus) ProtoMessage

func (*InfraStatus) ProtoMessage()

func (*InfraStatus) Reset

func (m *InfraStatus) Reset()

func (*InfraStatus) String

func (m *InfraStatus) String() string

func (*InfraStatus) XXX_DiscardUnknown

func (m *InfraStatus) XXX_DiscardUnknown()

func (*InfraStatus) XXX_Marshal

func (m *InfraStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InfraStatus) XXX_Merge

func (m *InfraStatus) XXX_Merge(src proto.Message)

func (*InfraStatus) XXX_Size

func (m *InfraStatus) XXX_Size() int

func (*InfraStatus) XXX_Unmarshal

func (m *InfraStatus) XXX_Unmarshal(b []byte) error

type InfraStatusServiceClient

type InfraStatusServiceClient interface {
	// GetStatus gets the maintenance
	GetStatus(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*InfraStatus, error)
	// ResetStatus resets the maintenance
	ResetStatus(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*InfraStatus, error)
	// SetStatus sets the maintenance
	SetStatus(ctx context.Context, in *InfraStatus, opts ...grpc.CallOption) (*InfraStatus, error)
}

InfraStatusServiceClient is the client API for InfraStatusService service.

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

func NewInfraStatusServiceClient

func NewInfraStatusServiceClient(cc *grpc.ClientConn) InfraStatusServiceClient

type InfraStatusServiceServer

type InfraStatusServiceServer interface {
	// GetStatus gets the maintenance
	GetStatus(context.Context, *emptypb.Empty) (*InfraStatus, error)
	// ResetStatus resets the maintenance
	ResetStatus(context.Context, *emptypb.Empty) (*InfraStatus, error)
	// SetStatus sets the maintenance
	SetStatus(context.Context, *InfraStatus) (*InfraStatus, error)
}

InfraStatusServiceServer is the server API for InfraStatusService service.

type LifespanRequest

type LifespanRequest struct {
	// ID is the unique ID for the cluster.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Lifespan is the new lifespan.
	Lifespan             *durationpb.Duration   `protobuf:"bytes,2,opt,name=Lifespan,proto3" json:"Lifespan,omitempty"`
	Method               LifespanRequest_Method `protobuf:"varint,3,opt,name=method,proto3,enum=v1.LifespanRequest_Method" json:"method,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*LifespanRequest) Descriptor

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

func (*LifespanRequest) GetId

func (m *LifespanRequest) GetId() string

func (*LifespanRequest) GetLifespan

func (m *LifespanRequest) GetLifespan() *durationpb.Duration

func (*LifespanRequest) GetMethod

func (m *LifespanRequest) GetMethod() LifespanRequest_Method

func (*LifespanRequest) ProtoMessage

func (*LifespanRequest) ProtoMessage()

func (*LifespanRequest) Reset

func (m *LifespanRequest) Reset()

func (*LifespanRequest) String

func (m *LifespanRequest) String() string

func (*LifespanRequest) XXX_DiscardUnknown

func (m *LifespanRequest) XXX_DiscardUnknown()

func (*LifespanRequest) XXX_Marshal

func (m *LifespanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LifespanRequest) XXX_Merge

func (m *LifespanRequest) XXX_Merge(src proto.Message)

func (*LifespanRequest) XXX_Size

func (m *LifespanRequest) XXX_Size() int

func (*LifespanRequest) XXX_Unmarshal

func (m *LifespanRequest) XXX_Unmarshal(b []byte) error

type LifespanRequest_Method

type LifespanRequest_Method int32

method represents the various lifespan operations.

const (
	// REPLACE indicates that the given lifespan should replace the current
	// lifespan.
	LifespanRequest_REPLACE LifespanRequest_Method = 0
	// ADD indicates that the given lifespan should be added to the current
	// lifespan.
	LifespanRequest_ADD LifespanRequest_Method = 1
	// SUBTRACT indicates that the given lifespan should be subtracted from
	// the current lifespan.
	LifespanRequest_SUBTRACT LifespanRequest_Method = 2
)

func (LifespanRequest_Method) EnumDescriptor

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

func (LifespanRequest_Method) String

func (x LifespanRequest_Method) String() string

type Log

type Log struct {
	// Name is the name given to this pod in the workflow.
	Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	// Started is the time at which this pod was started. Used for ordering
	// between pods.
	Started *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=Started,proto3" json:"Started,omitempty"`
	// Body is the raw pod logs.
	Body []byte `protobuf:"bytes,3,opt,name=Body,proto3" json:"Body,omitempty"`
	// Message surfaces step state from Argo.
	Message              string   `protobuf:"bytes,4,opt,name=Message,proto3" json:"Message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Log represents the logs from a specific pod.

func (*Log) Descriptor

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

func (*Log) GetBody

func (m *Log) GetBody() []byte

func (*Log) GetMessage

func (m *Log) GetMessage() string

func (*Log) GetName

func (m *Log) GetName() string

func (*Log) GetStarted

func (m *Log) GetStarted() *timestamppb.Timestamp

func (*Log) ProtoMessage

func (*Log) ProtoMessage()

func (*Log) Reset

func (m *Log) Reset()

func (*Log) String

func (m *Log) String() string

func (*Log) XXX_DiscardUnknown

func (m *Log) XXX_DiscardUnknown()

func (*Log) XXX_Marshal

func (m *Log) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Log) XXX_Merge

func (m *Log) XXX_Merge(src proto.Message)

func (*Log) XXX_Size

func (m *Log) XXX_Size() int

func (*Log) XXX_Unmarshal

func (m *Log) XXX_Unmarshal(b []byte) error

type LogsResponse

type LogsResponse struct {
	// Logs are all of the logs from a cluster.
	Logs                 []*Log   `protobuf:"bytes,1,rep,name=Logs,proto3" json:"Logs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

LogsResponse represents a collection of logs.

func (*LogsResponse) Descriptor

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

func (*LogsResponse) GetLogs

func (m *LogsResponse) GetLogs() []*Log

func (*LogsResponse) ProtoMessage

func (*LogsResponse) ProtoMessage()

func (*LogsResponse) Reset

func (m *LogsResponse) Reset()

func (*LogsResponse) String

func (m *LogsResponse) String() string

func (*LogsResponse) XXX_DiscardUnknown

func (m *LogsResponse) XXX_DiscardUnknown()

func (*LogsResponse) XXX_Marshal

func (m *LogsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogsResponse) XXX_Merge

func (m *LogsResponse) XXX_Merge(src proto.Message)

func (*LogsResponse) XXX_Size

func (m *LogsResponse) XXX_Size() int

func (*LogsResponse) XXX_Unmarshal

func (m *LogsResponse) XXX_Unmarshal(b []byte) error

type Parameter

type Parameter struct {
	// Name is the unique name of the parameter.
	Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	// Description is a human readable description for the parameter.
	Description string `protobuf:"bytes,2,opt,name=Description,proto3" json:"Description,omitempty"`
	// Value that this parameter could have.
	// If the parameter is not optional, then value serves as an example.
	// If the parameter is optional, then value serves as a default.
	// If the parameter is internal, then value serves as a hardcoded constant.
	Value string `protobuf:"bytes,3,opt,name=Value,proto3" json:"Value,omitempty"`
	// Optional indicates that this parameter can be optionally provided by a
	// user. If the user does not provide a value, then Value serves as a
	// default.
	Optional bool `protobuf:"varint,4,opt,name=Optional,proto3" json:"Optional,omitempty"`
	// Internal indicates that this parameter should not be provided by a user,
	// but rather treats Value as a hardcoded constant.
	Internal bool `protobuf:"varint,5,opt,name=Internal,proto3" json:"Internal,omitempty"`
	// The relative order of importance of this parameter for when presenting in
	// a UI for example.
	Order int32  `protobuf:"varint,6,opt,name=Order,proto3" json:"Order,omitempty"`
	Help  string `protobuf:"bytes,7,opt,name=Help,proto3" json:"Help,omitempty"`
	// Indicates that the value for this parameter can be provided from the
	// contents of a file.
	FromFile             bool     `protobuf:"varint,8,opt,name=FromFile,proto3" json:"FromFile,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Parameter represents a single parameter that is needed to launch a flavor.

func (*Parameter) Descriptor

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

func (*Parameter) GetDescription

func (m *Parameter) GetDescription() string

func (*Parameter) GetFromFile

func (m *Parameter) GetFromFile() bool

func (*Parameter) GetHelp

func (m *Parameter) GetHelp() string

func (*Parameter) GetInternal

func (m *Parameter) GetInternal() bool

func (*Parameter) GetName

func (m *Parameter) GetName() string

func (*Parameter) GetOptional

func (m *Parameter) GetOptional() bool

func (*Parameter) GetOrder

func (m *Parameter) GetOrder() int32

func (*Parameter) GetValue

func (m *Parameter) GetValue() string

func (*Parameter) ProtoMessage

func (*Parameter) ProtoMessage()

func (*Parameter) Reset

func (m *Parameter) Reset()

func (*Parameter) String

func (m *Parameter) String() string

func (*Parameter) XXX_DiscardUnknown

func (m *Parameter) XXX_DiscardUnknown()

func (*Parameter) XXX_Marshal

func (m *Parameter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Parameter) XXX_Merge

func (m *Parameter) XXX_Merge(src proto.Message)

func (*Parameter) XXX_Size

func (m *Parameter) XXX_Size() int

func (*Parameter) XXX_Unmarshal

func (m *Parameter) XXX_Unmarshal(b []byte) error

type ResourceByID

type ResourceByID struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ResourceByID represents a generic reference to a named/unique resource.

func (*ResourceByID) Descriptor

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

func (*ResourceByID) GetId

func (m *ResourceByID) GetId() string

func (*ResourceByID) ProtoMessage

func (*ResourceByID) ProtoMessage()

func (*ResourceByID) Reset

func (m *ResourceByID) Reset()

func (*ResourceByID) String

func (m *ResourceByID) String() string

func (*ResourceByID) XXX_DiscardUnknown

func (m *ResourceByID) XXX_DiscardUnknown()

func (*ResourceByID) XXX_Marshal

func (m *ResourceByID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResourceByID) XXX_Merge

func (m *ResourceByID) XXX_Merge(src proto.Message)

func (*ResourceByID) XXX_Size

func (m *ResourceByID) XXX_Size() int

func (*ResourceByID) XXX_Unmarshal

func (m *ResourceByID) XXX_Unmarshal(b []byte) error

type ServiceAccount

type ServiceAccount struct {
	// Name is a human readable name for the service account.
	Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	// Description is a human readable description for the service account.
	Description string `protobuf:"bytes,2,opt,name=Description,proto3" json:"Description,omitempty"`
	// Email is the Red Hat email address for the service account.
	Email string `protobuf:"bytes,3,opt,name=Email,proto3" json:"Email,omitempty"`
	// IssuedAt is the time of issuing the service account token.
	IssuedAt int64 `protobuf:"varint,4,opt,name=IssuedAt,proto3" json:"IssuedAt,omitempty"`
	// NotBefore is the beginning of service account token valid time period.
	NotBefore int64 `protobuf:"varint,5,opt,name=NotBefore,proto3" json:"NotBefore,omitempty"`
	// ExpiresAt is the end of service account token valid time period.
	ExpiresAt            int64    `protobuf:"varint,6,opt,name=ExpiresAt,proto3" json:"ExpiresAt,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ServiceAccount represents an authenticated service account (robot) principal.

func (*ServiceAccount) Descriptor

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

func (*ServiceAccount) GetDescription

func (m *ServiceAccount) GetDescription() string

func (*ServiceAccount) GetEmail

func (m *ServiceAccount) GetEmail() string

func (*ServiceAccount) GetExpiresAt

func (m *ServiceAccount) GetExpiresAt() int64

func (*ServiceAccount) GetIssuedAt

func (m *ServiceAccount) GetIssuedAt() int64

func (*ServiceAccount) GetName

func (m *ServiceAccount) GetName() string

func (*ServiceAccount) GetNotBefore

func (m *ServiceAccount) GetNotBefore() int64

func (*ServiceAccount) ProtoMessage

func (*ServiceAccount) ProtoMessage()

func (*ServiceAccount) Reset

func (m *ServiceAccount) Reset()

func (*ServiceAccount) String

func (m *ServiceAccount) String() string

func (*ServiceAccount) XXX_DiscardUnknown

func (m *ServiceAccount) XXX_DiscardUnknown()

func (*ServiceAccount) XXX_Marshal

func (m *ServiceAccount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceAccount) XXX_Merge

func (m *ServiceAccount) XXX_Merge(src proto.Message)

func (*ServiceAccount) XXX_Size

func (m *ServiceAccount) XXX_Size() int

func (*ServiceAccount) XXX_Unmarshal

func (m *ServiceAccount) XXX_Unmarshal(b []byte) error

type Status

type Status int32

Status represents the various cluster states.

const (
	// FAILED is the state when the cluster has failed in one way or another.
	Status_FAILED Status = 0
	// CREATING is the state when the cluster is being created.
	Status_CREATING Status = 1
	// READY is the state when the cluster is available and ready for use.
	Status_READY Status = 2
	// DESTROYING is the state when the cluster is being destroyed.
	Status_DESTROYING Status = 3
	// FINISHED is the state when the cluster has been successfully destroyed.
	Status_FINISHED Status = 4
)

func (Status) EnumDescriptor

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

func (Status) String

func (x Status) String() string

type TokenResponse

type TokenResponse struct {
	// Account is the service account the token was generated for.
	Account *ServiceAccount `protobuf:"bytes,1,opt,name=Account,proto3" json:"Account,omitempty"`
	// Token is the token generated for the service account.
	Token                string   `protobuf:"bytes,2,opt,name=Token,proto3" json:"Token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TokenResponse) Descriptor

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

func (*TokenResponse) GetAccount

func (m *TokenResponse) GetAccount() *ServiceAccount

func (*TokenResponse) GetToken

func (m *TokenResponse) GetToken() string

func (*TokenResponse) ProtoMessage

func (*TokenResponse) ProtoMessage()

func (*TokenResponse) Reset

func (m *TokenResponse) Reset()

func (*TokenResponse) String

func (m *TokenResponse) String() string

func (*TokenResponse) XXX_DiscardUnknown

func (m *TokenResponse) XXX_DiscardUnknown()

func (*TokenResponse) XXX_Marshal

func (m *TokenResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TokenResponse) XXX_Merge

func (m *TokenResponse) XXX_Merge(src proto.Message)

func (*TokenResponse) XXX_Size

func (m *TokenResponse) XXX_Size() int

func (*TokenResponse) XXX_Unmarshal

func (m *TokenResponse) XXX_Unmarshal(b []byte) error

type UnimplementedCliServiceServer

type UnimplementedCliServiceServer struct {
}

UnimplementedCliServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedCliServiceServer) Upgrade

type UnimplementedClusterServiceServer

type UnimplementedClusterServiceServer struct {
}

UnimplementedClusterServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedClusterServiceServer) Artifacts

func (*UnimplementedClusterServiceServer) Create

func (*UnimplementedClusterServiceServer) Delete

func (*UnimplementedClusterServiceServer) Info

func (*UnimplementedClusterServiceServer) Lifespan

func (*UnimplementedClusterServiceServer) List

func (*UnimplementedClusterServiceServer) Logs

type UnimplementedFlavorServiceServer

type UnimplementedFlavorServiceServer struct {
}

UnimplementedFlavorServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedFlavorServiceServer) Info

func (*UnimplementedFlavorServiceServer) List

type UnimplementedInfraStatusServiceServer

type UnimplementedInfraStatusServiceServer struct {
}

UnimplementedInfraStatusServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedInfraStatusServiceServer) GetStatus

func (*UnimplementedInfraStatusServiceServer) ResetStatus

func (*UnimplementedInfraStatusServiceServer) SetStatus

type UnimplementedUserServiceServer

type UnimplementedUserServiceServer struct {
}

UnimplementedUserServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedUserServiceServer) CreateToken

func (*UnimplementedUserServiceServer) Token

func (*UnimplementedUserServiceServer) Whoami

type UnimplementedVersionServiceServer

type UnimplementedVersionServiceServer struct {
}

UnimplementedVersionServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedVersionServiceServer) GetVersion

type User

type User struct {
	// Expiry is the expiration date of this user session. Used only as a hint
	// to the user and not for enforcement.
	Expiry *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=Expiry,proto3" json:"Expiry,omitempty"`
	// Name is the full name of the user.
	Name string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
	// Email is the email address of the user.
	Email string `protobuf:"bytes,3,opt,name=Email,proto3" json:"Email,omitempty"`
	// Picture is a URL linking to this user's profile picture, if available.
	Picture              string   `protobuf:"bytes,4,opt,name=Picture,proto3" json:"Picture,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

User represents an authenticated (human) principal.

func (*User) Descriptor

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

func (*User) GetEmail

func (m *User) GetEmail() string

func (*User) GetExpiry

func (m *User) GetExpiry() *timestamppb.Timestamp

func (*User) GetName

func (m *User) GetName() string

func (*User) GetPicture

func (m *User) GetPicture() string

func (*User) ProtoMessage

func (*User) ProtoMessage()

func (*User) Reset

func (m *User) Reset()

func (*User) String

func (m *User) String() string

func (*User) XXX_DiscardUnknown

func (m *User) XXX_DiscardUnknown()

func (*User) XXX_Marshal

func (m *User) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*User) XXX_Merge

func (m *User) XXX_Merge(src proto.Message)

func (*User) XXX_Size

func (m *User) XXX_Size() int

func (*User) XXX_Unmarshal

func (m *User) XXX_Unmarshal(b []byte) error

type UserServiceClient

type UserServiceClient interface {
	// Whoami provides information about the currently authenticated principal.
	Whoami(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*WhoamiResponse, error)
	// CreateToken generates an arbitrary service account token
	CreateToken(ctx context.Context, in *ServiceAccount, opts ...grpc.CallOption) (*TokenResponse, error)
	// Token generates a service account token for the current user.
	Token(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*TokenResponse, error)
}

UserServiceClient is the client API for UserService service.

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

func NewUserServiceClient

func NewUserServiceClient(cc *grpc.ClientConn) UserServiceClient

type UserServiceServer

type UserServiceServer interface {
	// Whoami provides information about the currently authenticated principal.
	Whoami(context.Context, *emptypb.Empty) (*WhoamiResponse, error)
	// CreateToken generates an arbitrary service account token
	CreateToken(context.Context, *ServiceAccount) (*TokenResponse, error)
	// Token generates a service account token for the current user.
	Token(context.Context, *emptypb.Empty) (*TokenResponse, error)
}

UserServiceServer is the server API for UserService service.

type Version

type Version struct {
	BuildDate            *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=BuildDate,proto3" json:"BuildDate,omitempty"`
	GitCommit            string                 `protobuf:"bytes,2,opt,name=GitCommit,proto3" json:"GitCommit,omitempty"`
	GoVersion            string                 `protobuf:"bytes,3,opt,name=GoVersion,proto3" json:"GoVersion,omitempty"`
	Platform             string                 `protobuf:"bytes,4,opt,name=Platform,proto3" json:"Platform,omitempty"`
	Version              string                 `protobuf:"bytes,5,opt,name=Version,proto3" json:"Version,omitempty"`
	Workflow             string                 `protobuf:"bytes,6,opt,name=Workflow,proto3" json:"Workflow,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*Version) Descriptor

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

func (*Version) GetBuildDate

func (m *Version) GetBuildDate() *timestamppb.Timestamp

func (*Version) GetGitCommit

func (m *Version) GetGitCommit() string

func (*Version) GetGoVersion

func (m *Version) GetGoVersion() string

func (*Version) GetPlatform

func (m *Version) GetPlatform() string

func (*Version) GetVersion

func (m *Version) GetVersion() string

func (*Version) GetWorkflow

func (m *Version) GetWorkflow() string

func (*Version) ProtoMessage

func (*Version) ProtoMessage()

func (*Version) Reset

func (m *Version) Reset()

func (*Version) String

func (m *Version) String() string

func (*Version) XXX_DiscardUnknown

func (m *Version) XXX_DiscardUnknown()

func (*Version) XXX_Marshal

func (m *Version) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Version) XXX_Merge

func (m *Version) XXX_Merge(src proto.Message)

func (*Version) XXX_Size

func (m *Version) XXX_Size() int

func (*Version) XXX_Unmarshal

func (m *Version) XXX_Unmarshal(b []byte) error

type VersionServiceClient

type VersionServiceClient interface {
	GetVersion(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Version, error)
}

VersionServiceClient is the client API for VersionService service.

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

func NewVersionServiceClient

func NewVersionServiceClient(cc *grpc.ClientConn) VersionServiceClient

type VersionServiceServer

type VersionServiceServer interface {
	GetVersion(context.Context, *emptypb.Empty) (*Version, error)
}

VersionServiceServer is the server API for VersionService service.

type WhoamiResponse

type WhoamiResponse struct {
	// Principal represents a possible type of authenticated principal.
	//
	// Types that are valid to be assigned to Principal:
	//
	//	*WhoamiResponse_User
	//	*WhoamiResponse_ServiceAccount
	Principal            isWhoamiResponse_Principal `protobuf_oneof:"principal"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

WhoamiResponse represents details about the current authenticated principal.

func (*WhoamiResponse) Descriptor

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

func (*WhoamiResponse) GetPrincipal

func (m *WhoamiResponse) GetPrincipal() isWhoamiResponse_Principal

func (*WhoamiResponse) GetServiceAccount

func (m *WhoamiResponse) GetServiceAccount() *ServiceAccount

func (*WhoamiResponse) GetUser

func (m *WhoamiResponse) GetUser() *User

func (*WhoamiResponse) ProtoMessage

func (*WhoamiResponse) ProtoMessage()

func (*WhoamiResponse) Reset

func (m *WhoamiResponse) Reset()

func (*WhoamiResponse) String

func (m *WhoamiResponse) String() string

func (*WhoamiResponse) XXX_DiscardUnknown

func (m *WhoamiResponse) XXX_DiscardUnknown()

func (*WhoamiResponse) XXX_Marshal

func (m *WhoamiResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WhoamiResponse) XXX_Merge

func (m *WhoamiResponse) XXX_Merge(src proto.Message)

func (*WhoamiResponse) XXX_OneofWrappers

func (*WhoamiResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*WhoamiResponse) XXX_Size

func (m *WhoamiResponse) XXX_Size() int

func (*WhoamiResponse) XXX_Unmarshal

func (m *WhoamiResponse) XXX_Unmarshal(b []byte) error

type WhoamiResponse_ServiceAccount

type WhoamiResponse_ServiceAccount struct {
	ServiceAccount *ServiceAccount `protobuf:"bytes,2,opt,name=ServiceAccount,proto3,oneof"`
}

type WhoamiResponse_User

type WhoamiResponse_User struct {
	User *User `protobuf:"bytes,1,opt,name=User,proto3,oneof"`
}

Jump to

Keyboard shortcuts

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