sentry

package
v0.1.2 Latest Latest
Warning

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

 Go to latest Published: Aug 12, 2022 License: Apache-2.0 Imports: 25 Imported by: 4

Documentation

Overview

Package sentry is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package sentry is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package sentry is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package sentry is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package sentry is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var AuditInformation_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "paralus.dev.sentry.rpc.AuditInformation",
	HandlerType: (*AuditInformationServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "LookupUser",
			Handler:    _AuditInformation_LookupUser_Handler,
		},
		{
			MethodName: "LookupCluster",
			Handler:    _AuditInformation_LookupCluster_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/rpc/sentry/audit_info.proto",
}

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

View Source 
var Bootstrap_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "paralus.dev.sentry.rpc.Bootstrap",
	HandlerType: (*BootstrapServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PatchBootstrapInfra",
			Handler:    _Bootstrap_PatchBootstrapInfra_Handler,
		},
		{
			MethodName: "GetBootstrapInfra",
			Handler:    _Bootstrap_GetBootstrapInfra_Handler,
		},
		{
			MethodName: "PatchBootstrapAgentTemplate",
			Handler:    _Bootstrap_PatchBootstrapAgentTemplate_Handler,
		},
		{
			MethodName: "GetBootstrapAgentTemplate",
			Handler:    _Bootstrap_GetBootstrapAgentTemplate_Handler,
		},
		{
			MethodName: "GetBootstrapAgentTemplates",
			Handler:    _Bootstrap_GetBootstrapAgentTemplates_Handler,
		},
		{
			MethodName: "RegisterBootstrapAgent",
			Handler:    _Bootstrap_RegisterBootstrapAgent_Handler,
		},
		{
			MethodName: "GetBootstrapAgentConfig",
			Handler:    _Bootstrap_GetBootstrapAgentConfig_Handler,
		},
		{
			MethodName: "CreateBootstrapAgent",
			Handler:    _Bootstrap_CreateBootstrapAgent_Handler,
		},
		{
			MethodName: "GetBootstrapAgent",
			Handler:    _Bootstrap_GetBootstrapAgent_Handler,
		},
		{
			MethodName: "GetBootstrapAgents",
			Handler:    _Bootstrap_GetBootstrapAgents_Handler,
		},
		{
			MethodName: "DeleteBootstrapAgent",
			Handler:    _Bootstrap_DeleteBootstrapAgent_Handler,
		},
		{
			MethodName: "UpdateBootstrapAgent",
			Handler:    _Bootstrap_UpdateBootstrapAgent_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/rpc/sentry/bootstrap.proto",
}

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

View Source 
var ClusterAuthorization_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "paralus.dev.sentry.rpc.ClusterAuthorization",
	HandlerType: (*ClusterAuthorizationServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetUserAuthorization",
			Handler:    _ClusterAuthorization_GetUserAuthorization_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/rpc/sentry/cluster_authz.proto",
}

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

View Source 
var File_proto_rpc_sentry_audit_info_proto protoreflect.FileDescriptor
View Source 
var File_proto_rpc_sentry_bootstrap_proto protoreflect.FileDescriptor
View Source 
var File_proto_rpc_sentry_cluster_authz_proto protoreflect.FileDescriptor
View Source 
var File_proto_rpc_sentry_kubeconfig_proto protoreflect.FileDescriptor
View Source 
var File_proto_rpc_sentry_kubectl_cluster_proto protoreflect.FileDescriptor
View Source 
var File_proto_rpc_sentry_relaypeer_proto protoreflect.FileDescriptor
View Source 
var KubeConfig_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "paralus.dev.sentry.rpc.KubeConfig",
	HandlerType: (*KubeConfigServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetForClusterWebSession",
			Handler:    _KubeConfig_GetForClusterWebSession_Handler,
		},
		{
			MethodName: "GetForClusterSystemSession",
			Handler:    _KubeConfig_GetForClusterSystemSession_Handler,
		},
		{
			MethodName: "GetForUser",
			Handler:    _KubeConfig_GetForUser_Handler,
		},
		{
			MethodName: "RevokeKubeconfig",
			Handler:    _KubeConfig_RevokeKubeconfig_Handler,
		},
		{
			MethodName: "GetOrganizationSetting",
			Handler:    _KubeConfig_GetOrganizationSetting_Handler,
		},
		{
			MethodName: "GetUserSetting",
			Handler:    _KubeConfig_GetUserSetting_Handler,
		},
		{
			MethodName: "GetSSOUserSetting",
			Handler:    _KubeConfig_GetSSOUserSetting_Handler,
		},
		{
			MethodName: "UpdateOrganizationSetting",
			Handler:    _KubeConfig_UpdateOrganizationSetting_Handler,
		},
		{
			MethodName: "UpdateUserSetting",
			Handler:    _KubeConfig_UpdateUserSetting_Handler,
		},
		{
			MethodName: "UpdateSSOUserSetting",
			Handler:    _KubeConfig_UpdateSSOUserSetting_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/rpc/sentry/kubeconfig.proto",
}

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

View Source 
var KubectlClusterSettings_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "paralus.dev.sentry.rpc.KubectlClusterSettings",
	HandlerType: (*KubectlClusterSettingsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "UpdateKubectlClusterSettings",
			Handler:    _KubectlClusterSettings_UpdateKubectlClusterSettings_Handler,
		},
		{
			MethodName: "GetKubectlClusterSettings",
			Handler:    _KubectlClusterSettings_GetKubectlClusterSettings_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/rpc/sentry/kubectl_cluster.proto",
}

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

View Source 
var RelayPeerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "paralus.dev.sentry.rpc.RelayPeerService",
	HandlerType: (*RelayPeerServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "RelayPeerHelloRPC",
			Handler:       _RelayPeerService_RelayPeerHelloRPC_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "RelayPeerProbeRPC",
			Handler:       _RelayPeerService_RelayPeerProbeRPC_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "RelayPeerSurveyRPC",
			Handler:       _RelayPeerService_RelayPeerSurveyRPC_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "proto/rpc/sentry/relaypeer.proto",
}

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

Functions

func RegisterAuditInformationHandler 

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

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

func RegisterAuditInformationHandlerClient 

func RegisterAuditInformationHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AuditInformationClient) error

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

func RegisterAuditInformationHandlerFromEndpoint 

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

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

func RegisterAuditInformationHandlerServer 

func RegisterAuditInformationHandlerServer(ctx context.Context, mux *runtime.ServeMux, server AuditInformationServer) error

RegisterAuditInformationHandlerServer registers the http handlers for service AuditInformation to "mux". UnaryRPC :call AuditInformationServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterAuditInformationHandlerFromEndpoint instead.

func RegisterAuditInformationServer 

func RegisterAuditInformationServer(s grpc.ServiceRegistrar, srv AuditInformationServer)

func RegisterBootstrapHandler 

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

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

func RegisterBootstrapHandlerClient 

func RegisterBootstrapHandlerClient(ctx context.Context, mux *runtime.ServeMux, client BootstrapClient) error

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

func RegisterBootstrapHandlerFromEndpoint 

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

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

func RegisterBootstrapHandlerServer 

func RegisterBootstrapHandlerServer(ctx context.Context, mux *runtime.ServeMux, server BootstrapServer) error

RegisterBootstrapHandlerServer registers the http handlers for service Bootstrap to "mux". UnaryRPC :call BootstrapServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterBootstrapHandlerFromEndpoint instead.

func RegisterBootstrapServer 

func RegisterBootstrapServer(s grpc.ServiceRegistrar, srv BootstrapServer)

func RegisterClusterAuthorizationHandler 

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

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

func RegisterClusterAuthorizationHandlerClient 

func RegisterClusterAuthorizationHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ClusterAuthorizationClient) error

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

func RegisterClusterAuthorizationHandlerFromEndpoint 

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

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

func RegisterClusterAuthorizationHandlerServer 

func RegisterClusterAuthorizationHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ClusterAuthorizationServer) error

RegisterClusterAuthorizationHandlerServer registers the http handlers for service ClusterAuthorization to "mux". UnaryRPC :call ClusterAuthorizationServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterClusterAuthorizationHandlerFromEndpoint instead.

func RegisterClusterAuthorizationServer 

func RegisterClusterAuthorizationServer(s grpc.ServiceRegistrar, srv ClusterAuthorizationServer)

func RegisterKubeConfigHandler 

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

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

func RegisterKubeConfigHandlerClient 

func RegisterKubeConfigHandlerClient(ctx context.Context, mux *runtime.ServeMux, client KubeConfigClient) error

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

func RegisterKubeConfigHandlerFromEndpoint 

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

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

func RegisterKubeConfigHandlerServer 

func RegisterKubeConfigHandlerServer(ctx context.Context, mux *runtime.ServeMux, server KubeConfigServer) error

RegisterKubeConfigHandlerServer registers the http handlers for service KubeConfig to "mux". UnaryRPC :call KubeConfigServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterKubeConfigHandlerFromEndpoint instead.

func RegisterKubeConfigServer 

func RegisterKubeConfigServer(s grpc.ServiceRegistrar, srv KubeConfigServer)

func RegisterKubectlClusterSettingsHandler 

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

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

func RegisterKubectlClusterSettingsHandlerClient 

func RegisterKubectlClusterSettingsHandlerClient(ctx context.Context, mux *runtime.ServeMux, client KubectlClusterSettingsClient) error

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

