infra

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Oct 15, 2024 License: AGPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Infra_GetCluster_FullMethodName           = "/Infra/GetCluster"
	Infra_GetNodepool_FullMethodName          = "/Infra/GetNodepool"
	Infra_ClusterExists_FullMethodName        = "/Infra/ClusterExists"
	Infra_GetClusterKubeconfig_FullMethodName = "/Infra/GetClusterKubeconfig"
	Infra_MarkClusterOnlineAt_FullMethodName  = "/Infra/MarkClusterOnlineAt"
)

Variables

View Source 
var File_infra_proto protoreflect.FileDescriptor
View Source 
var Infra_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Infra",
	HandlerType: (*InfraServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetCluster",
			Handler:    _Infra_GetCluster_Handler,
		},
		{
			MethodName: "GetNodepool",
			Handler:    _Infra_GetNodepool_Handler,
		},
		{
			MethodName: "ClusterExists",
			Handler:    _Infra_ClusterExists_Handler,
		},
		{
			MethodName: "GetClusterKubeconfig",
			Handler:    _Infra_GetClusterKubeconfig_Handler,
		},
		{
			MethodName: "MarkClusterOnlineAt",
			Handler:    _Infra_MarkClusterOnlineAt_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "infra.proto",
}

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

Functions

func RegisterInfraServer 

func RegisterInfraServer(s grpc.ServiceRegistrar, srv InfraServer)

Types

type ClusterExistsIn 

type ClusterExistsIn struct {
	UserId      string `protobuf:"bytes,1,opt,name=userId,proto3" json:"userId,omitempty"`
	UserName    string `protobuf:"bytes,2,opt,name=userName,proto3" json:"userName,omitempty"`
	UserEmail   string `protobuf:"bytes,3,opt,name=userEmail,proto3" json:"userEmail,omitempty"`
	AccountName string `protobuf:"bytes,4,opt,name=accountName,proto3" json:"accountName,omitempty"`
	ClusterName string `protobuf:"bytes,5,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterExistsIn) Descriptor deprecated 

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

Deprecated: Use ClusterExistsIn.ProtoReflect.Descriptor instead.

func (*ClusterExistsIn) GetAccountName 

func (x *ClusterExistsIn) GetAccountName() string

func (*ClusterExistsIn) GetClusterName 

func (x *ClusterExistsIn) GetClusterName() string

func (*ClusterExistsIn) GetUserEmail 

func (x *ClusterExistsIn) GetUserEmail() string

func (*ClusterExistsIn) GetUserId 

func (x *ClusterExistsIn) GetUserId() string

func (*ClusterExistsIn) GetUserName 

func (x *ClusterExistsIn) GetUserName() string

func (*ClusterExistsIn) ProtoMessage 

func (*ClusterExistsIn) ProtoMessage()

func (*ClusterExistsIn) ProtoReflect 

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

func (*ClusterExistsIn) Reset 

func (x *ClusterExistsIn) Reset()

func (*ClusterExistsIn) String 

func (x *ClusterExistsIn) String() string

type ClusterExistsOut 

type ClusterExistsOut struct {
	Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterExistsOut) Descriptor deprecated 

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

Deprecated: Use ClusterExistsOut.ProtoReflect.Descriptor instead.

func (*ClusterExistsOut) GetExists 

func (x *ClusterExistsOut) GetExists() bool

func (*ClusterExistsOut) ProtoMessage 

func (*ClusterExistsOut) ProtoMessage()

func (*ClusterExistsOut) ProtoReflect 

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

func (*ClusterExistsOut) Reset 

func (x *ClusterExistsOut) Reset()

func (*ClusterExistsOut) String 

func (x *ClusterExistsOut) String() string

type GetClusterIn 

type GetClusterIn struct {
	UserId      string `protobuf:"bytes,1,opt,name=userId,proto3" json:"userId,omitempty"`
	UserName    string `protobuf:"bytes,2,opt,name=userName,proto3" json:"userName,omitempty"`
	UserEmail   string `protobuf:"bytes,3,opt,name=userEmail,proto3" json:"userEmail,omitempty"`
	AccountName string `protobuf:"bytes,4,opt,name=accountName,proto3" json:"accountName,omitempty"`
	ClusterName string `protobuf:"bytes,5,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	// contains filtered or unexported fields
}

func (*GetClusterIn) Descriptor deprecated 

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

Deprecated: Use GetClusterIn.ProtoReflect.Descriptor instead.

func (*GetClusterIn) GetAccountName 

func (x *GetClusterIn) GetAccountName() string

func (*GetClusterIn) GetClusterName 

func (x *GetClusterIn) GetClusterName() string

func (*GetClusterIn) GetUserEmail 

func (x *GetClusterIn) GetUserEmail() string

func (*GetClusterIn) GetUserId 

func (x *GetClusterIn) GetUserId() string

func (*GetClusterIn) GetUserName 

func (x *GetClusterIn) GetUserName() string

func (*GetClusterIn) ProtoMessage 

func (*GetClusterIn) ProtoMessage()

func (*GetClusterIn) ProtoReflect 

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

func (*GetClusterIn) Reset 

func (x *GetClusterIn) Reset()

func (*GetClusterIn) String 

func (x *GetClusterIn) String() string

type GetClusterKubeconfigOut 

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

func (*GetClusterKubeconfigOut) Descriptor deprecated 

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

Deprecated: Use GetClusterKubeconfigOut.ProtoReflect.Descriptor instead.

func (*GetClusterKubeconfigOut) GetKubeconfig 

func (x *GetClusterKubeconfigOut) GetKubeconfig() []byte

func (*GetClusterKubeconfigOut) ProtoMessage 

func (*GetClusterKubeconfigOut) ProtoMessage()

func (*GetClusterKubeconfigOut) ProtoReflect 

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

func (*GetClusterKubeconfigOut) Reset 

func (x *GetClusterKubeconfigOut) Reset()

func (*GetClusterKubeconfigOut) String 

func (x *GetClusterKubeconfigOut) String() string

type GetClusterOut 

type GetClusterOut struct {
	MessageQueueTopic string `protobuf:"bytes,1,opt,name=messageQueueTopic,proto3" json:"messageQueueTopic,omitempty"`
	DnsHost           string `protobuf:"bytes,2,opt,name=dnsHost,proto3" json:"dnsHost,omitempty"`
	IACJobName        string `protobuf:"bytes,3,opt,name=IACJobName,proto3" json:"IACJobName,omitempty"`
	IACJobNamespace   string `protobuf:"bytes,4,opt,name=IACJobNamespace,proto3" json:"IACJobNamespace,omitempty"`
	// contains filtered or unexported fields
}

func (*GetClusterOut) Descriptor deprecated 

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

Deprecated: Use GetClusterOut.ProtoReflect.Descriptor instead.

func (*GetClusterOut) GetDnsHost 

func (x *GetClusterOut) GetDnsHost() string

func (*GetClusterOut) GetIACJobName 

func (x *GetClusterOut) GetIACJobName() string

func (*GetClusterOut) GetIACJobNamespace 

func (x *GetClusterOut) GetIACJobNamespace() string

func (*GetClusterOut) GetMessageQueueTopic 

func (x *GetClusterOut) GetMessageQueueTopic() string

func (*GetClusterOut) ProtoMessage 

func (*GetClusterOut) ProtoMessage()

func (*GetClusterOut) ProtoReflect 

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

func (*GetClusterOut) Reset 

func (x *GetClusterOut) Reset()

func (*GetClusterOut) String 

func (x *GetClusterOut) String() string

type GetNodepoolIn 