func RegisterKubectlClusterSettingsHandlerFromEndpoint 

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

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

func RegisterKubectlClusterSettingsHandlerServer 

func RegisterKubectlClusterSettingsHandlerServer(ctx context.Context, mux *runtime.ServeMux, server KubectlClusterSettingsServer) error

RegisterKubectlClusterSettingsHandlerServer registers the http handlers for service KubectlClusterSettings to "mux". UnaryRPC :call KubectlClusterSettingsServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterKubectlClusterSettingsHandlerFromEndpoint instead.

func RegisterKubectlClusterSettingsServer 

func RegisterKubectlClusterSettingsServer(s grpc.ServiceRegistrar, srv KubectlClusterSettingsServer)

func RegisterRelayPeerServiceServer 

func RegisterRelayPeerServiceServer(s grpc.ServiceRegistrar, srv RelayPeerServiceServer)

Types

type AuditInformationClient 

type AuditInformationClient interface {
	LookupUser(ctx context.Context, in *LookupUserRequest, opts ...grpc.CallOption) (*LookupUserResponse, error)
	LookupCluster(ctx context.Context, in *LookupClusterRequest, opts ...grpc.CallOption) (*LookupClusterResponse, error)
}

AuditInformationClient is the client API for AuditInformation 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 NewAuditInformationClient 

func NewAuditInformationClient(cc grpc.ClientConnInterface) AuditInformationClient

type AuditInformationServer 

type AuditInformationServer interface {
	LookupUser(context.Context, *LookupUserRequest) (*LookupUserResponse, error)
	LookupCluster(context.Context, *LookupClusterRequest) (*LookupClusterResponse, error)
}

AuditInformationServer is the server API for AuditInformation service. All implementations should embed UnimplementedAuditInformationServer for forward compatibility

type BootstrapClient 

type BootstrapClient interface {
	PatchBootstrapInfra(ctx context.Context, in *sentry.BootstrapInfra, opts ...grpc.CallOption) (*sentry.BootstrapInfra, error)
	GetBootstrapInfra(ctx context.Context, in *sentry.BootstrapInfra, opts ...grpc.CallOption) (*sentry.BootstrapInfra, error)
	PatchBootstrapAgentTemplate(ctx context.Context, in *sentry.BootstrapAgentTemplate, opts ...grpc.CallOption) (*sentry.BootstrapAgentTemplate, error)
	GetBootstrapAgentTemplate(ctx context.Context, in *sentry.BootstrapAgentTemplate, opts ...grpc.CallOption) (*sentry.BootstrapAgentTemplate, error)
	GetBootstrapAgentTemplates(ctx context.Context, in *v3.QueryOptions, opts ...grpc.CallOption) (*sentry.BootstrapAgentTemplateList, error)
	RegisterBootstrapAgent(ctx context.Context, in *RegisterAgentRequest, opts ...grpc.CallOption) (*RegisterAgentResponse, error)
	GetBootstrapAgentConfig(ctx context.Context, in *sentry.BootstrapAgent, opts ...grpc.CallOption) (*v3.HttpBody, error)
	CreateBootstrapAgent(ctx context.Context, in *sentry.BootstrapAgent, opts ...grpc.CallOption) (*sentry.BootstrapAgent, error)
	GetBootstrapAgent(ctx context.Context, in *sentry.BootstrapAgent, opts ...grpc.CallOption) (*sentry.BootstrapAgent, error)
	GetBootstrapAgents(ctx context.Context, in *GetBootstrapAgentsRequest, opts ...grpc.CallOption) (*sentry.BootstrapAgentList, error)
	DeleteBootstrapAgent(ctx context.Context, in *sentry.BootstrapAgent, opts ...grpc.CallOption) (*DeleteBootstrapAgentResponse, error)
	UpdateBootstrapAgent(ctx context.Context, in *sentry.BootstrapAgent, opts ...grpc.CallOption) (*sentry.BootstrapAgent, error)
}

BootstrapClient is the client API for Bootstrap 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 NewBootstrapClient 

func NewBootstrapClient(cc grpc.ClientConnInterface) BootstrapClient

type BootstrapServer 

type BootstrapServer interface {
	PatchBootstrapInfra(context.Context, *sentry.BootstrapInfra) (*sentry.BootstrapInfra, error)
	GetBootstrapInfra(context.Context, *sentry.BootstrapInfra) (*sentry.BootstrapInfra, error)
	PatchBootstrapAgentTemplate(context.Context, *sentry.BootstrapAgentTemplate) (*sentry.BootstrapAgentTemplate, error)
	GetBootstrapAgentTemplate(context.Context, *sentry.BootstrapAgentTemplate) (*sentry.BootstrapAgentTemplate, error)
	GetBootstrapAgentTemplates(context.Context, *v3.QueryOptions) (*sentry.BootstrapAgentTemplateList, error)
	RegisterBootstrapAgent(context.Context, *RegisterAgentRequest) (*RegisterAgentResponse, error)
	GetBootstrapAgentConfig(context.Context, *sentry.BootstrapAgent) (*v3.HttpBody, error)
	CreateBootstrapAgent(context.Context, *sentry.BootstrapAgent) (*sentry.BootstrapAgent, error)
	GetBootstrapAgent(context.Context, *sentry.BootstrapAgent) (*sentry.BootstrapAgent, error)
	GetBootstrapAgents(context.Context, *GetBootstrapAgentsRequest) (*sentry.BootstrapAgentList, error)
	DeleteBootstrapAgent(context.Context, *sentry.BootstrapAgent) (*DeleteBootstrapAgentResponse, error)
	UpdateBootstrapAgent(context.Context, *sentry.BootstrapAgent) (*sentry.BootstrapAgent, error)
}

BootstrapServer is the server API for Bootstrap service. All implementations should embed UnimplementedBootstrapServer for forward compatibility

type ClusterAuthorizationClient 

type ClusterAuthorizationClient interface {
	GetUserAuthorization(ctx context.Context, in *GetUserAuthorizationRequest, opts ...grpc.CallOption) (*GetUserAuthorizationResponse, error)
}

ClusterAuthorizationClient is the client API for ClusterAuthorization 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 NewClusterAuthorizationClient 

func NewClusterAuthorizationClient(cc grpc.ClientConnInterface) ClusterAuthorizationClient

type ClusterAuthorizationServer 

type ClusterAuthorizationServer interface {
	GetUserAuthorization(context.Context, *GetUserAuthorizationRequest) (*GetUserAuthorizationResponse, error)
}

ClusterAuthorizationServer is the server API for ClusterAuthorization service. All implementations should embed UnimplementedClusterAuthorizationServer for forward compatibility

type DeleteBootstrapAgentResponse 

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

func (*DeleteBootstrapAgentResponse) Descriptor deprecated 

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

Deprecated: Use DeleteBootstrapAgentResponse.ProtoReflect.Descriptor instead.

func (*DeleteBootstrapAgentResponse) ProtoMessage 

func (*DeleteBootstrapAgentResponse) ProtoMessage()

func (*DeleteBootstrapAgentResponse) ProtoReflect 

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

func (*DeleteBootstrapAgentResponse) Reset 

func (x *DeleteBootstrapAgentResponse) Reset()

func (*DeleteBootstrapAgentResponse) String 

func (x *DeleteBootstrapAgentResponse) String() string

type DeleteRelayNetworkResponse 

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

func (*DeleteRelayNetworkResponse) Descriptor deprecated 

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

Deprecated: Use DeleteRelayNetworkResponse.ProtoReflect.Descriptor instead.

func (*DeleteRelayNetworkResponse) ProtoMessage 

func (*DeleteRelayNetworkResponse) ProtoMessage()

func (*DeleteRelayNetworkResponse) ProtoReflect 

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

func (*DeleteRelayNetworkResponse) Reset 

func (x *DeleteRelayNetworkResponse) Reset()

func (*DeleteRelayNetworkResponse) String 

func (x *DeleteRelayNetworkResponse) String() string

type GetBootstrapAgentsRequest 

type GetBootstrapAgentsRequest struct {
	Opts          *v3.QueryOptions `protobuf:"bytes,1,opt,name=opts,proto3" json:"opts,omitempty"`
	TemplateScope string           `protobuf:"bytes,2,opt,name=templateScope,proto3" json:"templateScope,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBootstrapAgentsRequest) Descriptor deprecated 

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

Deprecated: Use GetBootstrapAgentsRequest.ProtoReflect.Descriptor instead.

func (*GetBootstrapAgentsRequest) GetOpts 

func (x *GetBootstrapAgentsRequest) GetOpts() *v3.QueryOptions

func (*GetBootstrapAgentsRequest) GetTemplateScope 

func (x *GetBootstrapAgentsRequest) GetTemplateScope() string

func (*GetBootstrapAgentsRequest) ProtoMessage 

func (*GetBootstrapAgentsRequest) ProtoMessage()

func (*GetBootstrapAgentsRequest) ProtoReflect 

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

func (*GetBootstrapAgentsRequest) Reset 

func (x *GetBootstrapAgentsRequest) Reset()

func (*GetBootstrapAgentsRequest) String 

func (x *GetBootstrapAgentsRequest) String() string

type GetForClusterRequest 

type GetForClusterRequest struct {
	Opts       *v3.QueryOptions `protobuf:"bytes,1,opt,name=opts,proto3" json:"opts,omitempty"`
	Namespace  string           `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	SystemUser bool             `protobuf:"varint,3,opt,name=systemUser,proto3" json:"systemUser,omitempty"`
	// contains filtered or unexported fields
}

func (*GetForClusterRequest) Descriptor deprecated 

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

Deprecated: Use GetForClusterRequest.ProtoReflect.Descriptor instead.

func (*GetForClusterRequest) GetNamespace 

func (x *GetForClusterRequest) GetNamespace() string

func (*GetForClusterRequest) GetOpts 

func (x *GetForClusterRequest) GetOpts() *v3.QueryOptions

func (*GetForClusterRequest) GetSystemUser 

func (x *GetForClusterRequest) GetSystemUser() bool

func (*GetForClusterRequest) ProtoMessage 

func (*GetForClusterRequest) ProtoMessage()

func (*GetForClusterRequest) ProtoReflect 

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

func (*GetForClusterRequest) Reset 

func (x *GetForClusterRequest) Reset()

func (*GetForClusterRequest) String 

func (x *GetForClusterRequest) String() string

type GetForUserRequest 

type GetForUserRequest struct {
	Opts      *v3.QueryOptions `protobuf:"bytes,1,opt,name=opts,proto3" json:"opts,omitempty"`
	Namespace string           `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*GetForUserRequest) Descriptor deprecated 

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

Deprecated: Use GetForUserRequest.ProtoReflect.Descriptor instead.

func (*GetForUserRequest) GetNamespace 

func (x *GetForUserRequest) GetNamespace() string

func (*GetForUserRequest) GetOpts 

func (x *GetForUserRequest) GetOpts() *v3.QueryOptions

func (*GetForUserRequest) ProtoMessage 

func (*GetForUserRequest) ProtoMessage()

func (*GetForUserRequest) ProtoReflect 

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

func (*GetForUserRequest) Reset 

func (x *GetForUserRequest) Reset()

func (*GetForUserRequest) String 

func (x *GetForUserRequest) String() string

type GetKubeconfigSettingRequest 

type GetKubeconfigSettingRequest struct {
	Opts *v3.QueryOptions `protobuf:"bytes,1,opt,name=opts,proto3" json:"opts,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKubeconfigSettingRequest) Descriptor deprecated 

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

Deprecated: Use GetKubeconfigSettingRequest.ProtoReflect.Descriptor instead.

func (*GetKubeconfigSettingRequest) GetOpts 

func (x *GetKubeconfigSettingRequest) GetOpts() *v3.QueryOptions

func (*GetKubeconfigSettingRequest) ProtoMessage 

func (*GetKubeconfigSettingRequest) ProtoMessage()

func (*GetKubeconfigSettingRequest) ProtoReflect 

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

func (*GetKubeconfigSettingRequest) Reset 

func (x *GetKubeconfigSettingRequest) Reset()

func (*GetKubeconfigSettingRequest) String 

func (x *GetKubeconfigSettingRequest) String() string

type GetKubeconfigSettingResponse 

type GetKubeconfigSettingResponse struct {
	ValiditySeconds             int64 `protobuf:"varint,1,opt,name=validitySeconds,proto3" json:"validitySeconds,omitempty"`
	EnableSessionCheck          bool  `protobuf:"varint,2,opt,name=enableSessionCheck,proto3" json:"enableSessionCheck,omitempty"`
	EnablePrivateRelay          bool  `protobuf:"varint,3,opt,name=enablePrivateRelay,proto3" json:"enablePrivateRelay,omitempty"`
	EnforceOrgAdminSecretAccess bool  `protobuf:"varint,4,opt,name=enforceOrgAdminSecretAccess,proto3" json:"enforceOrgAdminSecretAccess,omitempty"`
	DisableWebKubectl           bool  `protobuf:"varint,5,opt,name=disableWebKubectl,proto3" json:"disableWebKubectl,omitempty"`
	DisableCLIKubectl           bool  `protobuf:"varint,6,opt,name=disableCLIKubectl,proto3" json:"disableCLIKubectl,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKubeconfigSettingResponse) Descriptor deprecated 

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

Deprecated: Use GetKubeconfigSettingResponse.ProtoReflect.Descriptor instead.

func (*GetKubeconfigSettingResponse) GetDisableCLIKubectl 

func (x *GetKubeconfigSettingResponse) GetDisableCLIKubectl() bool

func (*GetKubeconfigSettingResponse) GetDisableWebKubectl 

func (x *GetKubeconfigSettingResponse) GetDisableWebKubectl() bool

func (*GetKubeconfigSettingResponse) GetEnablePrivateRelay 

func (x *GetKubeconfigSettingResponse) GetEnablePrivateRelay() bool

func (*GetKubeconfigSettingResponse) GetEnableSessionCheck 

func (x *GetKubeconfigSettingResponse) GetEnableSessionCheck() bool

func (*GetKubeconfigSettingResponse) GetEnforceOrgAdminSecretAccess 

func (x *GetKubeconfigSettingResponse) GetEnforceOrgAdminSecretAccess() bool

func (*GetKubeconfigSettingResponse) GetValiditySeconds 

func (x *GetKubeconfigSettingResponse) GetValiditySeconds() int64

func (*GetKubeconfigSettingResponse) ProtoMessage 

func (*GetKubeconfigSettingResponse) ProtoMessage()

func (*GetKubeconfigSettingResponse) ProtoReflect 

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

func (*GetKubeconfigSettingResponse) Reset 

func (x *GetKubeconfigSettingResponse) Reset()

func (*GetKubeconfigSettingResponse) String 

func (x *GetKubeconfigSettingResponse) String() string

type GetKubectlClusterSettingsRequest 

type GetKubectlClusterSettingsRequest struct {
	Opts *v3.QueryOptions `protobuf:"bytes,1,opt,name=opts,proto3" json:"opts,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKubectlClusterSettingsRequest) Descriptor deprecated 

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

Deprecated: Use GetKubectlClusterSettingsRequest.ProtoReflect.Descriptor instead.

func (*GetKubectlClusterSettingsRequest) GetOpts 

func (x *GetKubectlClusterSettingsRequest) GetOpts() *v3.QueryOptions

func (*GetKubectlClusterSettingsRequest) ProtoMessage 

func (*GetKubectlClusterSettingsRequest) ProtoMessage()

func (*GetKubectlClusterSettingsRequest) ProtoReflect 

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

func (*GetKubectlClusterSettingsRequest) Reset 

func (x *GetKubectlClusterSettingsRequest) Reset()

func (*GetKubectlClusterSettingsRequest) String 

func (x *GetKubectlClusterSettingsRequest) String() string

type GetKubectlClusterSettingsResponse 

type GetKubectlClusterSettingsResponse struct {
	DisableWebKubectl bool `protobuf:"varint,1,opt,name=disableWebKubectl,proto3" json:"disableWebKubectl,omitempty"`
	DisableCLIKubectl bool `protobuf:"varint,2,opt,name=disableCLIKubectl,proto3" json:"disableCLIKubectl,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKubectlClusterSettingsResponse) Descriptor deprecated 

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

Deprecated: Use GetKubectlClusterSettingsResponse.ProtoReflect.Descriptor instead.

func (*GetKubectlClusterSettingsResponse) GetDisableCLIKubectl 

func (x *GetKubectlClusterSettingsResponse) GetDisableCLIKubectl() bool

func (*GetKubectlClusterSettingsResponse) GetDisableWebKubectl 

func (x *GetKubectlClusterSettingsResponse) GetDisableWebKubectl() bool

func (*GetKubectlClusterSettingsResponse) ProtoMessage 

func (*GetKubectlClusterSettingsResponse) ProtoMessage()

func (*GetKubectlClusterSettingsResponse) ProtoReflect 

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

func (*GetKubectlClusterSettingsResponse) Reset 

func (x *GetKubectlClusterSettingsResponse) Reset()

func (*GetKubectlClusterSettingsResponse) String 

func (x *GetKubectlClusterSettingsResponse) String() string

type GetRelayNetworksRequest 

type GetRelayNetworksRequest struct {
	Opts *v3.QueryOptions `protobuf:"bytes,1,opt,name=opts,proto3" json:"opts,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRelayNetworksRequest) Descriptor deprecated 

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

Deprecated: Use GetRelayNetworksRequest.ProtoReflect.Descriptor instead.

func (*GetRelayNetworksRequest) GetOpts 

func (x *GetRelayNetworksRequest) GetOpts() *v3.QueryOptions

func (*GetRelayNetworksRequest) ProtoMessage 

func (*GetRelayNetworksRequest) ProtoMessage()

func (*GetRelayNetworksRequest) ProtoReflect 

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

func (*GetRelayNetworksRequest) Reset 

func (x *GetRelayNetworksRequest) Reset()

func (*GetRelayNetworksRequest) String 

func (x *GetRelayNetworksRequest) String() string

type GetUserAuthorizationRequest 

type GetUserAuthorizationRequest struct {
	UserCN           string `protobuf:"bytes,1,opt,name=userCN,proto3" json:"userCN,omitempty"`
	ClusterID        string `protobuf:"bytes,2,opt,name=clusterID,proto3" json:"clusterID,omitempty"`
	CertIssueSeconds int64  `protobuf:"varint,3,opt,name=certIssueSeconds,proto3" json:"certIssueSeconds,omitempty"`
	// contains filtered or unexported fields
}

func (*GetUserAuthorizationRequest) Descriptor deprecated 

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

Deprecated: Use GetUserAuthorizationRequest.ProtoReflect.Descriptor instead.

func (*GetUserAuthorizationRequest) GetCertIssueSeconds 

func (x *GetUserAuthorizationRequest) GetCertIssueSeconds() int64

func (*GetUserAuthorizationRequest) GetClusterID 

func (x *GetUserAuthorizationRequest) GetClusterID() string

func (*GetUserAuthorizationRequest) GetUserCN 

func (x *GetUserAuthorizationRequest) GetUserCN() string

func (*GetUserAuthorizationRequest) ProtoMessage 

func (*GetUserAuthorizationRequest) ProtoMessage()

func (*GetUserAuthorizationRequest) ProtoReflect 

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

func (*GetUserAuthorizationRequest) Reset 

func (x *GetUserAuthorizationRequest) Reset()

func (*GetUserAuthorizationRequest) String 

func (x *GetUserAuthorizationRequest) String() string

type GetUserAuthorizationResponse 

type GetUserAuthorizationResponse struct {
	UserName                        string                   `protobuf:"bytes,1,opt,name=userName,proto3" json:"userName,omitempty"`
	ServiceAccount                  *controller.StepObject   `protobuf:"bytes,2,opt,name=serviceAccount,proto3" json:"serviceAccount,omitempty"`
	ClusterRoles                    []*controller.StepObject `protobuf:"bytes,3,rep,name=clusterRoles,proto3" json:"clusterRoles,omitempty"`
	ClusterRoleBindings             []*controller.StepObject `protobuf:"bytes,4,rep,name=clusterRoleBindings,proto3" json:"clusterRoleBindings,omitempty"`
	Roles                           []*controller.StepObject `protobuf:"bytes,5,rep,name=roles,proto3" json:"roles,omitempty"`
	RoleBindings                    []*controller.StepObject `protobuf:"bytes,6,rep,name=roleBindings,proto3" json:"roleBindings,omitempty"`
	DeleteClusterRoleBindings       []*controller.StepObject `protobuf:"bytes,7,rep,name=deleteClusterRoleBindings,proto3" json:"deleteClusterRoleBindings,omitempty"`
	DeleteRoleBindings              []*controller.StepObject `protobuf:"bytes,8,rep,name=deleteRoleBindings,proto3" json:"deleteRoleBindings,omitempty"`
	Namespaces                      []*controller.StepObject `protobuf:"bytes,9,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	RoleName                        string                   `protobuf:"bytes,10,opt,name=roleName,proto3" json:"roleName,omitempty"`
	IsRead                          bool                     `protobuf:"varint,11,opt,name=isRead,proto3" json:"isRead,omitempty"`
	EnforceOrgAdminOnlySecretAccess bool                     `protobuf:"varint,12,opt,name=enforceOrgAdminOnlySecretAccess,proto3" json:"enforceOrgAdminOnlySecretAccess,omitempty"`
	IsOrgAdmin                      bool                     `protobuf:"varint,13,opt,name=isOrgAdmin,proto3" json:"isOrgAdmin,omitempty"`
	// contains filtered or unexported fields
}

func (*GetUserAuthorizationResponse) Descriptor deprecated 

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

Deprecated: Use GetUserAuthorizationResponse.ProtoReflect.Descriptor instead.

func (*GetUserAuthorizationResponse) GetClusterRoleBindings 

func (x *GetUserAuthorizationResponse) GetClusterRoleBindings() []*controller.StepObject

func (*GetUserAuthorizationResponse) GetClusterRoles 

func (x *GetUserAuthorizationResponse) GetClusterRoles() []*controller.StepObject

func (*GetUserAuthorizationResponse) GetDeleteClusterRoleBindings 

func (x *GetUserAuthorizationResponse) GetDeleteClusterRoleBindings() []*controller.StepObject

func (*GetUserAuthorizationResponse) GetDeleteRoleBindings 

func (x *GetUserAuthorizationResponse) GetDeleteRoleBindings() []*controller.StepObject

func (*GetUserAuthorizationResponse) GetEnforceOrgAdminOnlySecretAccess 

func (x *GetUserAuthorizationResponse) GetEnforceOrgAdminOnlySecretAccess() bool

func (*GetUserAuthorizationResponse) GetIsOrgAdmin 

func (x *GetUserAuthorizationResponse) GetIsOrgAdmin() bool

func (*GetUserAuthorizationResponse) GetIsRead 

func (x *GetUserAuthorizationResponse) GetIsRead() bool

func (*GetUserAuthorizationResponse) GetNamespaces 

func (x *GetUserAuthorizationResponse) GetNamespaces() []*controller.StepObject

func (*GetUserAuthorizationResponse) GetRoleBindings 

func (x *GetUserAuthorizationResponse) GetRoleBindings() []*controller.StepObject

func (*GetUserAuthorizationResponse) GetRoleName 

func (x *GetUserAuthorizationResponse) GetRoleName() string

func (*GetUserAuthorizationResponse) GetRoles 

func (x *GetUserAuthorizationResponse) GetRoles() []*controller.StepObject

func (*GetUserAuthorizationResponse) GetServiceAccount 

func (x *GetUserAuthorizationResponse) GetServiceAccount() *controller.StepObject

func (*GetUserAuthorizationResponse) GetUserName 

func (x *GetUserAuthorizationResponse) GetUserName() string

func (*GetUserAuthorizationResponse) ProtoMessage 

func (*GetUserAuthorizationResponse) ProtoMessage()

func (*GetUserAuthorizationResponse) ProtoReflect 

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

func (*GetUserAuthorizationResponse) Reset 

func (x *GetUserAuthorizationResponse) Reset()

func (*GetUserAuthorizationResponse) String 

func (x *GetUserAuthorizationResponse) String() string

type KubeConfigClient 

type KubeConfigClient interface {
	GetForClusterWebSession(ctx context.Context, in *GetForClusterRequest, opts ...grpc.CallOption) (*v3.HttpBody, error)
	GetForClusterSystemSession(ctx context.Context, in *GetForClusterRequest, opts ...grpc.CallOption) (*v3.HttpBody, error)
	GetForUser(ctx context.Context, in *GetForUserRequest, opts ...grpc.CallOption) (*v3.HttpBody, error)
	RevokeKubeconfig(ctx context.Context, in *RevokeKubeconfigRequest, opts ...grpc.CallOption) (*RevokeKubeconfigResponse, error)
	GetOrganizationSetting(ctx context.Context, in *GetKubeconfigSettingRequest, opts ...grpc.CallOption) (*GetKubeconfigSettingResponse, error)
	GetUserSetting(ctx context.Context, in *GetKubeconfigSettingRequest, opts ...grpc.CallOption) (*GetKubeconfigSettingResponse, error)
	GetSSOUserSetting(ctx context.Context, in *GetKubeconfigSettingRequest, opts ...grpc.CallOption) (*GetKubeconfigSettingResponse, error)
	UpdateOrganizationSetting(ctx context.Context, in *UpdateKubeconfigSettingRequest, opts ...grpc.CallOption) (*UpdateKubeconfigSettingResponse, error)
	UpdateUserSetting(ctx context.Context, in *UpdateKubeconfigSettingRequest, opts ...grpc.CallOption) (*UpdateKubeconfigSettingResponse, error)
	UpdateSSOUserSetting(ctx context.Context, in *UpdateKubeconfigSettingRequest, opts ...grpc.CallOption) (*UpdateKubeconfigSettingResponse, error)
}

KubeConfigClient is the client API for KubeConfig 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 NewKubeConfigClient 

func NewKubeConfigClient(cc grpc.ClientConnInterface) KubeConfigClient

type KubeConfigServer 

type KubeConfigServer interface {
	GetForClusterWebSession(context.Context, *GetForClusterRequest) (*v3.HttpBody, error)
	GetForClusterSystemSession(context.Context, *GetForClusterRequest) (*v3.HttpBody, error)
	GetForUser(context.Context, *GetForUserRequest) (*v3.HttpBody, error)
	RevokeKubeconfig(context.Context, *RevokeKubeconfigRequest) (*RevokeKubeconfigResponse, error)
	GetOrganizationSetting(context.Context, *GetKubeconfigSettingRequest) (*GetKubeconfigSettingResponse, error)
	GetUserSetting(context.Context, *GetKubeconfigSettingRequest) (*GetKubeconfigSettingResponse, error)
	GetSSOUserSetting(context.Context, *GetKubeconfigSettingRequest) (*GetKubeconfigSettingResponse, error)
	UpdateOrganizationSetting(context.Context, *UpdateKubeconfigSettingRequest) (*UpdateKubeconfigSettingResponse, error)
	UpdateUserSetting(context.Context, *UpdateKubeconfigSettingRequest) (*UpdateKubeconfigSettingResponse, error)
	UpdateSSOUserSetting(context.Context, *UpdateKubeconfigSettingRequest) (*UpdateKubeconfigSettingResponse, error)
}

KubeConfigServer is the server API for KubeConfig service. All implementations should embed UnimplementedKubeConfigServer for forward compatibility

type KubectlClusterSettingsClient 

type KubectlClusterSettingsClient interface {
	UpdateKubectlClusterSettings(ctx context.Context, in *UpdateKubectlClusterSettingsRequest, opts ...grpc.CallOption) (*UpdateKubectlClusterSettingsResponse, error)
	GetKubectlClusterSettings(ctx context.Context, in *GetKubectlClusterSettingsRequest, opts ...grpc.CallOption) (*GetKubectlClusterSettingsResponse, error)
}

KubectlClusterSettingsClient is the client API for KubectlClusterSettings 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 NewKubectlClusterSettingsClient 

func NewKubectlClusterSettingsClient(cc grpc.ClientConnInterface) KubectlClusterSettingsClient

type KubectlClusterSettingsServer 

type KubectlClusterSettingsServer interface {
	UpdateKubectlClusterSettings(context.Context, *UpdateKubectlClusterSettingsRequest) (*UpdateKubectlClusterSettingsResponse, error)
	GetKubectlClusterSettings(context.Context, *GetKubectlClusterSettingsRequest) (*GetKubectlClusterSettingsResponse, error)
}

KubectlClusterSettingsServer is the server API for KubectlClusterSettings service. All implementations should embed UnimplementedKubectlClusterSettingsServer for forward compatibility

type LookupClusterRequest 

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

func (*LookupClusterRequest) Descriptor deprecated 

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

Deprecated: Use LookupClusterRequest.ProtoReflect.Descriptor instead.

func (*LookupClusterRequest) GetClusterSNI 

func (x *LookupClusterRequest) GetClusterSNI() string

func (*LookupClusterRequest) ProtoMessage 

func (*LookupClusterRequest) ProtoMessage()

func (*LookupClusterRequest) ProtoReflect 

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

func (*LookupClusterRequest) Reset 

func (x *LookupClusterRequest) Reset()

func (*LookupClusterRequest) String 

func (x *LookupClusterRequest) String() string

type LookupClusterResponse 

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

func (*LookupClusterResponse) Descriptor deprecated 

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

Deprecated: Use LookupClusterResponse.ProtoReflect.Descriptor instead.

func (*LookupClusterResponse) GetDisplayName 

func (x *LookupClusterResponse) GetDisplayName() string

func (*LookupClusterResponse) GetName 

func (x *LookupClusterResponse) GetName() string

func (*LookupClusterResponse) ProtoMessage 

func (*LookupClusterResponse) ProtoMessage()

func (*LookupClusterResponse) ProtoReflect 

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

func (*LookupClusterResponse) Reset 

func (x *LookupClusterResponse) Reset()

func (*LookupClusterResponse) String 

func (x *LookupClusterResponse) String() string

type LookupUserRequest 

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

func (*LookupUserRequest) Descriptor deprecated 

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

Deprecated: Use LookupUserRequest.ProtoReflect.Descriptor instead.

func (*LookupUserRequest) GetUserCN 

func (x *LookupUserRequest) GetUserCN() string

func (*LookupUserRequest) ProtoMessage 

func (*LookupUserRequest) ProtoMessage()

func (*LookupUserRequest) ProtoReflect 

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

func (*LookupUserRequest) Reset 

func (x *LookupUserRequest) Reset()

func (*LookupUserRequest) String 

func (x *LookupUserRequest) String() string

type LookupUserResponse 

type LookupUserResponse struct {
	UserName       string `protobuf:"bytes,1,opt,name=userName,proto3" json:"userName,omitempty"`
	AccountID      string `protobuf:"bytes,2,opt,name=accountID,proto3" json:"accountID,omitempty"`
	IsSSO          string `protobuf:"bytes,3,opt,name=isSSO,proto3" json:"isSSO,omitempty"`
	OrganizationID string `protobuf:"bytes,4,opt,name=organizationID,proto3" json:"organizationID,omitempty"`
	PartnerID      string `protobuf:"bytes,5,opt,name=partnerID,proto3" json:"partnerID,omitempty"`
	SessionType    string `protobuf:"bytes,6,opt,name=sessionType,proto3" json:"sessionType,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupUserResponse) Descriptor deprecated 

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

Deprecated: Use LookupUserResponse.ProtoReflect.Descriptor instead.

func (*LookupUserResponse) GetAccountID 

func (x *LookupUserResponse) GetAccountID() string

func (*LookupUserResponse) GetIsSSO 

func (x *LookupUserResponse) GetIsSSO() string

func (*LookupUserResponse) GetOrganizationID 

func (x *LookupUserResponse) GetOrganizationID() string

func (*LookupUserResponse) GetPartnerID 

func (x *LookupUserResponse) GetPartnerID() string

func (*LookupUserResponse) GetSessionType 

func (x *LookupUserResponse) GetSessionType() string

func (*LookupUserResponse) GetUserName 

func (x *LookupUserResponse) GetUserName() string

func (*LookupUserResponse) ProtoMessage 

func (*LookupUserResponse) ProtoMessage()

func (*LookupUserResponse) ProtoReflect 

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

func (*LookupUserResponse) Reset 

func (x *LookupUserResponse) Reset()

func (*LookupUserResponse) String 

func (x *LookupUserResponse) String() string

type Option 

type Option func(*options)

Option is the functional argument for Pool options

func WithAddr 

func WithAddr(addr string) Option

WithAddr sets address of the pool

func WithCaCertPEM 

func WithCaCertPEM(caCert []byte) Option

WithCaCertPEM sets PEM encoded CA cert for pool

func WithClientCertPEM 

func WithClientCertPEM(cert []byte) Option

WithClientCertPEM sets PEM encoded client cert for pool

func WithClientKeyPEM 

func WithClientKeyPEM(key []byte) Option

WithClientKeyPEM sets PEM encoded client key for pool

func WithMaxConn 

func WithMaxConn(maxConn int) Option

WithMaxConn sets maximum number of connections of the pool if not set defaults to 10

type PeerHelloRequest 

type PeerHelloRequest struct {
	Relayuuid string `protobuf:"bytes,1,opt,name=relayuuid,proto3" json:"relayuuid,omitempty"` // the uuid of the relay
	Relayip   string `protobuf:"bytes,2,opt,name=relayip,proto3" json:"relayip,omitempty"`     // the ip address of the relay
	// contains filtered or unexported fields
}

func (*PeerHelloRequest) Descriptor deprecated 

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

Deprecated: Use PeerHelloRequest.ProtoReflect.Descriptor instead.

func (*PeerHelloRequest) GetRelayip 

func (x *PeerHelloRequest) GetRelayip() string

func (*PeerHelloRequest) GetRelayuuid 

func (x *PeerHelloRequest) GetRelayuuid() string

func (*PeerHelloRequest) ProtoMessage 

func (*PeerHelloRequest) ProtoMessage()

func (*PeerHelloRequest) ProtoReflect 

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

func (*PeerHelloRequest) Reset 

func (x *PeerHelloRequest) Reset()

func (*PeerHelloRequest) String 

func (x *PeerHelloRequest) String() string

type PeerHelloResponse 

type PeerHelloResponse struct {
	Serviceuuid string `protobuf:"bytes,1,opt,name=serviceuuid,proto3" json:"serviceuuid,omitempty"` // the uuid of the service
	Serviceip   string `protobuf:"bytes,2,opt,name=serviceip,proto3" json:"serviceip,omitempty"`     // the ip address of the relay
	// contains filtered or unexported fields
}

func (*PeerHelloResponse) Descriptor deprecated 

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

Deprecated: Use PeerHelloResponse.ProtoReflect.Descriptor instead.

func (*PeerHelloResponse) GetServiceip 

func (x *PeerHelloResponse) GetServiceip() string

func (*PeerHelloResponse) GetServiceuuid 

func (x *PeerHelloResponse) GetServiceuuid() string

func (*PeerHelloResponse) ProtoMessage 

func (*PeerHelloResponse) ProtoMessage()

func (*PeerHelloResponse) ProtoReflect 

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

func (*PeerHelloResponse) Reset 

func (x *PeerHelloResponse) Reset()

func (*PeerHelloResponse) String 

func (x *PeerHelloResponse) String() string

type PeerProbeRequest 

type PeerProbeRequest struct {
	Relayuuid  string `protobuf:"bytes,1,opt,name=relayuuid,proto3" json:"relayuuid,omitempty"`
	Clustersni string `protobuf:"bytes,2,opt,name=clustersni,proto3" json:"clustersni,omitempty"`
	// contains filtered or unexported fields
}

Probe Request from relay to peering service

func (*PeerProbeRequest) Descriptor deprecated 

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

Deprecated: Use PeerProbeRequest.ProtoReflect.Descriptor instead.

func (*PeerProbeRequest) GetClustersni 

func (x *PeerProbeRequest) GetClustersni() string

func (*PeerProbeRequest) GetRelayuuid 

func (x *PeerProbeRequest) GetRelayuuid() string

func (*PeerProbeRequest) ProtoMessage 

func (*PeerProbeRequest) ProtoMessage()

func (*PeerProbeRequest) ProtoReflect 

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

func (*PeerProbeRequest) Reset 

func (x *PeerProbeRequest) Reset()

func (*PeerProbeRequest) String 

func (x *PeerProbeRequest) String() string

type PeerProbeResponse 

type PeerProbeResponse struct {
	Clustersni string                        `protobuf:"bytes,1,opt,name=clustersni,proto3" json:"clustersni,omitempty"`
	Items      []*RelayClusterConnectionInfo `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

Probe Response from service to relay

func (*PeerProbeResponse) Descriptor deprecated 

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

Deprecated: Use PeerProbeResponse.ProtoReflect.Descriptor instead.

func (*PeerProbeResponse) GetClustersni 

func (x *PeerProbeResponse) GetClustersni() string

func (*PeerProbeResponse) GetItems 

func (x *PeerProbeResponse) GetItems() []*RelayClusterConnectionInfo

func (*PeerProbeResponse) ProtoMessage 

func (*PeerProbeResponse) ProtoMessage()

func (*PeerProbeResponse) ProtoReflect 

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

func (*PeerProbeResponse) Reset 

func (x *PeerProbeResponse) Reset()

func (*PeerProbeResponse) String 

func (x *PeerProbeResponse) String() string

type PeerSurveyRequest 

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

Survey request sent from the service to all relays

func (*PeerSurveyRequest) Descriptor deprecated 

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

Deprecated: Use PeerSurveyRequest.ProtoReflect.Descriptor instead.

func (*PeerSurveyRequest) GetClustersni 

func (x *PeerSurveyRequest) GetClustersni() string

func (*PeerSurveyRequest) ProtoMessage 

func (*PeerSurveyRequest) ProtoMessage()

func (*PeerSurveyRequest) ProtoReflect 

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

func (*PeerSurveyRequest) Reset 

func (x *PeerSurveyRequest) Reset()

func (*PeerSurveyRequest) String 

func (x *PeerSurveyRequest) String() string

type PeerSurveyResponse 

type PeerSurveyResponse struct {
	Relayuuid  string `protobuf:"bytes,1,opt,name=relayuuid,proto3" json:"relayuuid,omitempty"` // the uuid of the relay
	Relayip    string `protobuf:"bytes,2,opt,name=relayip,proto3" json:"relayip,omitempty"`     // the ip address of the relay
	Clustersni string `protobuf:"bytes,3,opt,name=clustersni,proto3" json:"clustersni,omitempty"`
	// contains filtered or unexported fields
}

Survey response from relay to service

func (*PeerSurveyResponse) Descriptor deprecated 

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

Deprecated: Use PeerSurveyResponse.ProtoReflect.Descriptor instead.

func (*PeerSurveyResponse) GetClustersni 

func (x *PeerSurveyResponse) GetClustersni() string

func (*PeerSurveyResponse) GetRelayip 

func (x *PeerSurveyResponse) GetRelayip() string

func (*PeerSurveyResponse) GetRelayuuid 

func (x *PeerSurveyResponse) GetRelayuuid() string

func (*PeerSurveyResponse) ProtoMessage 

func (*PeerSurveyResponse) ProtoMessage()

func (*PeerSurveyResponse) ProtoReflect 

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

func (*PeerSurveyResponse) Reset 

func (x *PeerSurveyResponse) Reset()

func (*PeerSurveyResponse) String 

func (x *PeerSurveyResponse) String() string

type RegisterAgentRequest 

type RegisterAgentRequest struct {
	TemplateToken string `protobuf:"bytes,1,opt,name=templateToken,proto3" json:"templateToken,omitempty"`
	TemplateName  string `protobuf:"bytes,2,opt,name=templateName,proto3" json:"templateName,omitempty"`
	Token         string `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
	Csr           []byte `protobuf:"bytes,4,opt,name=csr,proto3" json:"csr,omitempty"`
	IpAddress     string `protobuf:"bytes,5,opt,name=ipAddress,proto3" json:"ipAddress,omitempty"`
	Name          string `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterAgentRequest) Descriptor deprecated 

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

Deprecated: Use RegisterAgentRequest.ProtoReflect.Descriptor instead.

func (*RegisterAgentRequest) GetCsr 

func (x *RegisterAgentRequest) GetCsr() []byte

func (*RegisterAgentRequest) GetIpAddress 

func (x *RegisterAgentRequest) GetIpAddress() string

func (*RegisterAgentRequest) GetName 

func (x *RegisterAgentRequest) GetName() string

func (*RegisterAgentRequest) GetTemplateName 

func (x *RegisterAgentRequest) GetTemplateName() string

func (*RegisterAgentRequest) GetTemplateToken 

func (x *RegisterAgentRequest) GetTemplateToken() string

func (*RegisterAgentRequest) GetToken 

func (x *RegisterAgentRequest) GetToken() string

func (*RegisterAgentRequest) ProtoMessage 

func (*RegisterAgentRequest) ProtoMessage()

func (*RegisterAgentRequest) ProtoReflect 

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

func (*RegisterAgentRequest) Reset 

func (x *RegisterAgentRequest) Reset()

func (*RegisterAgentRequest) String 

func (x *RegisterAgentRequest) String() string

type RegisterAgentResponse 

type RegisterAgentResponse struct {
	Certificate   []byte `protobuf:"bytes,1,opt,name=certificate,proto3" json:"certificate,omitempty"`
	CaCertificate []byte `protobuf:"bytes,2,opt,name=caCertificate,proto3" json:"caCertificate,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterAgentResponse) Descriptor deprecated 

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

Deprecated: Use RegisterAgentResponse.ProtoReflect.Descriptor instead.

func (*RegisterAgentResponse) GetCaCertificate 

func (x *RegisterAgentResponse) GetCaCertificate() []byte

func (*RegisterAgentResponse) GetCertificate 

func (x *RegisterAgentResponse) GetCertificate() []byte

func (*RegisterAgentResponse) ProtoMessage 

func (*RegisterAgentResponse) ProtoMessage()

func (*RegisterAgentResponse) ProtoReflect 

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

func (*RegisterAgentResponse) Reset 

func (x *RegisterAgentResponse) Reset()

func (*RegisterAgentResponse) String 

func (x *RegisterAgentResponse) String() string

type RelayAgentDownloadRequest 

type RelayAgentDownloadRequest struct {
	Metadata     *v3.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	ClusterScope string       `protobuf:"bytes,2,opt,name=clusterScope,proto3" json:"clusterScope,omitempty"`
	// contains filtered or unexported fields
}

func (*RelayAgentDownloadRequest) Descriptor deprecated 

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

Deprecated: Use RelayAgentDownloadRequest.ProtoReflect.Descriptor instead.

func (*RelayAgentDownloadRequest) GetClusterScope 

func (x *RelayAgentDownloadRequest) GetClusterScope() string

func (*RelayAgentDownloadRequest) GetMetadata 

func (x *RelayAgentDownloadRequest) GetMetadata() *v3.Metadata

func (*RelayAgentDownloadRequest) ProtoMessage 

func (*RelayAgentDownloadRequest) ProtoMessage()

func (*RelayAgentDownloadRequest) ProtoReflect 

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

func (*RelayAgentDownloadRequest) Reset 

func (x *RelayAgentDownloadRequest) Reset()

func (*RelayAgentDownloadRequest) String 

func (x *RelayAgentDownloadRequest) String() string

type RelayClusterConnectionInfo 

type RelayClusterConnectionInfo struct {
	Relayuuid string `protobuf:"bytes,1,opt,name=relayuuid,proto3" json:"relayuuid,omitempty"` // the uuid of the relay
	Relayip   string `protobuf:"bytes,2,opt,name=relayip,proto3" json:"relayip,omitempty"`     // the ip address of the relay
	// contains filtered or unexported fields
}

func (*RelayClusterConnectionInfo) Descriptor deprecated 

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

Deprecated: Use RelayClusterConnectionInfo.ProtoReflect.Descriptor instead.

func (*RelayClusterConnectionInfo) GetRelayip 

func (x *RelayClusterConnectionInfo) GetRelayip() string

func (*RelayClusterConnectionInfo) GetRelayuuid 

func (x *RelayClusterConnectionInfo) GetRelayuuid() string

func (*RelayClusterConnectionInfo) ProtoMessage 

func (*RelayClusterConnectionInfo) ProtoMessage()

func (*RelayClusterConnectionInfo) ProtoReflect 

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

func (*RelayClusterConnectionInfo) Reset 

func (x *RelayClusterConnectionInfo) Reset()

func (*RelayClusterConnectionInfo) String 

func (x *RelayClusterConnectionInfo) String() string

type RelayPeerServiceClient 

type RelayPeerServiceClient interface {
	RelayPeerHelloRPC(ctx context.Context, opts ...grpc.CallOption) (RelayPeerService_RelayPeerHelloRPCClient, error)
	RelayPeerProbeRPC(ctx context.Context, opts ...grpc.CallOption) (RelayPeerService_RelayPeerProbeRPCClient, error)
	RelayPeerSurveyRPC(ctx context.Context, opts ...grpc.CallOption) (RelayPeerService_RelayPeerSurveyRPCClient, error)
}

RelayPeerServiceClient is the client API for RelayPeerService 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 NewRelayPeerServiceClient 

func NewRelayPeerServiceClient(cc grpc.ClientConnInterface) RelayPeerServiceClient

type RelayPeerServiceServer 

type RelayPeerServiceServer interface {
	RelayPeerHelloRPC(RelayPeerService_RelayPeerHelloRPCServer) error
	RelayPeerProbeRPC(RelayPeerService_RelayPeerProbeRPCServer) error
	RelayPeerSurveyRPC(RelayPeerService_RelayPeerSurveyRPCServer) error
}

RelayPeerServiceServer is the server API for RelayPeerService service. All implementations should embed UnimplementedRelayPeerServiceServer for forward compatibility

type RelayPeerService_RelayPeerHelloRPCClient 

type RelayPeerService_RelayPeerHelloRPCClient interface {
	Send(*PeerHelloRequest) error
	Recv() (*PeerHelloResponse, error)
	grpc.ClientStream
}

type RelayPeerService_RelayPeerHelloRPCServer 

type RelayPeerService_RelayPeerHelloRPCServer interface {
	Send(*PeerHelloResponse) error
	Recv() (*PeerHelloRequest, error)
	grpc.ServerStream
}

type RelayPeerService_RelayPeerProbeRPCClient 

type RelayPeerService_RelayPeerProbeRPCClient interface {
	Send(*PeerProbeRequest) error
	Recv() (*PeerProbeResponse, error)
	grpc.ClientStream
}

type RelayPeerService_RelayPeerProbeRPCServer 

type RelayPeerService_RelayPeerProbeRPCServer interface {
	Send(*PeerProbeResponse) error
	Recv() (*PeerProbeRequest, error)
	grpc.ServerStream
}

type RelayPeerService_RelayPeerSurveyRPCClient 

type RelayPeerService_RelayPeerSurveyRPCClient interface {
	Send(*PeerSurveyResponse) error
	Recv() (*PeerSurveyRequest, error)
	grpc.ClientStream
}

type RelayPeerService_RelayPeerSurveyRPCServer 

type RelayPeerService_RelayPeerSurveyRPCServer interface {
	Send(*PeerSurveyRequest) error
	Recv() (*PeerSurveyResponse, error)
	grpc.ServerStream
}

type RevokeKubeconfigRequest 

type RevokeKubeconfigRequest struct {
	Opts *v3.QueryOptions `protobuf:"bytes,1,opt,name=opts,proto3" json:"opts,omitempty"`
	// contains filtered or unexported fields
}

func (*RevokeKubeconfigRequest) Descriptor deprecated 

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

Deprecated: Use RevokeKubeconfigRequest.ProtoReflect.Descriptor instead.

func (*RevokeKubeconfigRequest) GetOpts 

func (x *RevokeKubeconfigRequest) GetOpts() *v3.QueryOptions

func (*RevokeKubeconfigRequest) ProtoMessage 

func (*RevokeKubeconfigRequest) ProtoMessage()

func (*RevokeKubeconfigRequest) ProtoReflect 

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

func (*RevokeKubeconfigRequest) Reset 

func (x *RevokeKubeconfigRequest) Reset()

func (*RevokeKubeconfigRequest) String 

func (x *RevokeKubeconfigRequest) String() string

type RevokeKubeconfigResponse 

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

func (*RevokeKubeconfigResponse) Descriptor deprecated 

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

Deprecated: Use RevokeKubeconfigResponse.ProtoReflect.Descriptor instead.

func (*RevokeKubeconfigResponse) ProtoMessage 

func (*RevokeKubeconfigResponse) ProtoMessage()

func (*RevokeKubeconfigResponse) ProtoReflect 

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

func (*RevokeKubeconfigResponse) Reset 

func (x *RevokeKubeconfigResponse) Reset()

func (*RevokeKubeconfigResponse) String 

func (x *RevokeKubeconfigResponse) String() string

type SentryAuthorizationClient 

type SentryAuthorizationClient interface {
	Unhealthy()
	Close() error
	ClusterAuthorizationClient
	AuditInformationClient
}

SentryAuthorizationClient is the interface for accessing all the RPCs exposed by Paralus Sentry for Authorization

type SentryAuthorizationPool 

type SentryAuthorizationPool interface {
	Close()
	NewClient(ctx context.Context) (SentryAuthorizationClient, error)
}

SentryAuthorizationPool maintains pool of grpc connections to sentry authorization service

func NewSentryAuthorizationPool 

func NewSentryAuthorizationPool(opts ...Option) (SentryAuthorizationPool, error)

NewSentryAuthorizationPool new sentry authorization pool

type SentryClient 

type SentryClient interface {
	Unhealthy()
	Close() error
	BootstrapClient
	ClusterAuthorizationClient
	KubeConfigClient
}

SentryClient is the interface for accessing all the RPCs exposed by Paralus Sentry

type SentryPool 

type SentryPool interface {
	Close()
	NewClient(ctx context.Context) (SentryClient, error)
}

SentryPool maintains pool of grpc connections to sentry service

func NewSentryPool 

func NewSentryPool(addr string, maxConn int) SentryPool

NewSentryPool new sentry pool

type UnimplementedAuditInformationServer 

type UnimplementedAuditInformationServer struct {
}

UnimplementedAuditInformationServer should be embedded to have forward compatible implementations.

func (UnimplementedAuditInformationServer) LookupCluster 

func (UnimplementedAuditInformationServer) LookupCluster(context.Context, *LookupClusterRequest) (*LookupClusterResponse, error)

func (UnimplementedAuditInformationServer) LookupUser 

func (UnimplementedAuditInformationServer) LookupUser(context.Context, *LookupUserRequest) (*LookupUserResponse, error)

type UnimplementedBootstrapServer 

type UnimplementedBootstrapServer struct {
}

UnimplementedBootstrapServer should be embedded to have forward compatible implementations.

func (UnimplementedBootstrapServer) CreateBootstrapAgent 

func (UnimplementedBootstrapServer) CreateBootstrapAgent(context.Context, *sentry.BootstrapAgent) (*sentry.BootstrapAgent, error)

func (UnimplementedBootstrapServer) DeleteBootstrapAgent 

func (UnimplementedBootstrapServer) DeleteBootstrapAgent(context.Context, *sentry.BootstrapAgent) (*DeleteBootstrapAgentResponse, error)

func (UnimplementedBootstrapServer) GetBootstrapAgent 

func (UnimplementedBootstrapServer) GetBootstrapAgent(context.Context, *sentry.BootstrapAgent) (*sentry.BootstrapAgent, error)

func (UnimplementedBootstrapServer) GetBootstrapAgentConfig 

func (UnimplementedBootstrapServer) GetBootstrapAgentConfig(context.Context, *sentry.BootstrapAgent) (*v3.HttpBody, error)

func (UnimplementedBootstrapServer) GetBootstrapAgentTemplate 

func (UnimplementedBootstrapServer) GetBootstrapAgentTemplate(context.Context, *sentry.BootstrapAgentTemplate) (*sentry.BootstrapAgentTemplate, error)

func (UnimplementedBootstrapServer) GetBootstrapAgentTemplates 

func (UnimplementedBootstrapServer) GetBootstrapAgentTemplates(context.Context, *v3.QueryOptions) (*sentry.BootstrapAgentTemplateList, error)

func (UnimplementedBootstrapServer) GetBootstrapAgents 

func (UnimplementedBootstrapServer) GetBootstrapAgents(context.Context, *GetBootstrapAgentsRequest) (*sentry.BootstrapAgentList, error)

func (UnimplementedBootstrapServer) GetBootstrapInfra 

func (UnimplementedBootstrapServer) GetBootstrapInfra(context.Context, *sentry.BootstrapInfra) (*sentry.BootstrapInfra, error)

func (UnimplementedBootstrapServer) PatchBootstrapAgentTemplate 

func (UnimplementedBootstrapServer) PatchBootstrapAgentTemplate(context.Context, *sentry.BootstrapAgentTemplate) (*sentry.BootstrapAgentTemplate, error)

func (UnimplementedBootstrapServer) PatchBootstrapInfra 

func (UnimplementedBootstrapServer) PatchBootstrapInfra(context.Context, *sentry.BootstrapInfra) (*sentry.BootstrapInfra, error)

func (UnimplementedBootstrapServer) RegisterBootstrapAgent 

func (UnimplementedBootstrapServer) RegisterBootstrapAgent(context.Context, *RegisterAgentRequest) (*RegisterAgentResponse, error)

func (UnimplementedBootstrapServer) UpdateBootstrapAgent 

func (UnimplementedBootstrapServer) UpdateBootstrapAgent(context.Context, *sentry.BootstrapAgent) (*sentry.BootstrapAgent, error)

type UnimplementedClusterAuthorizationServer 

type UnimplementedClusterAuthorizationServer struct {
}

UnimplementedClusterAuthorizationServer should be embedded to have forward compatible implementations.

func (UnimplementedClusterAuthorizationServer) GetUserAuthorization 

func (UnimplementedClusterAuthorizationServer) GetUserAuthorization(context.Context, *GetUserAuthorizationRequest) (*GetUserAuthorizationResponse, error)

type UnimplementedKubeConfigServer 

type UnimplementedKubeConfigServer struct {
}

UnimplementedKubeConfigServer should be embedded to have forward compatible implementations.

func (UnimplementedKubeConfigServer) GetForClusterSystemSession 

func (UnimplementedKubeConfigServer) GetForClusterSystemSession(context.Context, *GetForClusterRequest) (*v3.HttpBody, error)

func (UnimplementedKubeConfigServer) GetForClusterWebSession 

func (UnimplementedKubeConfigServer) GetForClusterWebSession(context.Context, *GetForClusterRequest) (*v3.HttpBody, error)

func (UnimplementedKubeConfigServer) GetForUser 

func (UnimplementedKubeConfigServer) GetForUser(context.Context, *GetForUserRequest) (*v3.HttpBody, error)

func (UnimplementedKubeConfigServer) GetOrganizationSetting 

func (UnimplementedKubeConfigServer) GetOrganizationSetting(context.Context, *GetKubeconfigSettingRequest) (*GetKubeconfigSettingResponse, error)

func (UnimplementedKubeConfigServer) GetSSOUserSetting 

func (UnimplementedKubeConfigServer) GetSSOUserSetting(context.Context, *GetKubeconfigSettingRequest) (*GetKubeconfigSettingResponse, error)

func (UnimplementedKubeConfigServer) GetUserSetting 

func (UnimplementedKubeConfigServer) GetUserSetting(context.Context, *GetKubeconfigSettingRequest) (*GetKubeconfigSettingResponse, error)

func (UnimplementedKubeConfigServer) RevokeKubeconfig 

func (UnimplementedKubeConfigServer) RevokeKubeconfig(context.Context, *RevokeKubeconfigRequest) (*RevokeKubeconfigResponse, error)

func (UnimplementedKubeConfigServer) UpdateOrganizationSetting 

func (UnimplementedKubeConfigServer) UpdateOrganizationSetting(context.Context, *UpdateKubeconfigSettingRequest) (*UpdateKubeconfigSettingResponse, error)

func (UnimplementedKubeConfigServer) UpdateSSOUserSetting 

func (UnimplementedKubeConfigServer) UpdateSSOUserSetting(context.Context, *UpdateKubeconfigSettingRequest) (*UpdateKubeconfigSettingResponse, error)

func (UnimplementedKubeConfigServer) UpdateUserSetting 

func (UnimplementedKubeConfigServer) UpdateUserSetting(context.Context, *UpdateKubeconfigSettingRequest) (*UpdateKubeconfigSettingResponse, error)

type UnimplementedKubectlClusterSettingsServer 

type UnimplementedKubectlClusterSettingsServer struct {
}

UnimplementedKubectlClusterSettingsServer should be embedded to have forward compatible implementations.

func (UnimplementedKubectlClusterSettingsServer) GetKubectlClusterSettings 

func (UnimplementedKubectlClusterSettingsServer) GetKubectlClusterSettings(context.Context, *GetKubectlClusterSettingsRequest) (*GetKubectlClusterSettingsResponse, error)

func (UnimplementedKubectlClusterSettingsServer) UpdateKubectlClusterSettings 

func (UnimplementedKubectlClusterSettingsServer) UpdateKubectlClusterSettings(context.Context, *UpdateKubectlClusterSettingsRequest) (*UpdateKubectlClusterSettingsResponse, error)

type UnimplementedRelayPeerServiceServer 

type UnimplementedRelayPeerServiceServer struct {
}

UnimplementedRelayPeerServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedRelayPeerServiceServer) RelayPeerHelloRPC 

func (UnimplementedRelayPeerServiceServer) RelayPeerHelloRPC(RelayPeerService_RelayPeerHelloRPCServer) error

func (UnimplementedRelayPeerServiceServer) RelayPeerProbeRPC 

func (UnimplementedRelayPeerServiceServer) RelayPeerProbeRPC(RelayPeerService_RelayPeerProbeRPCServer) error

func (UnimplementedRelayPeerServiceServer) RelayPeerSurveyRPC 

func (UnimplementedRelayPeerServiceServer) RelayPeerSurveyRPC(RelayPeerService_RelayPeerSurveyRPCServer) error

type UnsafeAuditInformationServer 

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

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

type UnsafeBootstrapServer 

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

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

type UnsafeClusterAuthorizationServer 

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

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

type UnsafeKubeConfigServer 

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

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

type UnsafeKubectlClusterSettingsServer 

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

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

type UnsafeRelayPeerServiceServer 

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

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

type UpdateKubeconfigSettingRequest 

type UpdateKubeconfigSettingRequest struct {
	Opts                        *v3.QueryOptions `protobuf:"bytes,1,opt,name=opts,proto3" json:"opts,omitempty"`
	ValiditySeconds             int64            `protobuf:"varint,2,opt,name=validitySeconds,proto3" json:"validitySeconds,omitempty"`
	EnableSessionCheck          bool             `protobuf:"varint,3,opt,name=enableSessionCheck,proto3" json:"enableSessionCheck,omitempty"`
	EnablePrivateRelay          bool             `protobuf:"varint,4,opt,name=enablePrivateRelay,proto3" json:"enablePrivateRelay,omitempty"`
	EnforceOrgAdminSecretAccess bool             `protobuf:"varint,5,opt,name=enforceOrgAdminSecretAccess,proto3" json:"enforceOrgAdminSecretAccess,omitempty"`
	DisableWebKubectl           bool             `protobuf:"varint,6,opt,name=disableWebKubectl,proto3" json:"disableWebKubectl,omitempty"`
	DisableCLIKubectl           bool             `protobuf:"varint,7,opt,name=disableCLIKubectl,proto3" json:"disableCLIKubectl,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateKubeconfigSettingRequest) Descriptor deprecated 

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

Deprecated: Use UpdateKubeconfigSettingRequest.ProtoReflect.Descriptor instead.

func (*UpdateKubeconfigSettingRequest) GetDisableCLIKubectl 

func (x *UpdateKubeconfigSettingRequest) GetDisableCLIKubectl() bool

func (*UpdateKubeconfigSettingRequest) GetDisableWebKubectl 

func (x *UpdateKubeconfigSettingRequest) GetDisableWebKubectl() bool

func (*UpdateKubeconfigSettingRequest) GetEnablePrivateRelay 

func (x *UpdateKubeconfigSettingRequest) GetEnablePrivateRelay() bool

func (*UpdateKubeconfigSettingRequest) GetEnableSessionCheck 

func (x *UpdateKubeconfigSettingRequest) GetEnableSessionCheck() bool

func (*UpdateKubeconfigSettingRequest) GetEnforceOrgAdminSecretAccess 

func (x *UpdateKubeconfigSettingRequest) GetEnforceOrgAdminSecretAccess() bool

func (*UpdateKubeconfigSettingRequest) GetOpts 

func (x *UpdateKubeconfigSettingRequest) GetOpts() *v3.QueryOptions

func (*UpdateKubeconfigSettingRequest) GetValiditySeconds 

func (x *UpdateKubeconfigSettingRequest) GetValiditySeconds() int64

func (*UpdateKubeconfigSettingRequest) ProtoMessage 

func (*UpdateKubeconfigSettingRequest) ProtoMessage()

func (*UpdateKubeconfigSettingRequest) ProtoReflect 

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

func (*UpdateKubeconfigSettingRequest) Reset 

func (x *UpdateKubeconfigSettingRequest) Reset()

func (*UpdateKubeconfigSettingRequest) String 

func (x *UpdateKubeconfigSettingRequest) String() string

type UpdateKubeconfigSettingResponse 

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

func (*UpdateKubeconfigSettingResponse) Descriptor deprecated 

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

Deprecated: Use UpdateKubeconfigSettingResponse.ProtoReflect.Descriptor instead.

func (*UpdateKubeconfigSettingResponse) ProtoMessage 

func (*UpdateKubeconfigSettingResponse) ProtoMessage()

func (*UpdateKubeconfigSettingResponse) ProtoReflect 

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

func (*UpdateKubeconfigSettingResponse) Reset 

func (x *UpdateKubeconfigSettingResponse) Reset()

func (*UpdateKubeconfigSettingResponse) String 

func (x *UpdateKubeconfigSettingResponse) String() string

type UpdateKubectlClusterSettingsRequest 

type UpdateKubectlClusterSettingsRequest struct {
	Opts              *v3.QueryOptions `protobuf:"bytes,1,opt,name=opts,proto3" json:"opts,omitempty"`
	DisableWebKubectl bool             `protobuf:"varint,2,opt,name=disableWebKubectl,proto3" json:"disableWebKubectl,omitempty"`
	DisableCLIKubectl bool             `protobuf:"varint,3,opt,name=disableCLIKubectl,proto3" json:"disableCLIKubectl,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateKubectlClusterSettingsRequest) Descriptor deprecated 

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

Deprecated: Use UpdateKubectlClusterSettingsRequest.ProtoReflect.Descriptor instead.

func (*UpdateKubectlClusterSettingsRequest) GetDisableCLIKubectl 

func (x *UpdateKubectlClusterSettingsRequest) GetDisableCLIKubectl() bool

func (*UpdateKubectlClusterSettingsRequest) GetDisableWebKubectl 

func (x *UpdateKubectlClusterSettingsRequest) GetDisableWebKubectl() bool

func (*UpdateKubectlClusterSettingsRequest) GetOpts 

func (x *UpdateKubectlClusterSettingsRequest) GetOpts() *v3.QueryOptions

func (*UpdateKubectlClusterSettingsRequest) ProtoMessage 

func (*UpdateKubectlClusterSettingsRequest) ProtoMessage()

func (*UpdateKubectlClusterSettingsRequest) ProtoReflect 

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

func (*UpdateKubectlClusterSettingsRequest) Reset 

func (x *UpdateKubectlClusterSettingsRequest) Reset()

func (*UpdateKubectlClusterSettingsRequest) String 

func (x *UpdateKubectlClusterSettingsRequest) String() string

type UpdateKubectlClusterSettingsResponse 

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

func (*UpdateKubectlClusterSettingsResponse) Descriptor deprecated 

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

Deprecated: Use UpdateKubectlClusterSettingsResponse.ProtoReflect.Descriptor instead.

func (*UpdateKubectlClusterSettingsResponse) ProtoMessage 

func (*UpdateKubectlClusterSettingsResponse) ProtoMessage()

func (*UpdateKubectlClusterSettingsResponse) ProtoReflect 

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

func (*UpdateKubectlClusterSettingsResponse) Reset 

func (x *UpdateKubectlClusterSettingsResponse) Reset()

func (*UpdateKubectlClusterSettingsResponse) String 

func (x *UpdateKubectlClusterSettingsResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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