type GetNodepoolIn struct {
	UserId       string `protobuf:"bytes,1,opt,name=userId,proto3" json:"userId,omitempty"`
	UserName     string `protobuf:"bytes,2,opt,name=userName,proto3" json:"userName,omitempty"`
	UserEmail    string `protobuf:"bytes,3,opt,name=userEmail,proto3" json:"userEmail,omitempty"`
	AccountName  string `protobuf:"bytes,4,opt,name=accountName,proto3" json:"accountName,omitempty"`
	ClusterName  string `protobuf:"bytes,5,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	NodepoolName string `protobuf:"bytes,6,opt,name=nodepoolName,proto3" json:"nodepoolName,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNodepoolIn) Descriptor deprecated 

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

Deprecated: Use GetNodepoolIn.ProtoReflect.Descriptor instead.

func (*GetNodepoolIn) GetAccountName 

func (x *GetNodepoolIn) GetAccountName() string

func (*GetNodepoolIn) GetClusterName 

func (x *GetNodepoolIn) GetClusterName() string

func (*GetNodepoolIn) GetNodepoolName 

func (x *GetNodepoolIn) GetNodepoolName() string

func (*GetNodepoolIn) GetUserEmail 

func (x *GetNodepoolIn) GetUserEmail() string

func (*GetNodepoolIn) GetUserId 

func (x *GetNodepoolIn) GetUserId() string

func (*GetNodepoolIn) GetUserName 

func (x *GetNodepoolIn) GetUserName() string

func (*GetNodepoolIn) ProtoMessage 

func (*GetNodepoolIn) ProtoMessage()

func (*GetNodepoolIn) ProtoReflect 

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

func (*GetNodepoolIn) Reset 

func (x *GetNodepoolIn) Reset()

func (*GetNodepoolIn) String 

func (x *GetNodepoolIn) String() string

type GetNodepoolOut 

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

func (*GetNodepoolOut) Descriptor deprecated 

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

Deprecated: Use GetNodepoolOut.ProtoReflect.Descriptor instead.

func (*GetNodepoolOut) GetIACJobName 

func (x *GetNodepoolOut) GetIACJobName() string

func (*GetNodepoolOut) GetIACJobNamespace 

func (x *GetNodepoolOut) GetIACJobNamespace() string

func (*GetNodepoolOut) ProtoMessage 

func (*GetNodepoolOut) ProtoMessage()

func (*GetNodepoolOut) ProtoReflect 

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

func (*GetNodepoolOut) Reset 

func (x *GetNodepoolOut) Reset()

func (*GetNodepoolOut) String 

func (x *GetNodepoolOut) String() string

type InfraClient 

type InfraClient interface {
	GetCluster(ctx context.Context, in *GetClusterIn, opts ...grpc.CallOption) (*GetClusterOut, error)
	GetNodepool(ctx context.Context, in *GetNodepoolIn, opts ...grpc.CallOption) (*GetNodepoolOut, error)
	ClusterExists(ctx context.Context, in *ClusterExistsIn, opts ...grpc.CallOption) (*ClusterExistsOut, error)
	GetClusterKubeconfig(ctx context.Context, in *GetClusterIn, opts ...grpc.CallOption) (*GetClusterKubeconfigOut, error)
	MarkClusterOnlineAt(ctx context.Context, in *MarkClusterOnlineAtIn, opts ...grpc.CallOption) (*MarkClusterOnlineAtOut, error)
}

InfraClient is the client API for Infra 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 NewInfraClient 

func NewInfraClient(cc grpc.ClientConnInterface) InfraClient

type InfraServer 

type InfraServer interface {
	GetCluster(context.Context, *GetClusterIn) (*GetClusterOut, error)
	GetNodepool(context.Context, *GetNodepoolIn) (*GetNodepoolOut, error)
	ClusterExists(context.Context, *ClusterExistsIn) (*ClusterExistsOut, error)
	GetClusterKubeconfig(context.Context, *GetClusterIn) (*GetClusterKubeconfigOut, error)
	MarkClusterOnlineAt(context.Context, *MarkClusterOnlineAtIn) (*MarkClusterOnlineAtOut, error)
	// contains filtered or unexported methods
}

InfraServer is the server API for Infra service. All implementations must embed UnimplementedInfraServer for forward compatibility

type MarkClusterOnlineAtIn 

type MarkClusterOnlineAtIn struct {
	AccountName string                 `protobuf:"bytes,1,opt,name=accountName,proto3" json:"accountName,omitempty"`
	ClusterName string                 `protobuf:"bytes,2,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	Timestamp   *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*MarkClusterOnlineAtIn) Descriptor deprecated 

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

Deprecated: Use MarkClusterOnlineAtIn.ProtoReflect.Descriptor instead.

func (*MarkClusterOnlineAtIn) GetAccountName 

func (x *MarkClusterOnlineAtIn) GetAccountName() string

func (*MarkClusterOnlineAtIn) GetClusterName 

func (x *MarkClusterOnlineAtIn) GetClusterName() string

func (*MarkClusterOnlineAtIn) GetTimestamp 

func (x *MarkClusterOnlineAtIn) GetTimestamp() *timestamppb.Timestamp

func (*MarkClusterOnlineAtIn) ProtoMessage 

func (*MarkClusterOnlineAtIn) ProtoMessage()

func (*MarkClusterOnlineAtIn) ProtoReflect 

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

func (*MarkClusterOnlineAtIn) Reset 

func (x *MarkClusterOnlineAtIn) Reset()

func (*MarkClusterOnlineAtIn) String 

func (x *MarkClusterOnlineAtIn) String() string

type MarkClusterOnlineAtOut 

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

func (*MarkClusterOnlineAtOut) Descriptor deprecated 

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

Deprecated: Use MarkClusterOnlineAtOut.ProtoReflect.Descriptor instead.

func (*MarkClusterOnlineAtOut) ProtoMessage 

func (*MarkClusterOnlineAtOut) ProtoMessage()

func (*MarkClusterOnlineAtOut) ProtoReflect 

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

func (*MarkClusterOnlineAtOut) Reset 

func (x *MarkClusterOnlineAtOut) Reset()

func (*MarkClusterOnlineAtOut) String 

func (x *MarkClusterOnlineAtOut) String() string

type UnimplementedInfraServer 

type UnimplementedInfraServer struct {
}

UnimplementedInfraServer must be embedded to have forward compatible implementations.

func (UnimplementedInfraServer) ClusterExists 

func (UnimplementedInfraServer) ClusterExists(context.Context, *ClusterExistsIn) (*ClusterExistsOut, error)

func (UnimplementedInfraServer) GetCluster 

func (UnimplementedInfraServer) GetCluster(context.Context, *GetClusterIn) (*GetClusterOut, error)

func (UnimplementedInfraServer) GetClusterKubeconfig 

func (UnimplementedInfraServer) GetClusterKubeconfig(context.Context, *GetClusterIn) (*GetClusterKubeconfigOut, error)

func (UnimplementedInfraServer) GetNodepool 

func (UnimplementedInfraServer) GetNodepool(context.Context, *GetNodepoolIn) (*GetNodepoolOut, error)

func (UnimplementedInfraServer) MarkClusterOnlineAt 

func (UnimplementedInfraServer) MarkClusterOnlineAt(context.Context, *MarkClusterOnlineAtIn) (*MarkClusterOnlineAtOut, error)

type UnsafeInfraServer 

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

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

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.