sentry

package
v0.2.8 Latest Latest
Warning

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

Go to latest
Published: Jun 14, 2024 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

View Source
const (
	AuditInformationService_LookupUser_FullMethodName    = "/paralus.dev.sentry.rpc.AuditInformationService/LookupUser"
	AuditInformationService_LookupCluster_FullMethodName = "/paralus.dev.sentry.rpc.AuditInformationService/LookupCluster"
)
View Source
const (
	BootstrapService_PatchBootstrapInfra_FullMethodName         = "/paralus.dev.sentry.rpc.BootstrapService/PatchBootstrapInfra"
	BootstrapService_GetBootstrapInfra_FullMethodName           = "/paralus.dev.sentry.rpc.BootstrapService/GetBootstrapInfra"
	BootstrapService_PatchBootstrapAgentTemplate_FullMethodName = "/paralus.dev.sentry.rpc.BootstrapService/PatchBootstrapAgentTemplate"
	BootstrapService_GetBootstrapAgentTemplate_FullMethodName   = "/paralus.dev.sentry.rpc.BootstrapService/GetBootstrapAgentTemplate"
	BootstrapService_GetBootstrapAgentTemplates_FullMethodName  = "/paralus.dev.sentry.rpc.BootstrapService/GetBootstrapAgentTemplates"
	BootstrapService_RegisterBootstrapAgent_FullMethodName      = "/paralus.dev.sentry.rpc.BootstrapService/RegisterBootstrapAgent"
	BootstrapService_GetBootstrapAgentConfig_FullMethodName     = "/paralus.dev.sentry.rpc.BootstrapService/GetBootstrapAgentConfig"
	BootstrapService_CreateBootstrapAgent_FullMethodName        = "/paralus.dev.sentry.rpc.BootstrapService/CreateBootstrapAgent"
	BootstrapService_GetBootstrapAgent_FullMethodName           = "/paralus.dev.sentry.rpc.BootstrapService/GetBootstrapAgent"
	BootstrapService_GetBootstrapAgents_FullMethodName          = "/paralus.dev.sentry.rpc.BootstrapService/GetBootstrapAgents"
	BootstrapService_DeleteBootstrapAgent_FullMethodName        = "/paralus.dev.sentry.rpc.BootstrapService/DeleteBootstrapAgent"
	BootstrapService_UpdateBootstrapAgent_FullMethodName        = "/paralus.dev.sentry.rpc.BootstrapService/UpdateBootstrapAgent"
)
View Source
const (
	KubeConfigService_GetForClusterWebSession_FullMethodName    = "/paralus.dev.sentry.rpc.KubeConfigService/GetForClusterWebSession"
	KubeConfigService_GetForClusterSystemSession_FullMethodName = "/paralus.dev.sentry.rpc.KubeConfigService/GetForClusterSystemSession"
	KubeConfigService_GetForUser_FullMethodName                 = "/paralus.dev.sentry.rpc.KubeConfigService/GetForUser"
	KubeConfigService_RevokeKubeconfig_FullMethodName           = "/paralus.dev.sentry.rpc.KubeConfigService/RevokeKubeconfig"
	KubeConfigService_GetOrganizationSetting_FullMethodName     = "/paralus.dev.sentry.rpc.KubeConfigService/GetOrganizationSetting"
	KubeConfigService_GetUserSetting_FullMethodName             = "/paralus.dev.sentry.rpc.KubeConfigService/GetUserSetting"
	KubeConfigService_GetSSOUserSetting_FullMethodName          = "/paralus.dev.sentry.rpc.KubeConfigService/GetSSOUserSetting"
	KubeConfigService_UpdateOrganizationSetting_FullMethodName  = "/paralus.dev.sentry.rpc.KubeConfigService/UpdateOrganizationSetting"
	KubeConfigService_UpdateUserSetting_FullMethodName          = "/paralus.dev.sentry.rpc.KubeConfigService/UpdateUserSetting"
	KubeConfigService_UpdateSSOUserSetting_FullMethodName       = "/paralus.dev.sentry.rpc.KubeConfigService/UpdateSSOUserSetting"
)
View Source
const (
	KubectlClusterSettingsService_UpdateKubectlClusterSettings_FullMethodName = "/paralus.dev.sentry.rpc.KubectlClusterSettingsService/UpdateKubectlClusterSettings"
	KubectlClusterSettingsService_GetKubectlClusterSettings_FullMethodName    = "/paralus.dev.sentry.rpc.KubectlClusterSettingsService/GetKubectlClusterSettings"
)
View Source
const (
	RelayPeerService_RelayPeerHelloRPC_FullMethodName  = "/paralus.dev.sentry.rpc.RelayPeerService/RelayPeerHelloRPC"
	RelayPeerService_RelayPeerProbeRPC_FullMethodName  = "/paralus.dev.sentry.rpc.RelayPeerService/RelayPeerProbeRPC"
	RelayPeerService_RelayPeerSurveyRPC_FullMethodName = "/paralus.dev.sentry.rpc.RelayPeerService/RelayPeerSurveyRPC"
)
View Source
const (
	ClusterAuthorizationService_GetUserAuthorization_FullMethodName = "/paralus.dev.sentry.rpc.ClusterAuthorizationService/GetUserAuthorization"
)

Variables

View Source
var AuditInformationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "paralus.dev.sentry.rpc.AuditInformationService",
	HandlerType: (*AuditInformationServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "LookupUser",
			Handler:    _AuditInformationService_LookupUser_Handler,
		},
		{
			MethodName: "LookupCluster",
			Handler:    _AuditInformationService_LookupCluster_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/rpc/sentry/audit_info.proto",
}

AuditInformationService_ServiceDesc is the grpc.ServiceDesc for AuditInformationService 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 BootstrapService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "paralus.dev.sentry.rpc.BootstrapService",
	HandlerType: (*BootstrapServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PatchBootstrapInfra",
			Handler:    _BootstrapService_PatchBootstrapInfra_Handler,
		},
		{
			MethodName: "GetBootstrapInfra",
			Handler:    _BootstrapService_GetBootstrapInfra_Handler,
		},
		{
			MethodName: "PatchBootstrapAgentTemplate",
			Handler:    _BootstrapService_PatchBootstrapAgentTemplate_Handler,
		},
		{
			MethodName: "GetBootstrapAgentTemplate",
			Handler:    _BootstrapService_GetBootstrapAgentTemplate_Handler,
		},
		{
			MethodName: "GetBootstrapAgentTemplates",
			Handler:    _BootstrapService_GetBootstrapAgentTemplates_Handler,
		},
		{
			MethodName: "RegisterBootstrapAgent",
			Handler:    _BootstrapService_RegisterBootstrapAgent_Handler,
		},
		{
			MethodName: "GetBootstrapAgentConfig",
			Handler:    _BootstrapService_GetBootstrapAgentConfig_Handler,
		},
		{
			MethodName: "CreateBootstrapAgent",
			Handler:    _BootstrapService_CreateBootstrapAgent_Handler,
		},
		{
			MethodName: "GetBootstrapAgent",
			Handler:    _BootstrapService_GetBootstrapAgent_Handler,
		},
		{
			MethodName: "GetBootstrapAgents",
			Handler:    _BootstrapService_GetBootstrapAgents_Handler,
		},
		{
			MethodName: "DeleteBootstrapAgent",
			Handler:    _BootstrapService_DeleteBootstrapAgent_Handler,
		},
		{
			MethodName: "UpdateBootstrapAgent",
			Handler:    _BootstrapService_UpdateBootstrapAgent_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/rpc/sentry/bootstrap.proto",
}

BootstrapService_ServiceDesc is the grpc.ServiceDesc for BootstrapService 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 ClusterAuthorizationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "paralus.dev.sentry.rpc.ClusterAuthorizationService",
	HandlerType: (*ClusterAuthorizationServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetUserAuthorization",
			Handler:    _ClusterAuthorizationService_GetUserAuthorization_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/rpc/sentry/cluster_authz.proto",
}

ClusterAuthorizationService_ServiceDesc is the grpc.ServiceDesc for ClusterAuthorizationService 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 KubeConfigService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "paralus.dev.sentry.rpc.KubeConfigService",
	HandlerType: (*KubeConfigServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetForClusterWebSession",
			Handler:    _KubeConfigService_GetForClusterWebSession_Handler,
		},
		{
			MethodName: "GetForClusterSystemSession",
			Handler:    _KubeConfigService_GetForClusterSystemSession_Handler,
		},
		{
			MethodName: "GetForUser",
			Handler:    _KubeConfigService_GetForUser_Handler,
		},
		{
			MethodName: "RevokeKubeconfig",
			Handler:    _KubeConfigService_RevokeKubeconfig_Handler,
		},
		{
			MethodName: "GetOrganizationSetting",
			Handler:    _KubeConfigService_GetOrganizationSetting_Handler,
		},
		{
			MethodName: "GetUserSetting",
			Handler:    _KubeConfigService_GetUserSetting_Handler,
		},
		{
			MethodName: "GetSSOUserSetting",
			Handler:    _KubeConfigService_GetSSOUserSetting_Handler,
		},
		{
			MethodName: "UpdateOrganizationSetting",
			Handler:    _KubeConfigService_UpdateOrganizationSetting_Handler,
		},
		{
			MethodName: "UpdateUserSetting",
			Handler:    _KubeConfigService_UpdateUserSetting_Handler,
		},
		{
			MethodName: "UpdateSSOUserSetting",
			Handler:    _KubeConfigService_UpdateSSOUserSetting_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/rpc/sentry/kubeconfig.proto",
}

KubeConfigService_ServiceDesc is the grpc.ServiceDesc for KubeConfigService 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 KubectlClusterSettingsService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "paralus.dev.sentry.rpc.KubectlClusterSettingsService",
	HandlerType: (*KubectlClusterSettingsServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "UpdateKubectlClusterSettings",
			Handler:    _KubectlClusterSettingsService_UpdateKubectlClusterSettings_Handler,
		},
		{
			MethodName: "GetKubectlClusterSettings",
			Handler:    _KubectlClusterSettingsService_GetKubectlClusterSettings_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/rpc/sentry/kubectl_cluster.proto",
}

KubectlClusterSettingsService_ServiceDesc is the grpc.ServiceDesc for KubectlClusterSettingsService 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 RegisterAuditInformationServiceHandler added in v0.1.3

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

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

func RegisterAuditInformationServiceHandlerClient added in v0.1.3

func RegisterAuditInformationServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AuditInformationServiceClient) error

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

func RegisterAuditInformationServiceHandlerFromEndpoint added in v0.1.3

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

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

func RegisterAuditInformationServiceHandlerServer added in v0.1.3

func RegisterAuditInformationServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server AuditInformationServiceServer) error

RegisterAuditInformationServiceHandlerServer registers the http handlers for service AuditInformationService to "mux". UnaryRPC :call AuditInformationServiceServer 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 RegisterAuditInformationServiceHandlerFromEndpoint instead.

func RegisterAuditInformationServiceServer added in v0.1.3

func RegisterAuditInformationServiceServer(s grpc.ServiceRegistrar, srv AuditInformationServiceServer)

func RegisterBootstrapServiceHandler added in v0.1.3

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

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

func RegisterBootstrapServiceHandlerClient added in v0.1.3

func RegisterBootstrapServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client BootstrapServiceClient) error

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

func RegisterBootstrapServiceHandlerFromEndpoint added in v0.1.3

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

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

func RegisterBootstrapServiceHandlerServer added in v0.1.3

func RegisterBootstrapServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server BootstrapServiceServer) error

RegisterBootstrapServiceHandlerServer registers the http handlers for service BootstrapService to "mux". UnaryRPC :call BootstrapServiceServer 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 RegisterBootstrapServiceHandlerFromEndpoint instead.

func RegisterBootstrapServiceServer added in v0.1.3

func RegisterBootstrapServiceServer(s grpc.ServiceRegistrar, srv BootstrapServiceServer)

func RegisterClusterAuthorizationServiceHandler added in v0.1.3

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

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

func RegisterClusterAuthorizationServiceHandlerClient added in v0.1.3

func RegisterClusterAuthorizationServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ClusterAuthorizationServiceClient) error

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

func RegisterClusterAuthorizationServiceHandlerFromEndpoint added in v0.1.3

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

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

func RegisterClusterAuthorizationServiceHandlerServer added in v0.1.3

func RegisterClusterAuthorizationServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ClusterAuthorizationServiceServer) error

RegisterClusterAuthorizationServiceHandlerServer registers the http handlers for service ClusterAuthorizationService to "mux". UnaryRPC :call ClusterAuthorizationServiceServer 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 RegisterClusterAuthorizationServiceHandlerFromEndpoint instead.

func RegisterClusterAuthorizationServiceServer added in v0.1.3

func RegisterClusterAuthorizationServiceServer(s grpc.ServiceRegistrar, srv ClusterAuthorizationServiceServer)

func RegisterKubeConfigServiceHandler added in v0.1.3

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

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

func RegisterKubeConfigServiceHandlerClient added in v0.1.3

func RegisterKubeConfigServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client KubeConfigServiceClient) error

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

func RegisterKubeConfigServiceHandlerFromEndpoint added in v0.1.3

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

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

func RegisterKubeConfigServiceHandlerServer added in v0.1.3

func RegisterKubeConfigServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server KubeConfigServiceServer) error

RegisterKubeConfigServiceHandlerServer registers the http handlers for service KubeConfigService to "mux". UnaryRPC :call KubeConfigServiceServer 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 RegisterKubeConfigServiceHandlerFromEndpoint instead.

func RegisterKubeConfigServiceServer added in v0.1.3

func RegisterKubeConfigServiceServer(s grpc.ServiceRegistrar, srv KubeConfigServiceServer)

func RegisterKubectlClusterSettingsServiceHandler added in v0.1.3

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

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

func RegisterKubectlClusterSettingsServiceHandlerClient added in v0.1.3

func RegisterKubectlClusterSettingsServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client KubectlClusterSettingsServiceClient) error

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

func RegisterKubectlClusterSettingsServiceHandlerFromEndpoint added in v0.1.3

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

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

func RegisterKubectlClusterSettingsServiceHandlerServer added in v0.1.3

func RegisterKubectlClusterSettingsServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server KubectlClusterSettingsServiceServer) error

RegisterKubectlClusterSettingsServiceHandlerServer registers the http handlers for service KubectlClusterSettingsService to "mux". UnaryRPC :call KubectlClusterSettingsServiceServer 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 RegisterKubectlClusterSettingsServiceHandlerFromEndpoint instead.

func RegisterKubectlClusterSettingsServiceServer added in v0.1.3

func RegisterKubectlClusterSettingsServiceServer(s grpc.ServiceRegistrar, srv KubectlClusterSettingsServiceServer)

func RegisterRelayPeerServiceServer

func RegisterRelayPeerServiceServer(s grpc.ServiceRegistrar, srv RelayPeerServiceServer)

Types

type AuditInformationServiceClient added in v0.1.3

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

AuditInformationServiceClient is the client API for AuditInformationService 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 NewAuditInformationServiceClient added in v0.1.3

func NewAuditInformationServiceClient(cc grpc.ClientConnInterface) AuditInformationServiceClient

type AuditInformationServiceServer added in v0.1.3

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

AuditInformationServiceServer is the server API for AuditInformationService service. All implementations should embed UnimplementedAuditInformationServiceServer for forward compatibility

type BootstrapServiceClient added in v0.1.3

type BootstrapServiceClient 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)
}

BootstrapServiceClient is the client API for BootstrapService 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 NewBootstrapServiceClient added in v0.1.3

func NewBootstrapServiceClient(cc grpc.ClientConnInterface) BootstrapServiceClient

type BootstrapServiceServer added in v0.1.3

BootstrapServiceServer is the server API for BootstrapService service. All implementations should embed UnimplementedBootstrapServiceServer for forward compatibility

type ClusterAuthorizationServiceClient added in v0.1.3

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

ClusterAuthorizationServiceClient is the client API for ClusterAuthorizationService 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 NewClusterAuthorizationServiceClient added in v0.1.3

func NewClusterAuthorizationServiceClient(cc grpc.ClientConnInterface) ClusterAuthorizationServiceClient

type ClusterAuthorizationServiceServer added in v0.1.3

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

ClusterAuthorizationServiceServer is the server API for ClusterAuthorizationService service. All implementations should embed UnimplementedClusterAuthorizationServiceServer 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 (*DeleteBootstrapAgentResponse) Reset

func (x *DeleteBootstrapAgentResponse) Reset()

func (*DeleteBootstrapAgentResponse) 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 (*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 (*GetBootstrapAgentsRequest) GetTemplateScope

func (x *GetBootstrapAgentsRequest) GetTemplateScope() string

func (*GetBootstrapAgentsRequest) ProtoMessage

func (*GetBootstrapAgentsRequest) ProtoMessage()

func (*GetBootstrapAgentsRequest) ProtoReflect

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 (*GetKubeconfigSettingRequest) ProtoMessage

func (*GetKubeconfigSettingRequest) ProtoMessage()

func (*GetKubeconfigSettingRequest) ProtoReflect

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"`
	SaValiditySeconds           int64 `protobuf:"varint,2,opt,name=saValiditySeconds,proto3" json:"saValiditySeconds,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 (*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) GetSaValiditySeconds added in v0.2.1

func (x *GetKubeconfigSettingResponse) GetSaValiditySeconds() int64

func (*GetKubeconfigSettingResponse) GetValiditySeconds

func (x *GetKubeconfigSettingResponse) GetValiditySeconds() int64

func (*GetKubeconfigSettingResponse) ProtoMessage

func (*GetKubeconfigSettingResponse) ProtoMessage()

func (*GetKubeconfigSettingResponse) ProtoReflect

func (*GetKubeconfigSettingResponse) Reset

func (x *GetKubeconfigSettingResponse) Reset()

func (*GetKubeconfigSettingResponse) 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 (*GetKubectlClusterSettingsRequest) ProtoMessage

func (*GetKubectlClusterSettingsRequest) ProtoMessage()

func (*GetKubectlClusterSettingsRequest) ProtoReflect

func (*GetKubectlClusterSettingsRequest) Reset

func (*GetKubectlClusterSettingsRequest) 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 (*GetKubectlClusterSettingsResponse) Reset

func (*GetKubectlClusterSettingsResponse) 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 (*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 (*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 (*GetUserAuthorizationResponse) Reset

func (x *GetUserAuthorizationResponse) Reset()

func (*GetUserAuthorizationResponse) String

type KubeConfigServiceClient added in v0.1.3

type KubeConfigServiceClient 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)
}

KubeConfigServiceClient is the client API for KubeConfigService 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 NewKubeConfigServiceClient added in v0.1.3

func NewKubeConfigServiceClient(cc grpc.ClientConnInterface) KubeConfigServiceClient

type KubeConfigServiceServer added in v0.1.3

KubeConfigServiceServer is the server API for KubeConfigService service. All implementations should embed UnimplementedKubeConfigServiceServer for forward compatibility

type KubectlClusterSettingsServiceClient added in v0.1.3

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

KubectlClusterSettingsServiceClient is the client API for KubectlClusterSettingsService 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 NewKubectlClusterSettingsServiceClient added in v0.1.3

func NewKubectlClusterSettingsServiceClient(cc grpc.ClientConnInterface) KubectlClusterSettingsServiceClient

type KubectlClusterSettingsServiceServer added in v0.1.3

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

KubectlClusterSettingsServiceServer is the server API for KubectlClusterSettingsService service. All implementations should embed UnimplementedKubectlClusterSettingsServiceServer 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"`
	Project     string `protobuf:"bytes,3,opt,name=project,proto3" json:"project,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) GetProject added in v0.2.5

func (x *LookupClusterResponse) GetProject() 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 (*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"`
	Fingerprint   string `protobuf:"bytes,7,opt,name=fingerprint,proto3" json:"fingerprint,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) GetFingerprint added in v0.2.2

func (x *RegisterAgentRequest) GetFingerprint() string

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 (*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 (*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.

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
	ClusterAuthorizationServiceClient
	AuditInformationServiceClient
}

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
	BootstrapServiceClient
	ClusterAuthorizationServiceClient
	KubeConfigServiceClient
}

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 UnimplementedAuditInformationServiceServer added in v0.1.3

type UnimplementedAuditInformationServiceServer struct {
}

UnimplementedAuditInformationServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedAuditInformationServiceServer) LookupCluster added in v0.1.3

func (UnimplementedAuditInformationServiceServer) LookupUser added in v0.1.3

type UnimplementedBootstrapServiceServer added in v0.1.3

type UnimplementedBootstrapServiceServer struct {
}

UnimplementedBootstrapServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedBootstrapServiceServer) CreateBootstrapAgent added in v0.1.3

func (UnimplementedBootstrapServiceServer) DeleteBootstrapAgent added in v0.1.3

func (UnimplementedBootstrapServiceServer) GetBootstrapAgent added in v0.1.3

func (UnimplementedBootstrapServiceServer) GetBootstrapAgentConfig added in v0.1.3

func (UnimplementedBootstrapServiceServer) GetBootstrapAgentTemplate added in v0.1.3

func (UnimplementedBootstrapServiceServer) GetBootstrapAgentTemplates added in v0.1.3

func (UnimplementedBootstrapServiceServer) GetBootstrapAgents added in v0.1.3

func (UnimplementedBootstrapServiceServer) GetBootstrapInfra added in v0.1.3

func (UnimplementedBootstrapServiceServer) PatchBootstrapAgentTemplate added in v0.1.3

func (UnimplementedBootstrapServiceServer) PatchBootstrapInfra added in v0.1.3

func (UnimplementedBootstrapServiceServer) RegisterBootstrapAgent added in v0.1.3

func (UnimplementedBootstrapServiceServer) UpdateBootstrapAgent added in v0.1.3

type UnimplementedClusterAuthorizationServiceServer added in v0.1.3

type UnimplementedClusterAuthorizationServiceServer struct {
}

UnimplementedClusterAuthorizationServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedClusterAuthorizationServiceServer) GetUserAuthorization added in v0.1.3

type UnimplementedKubeConfigServiceServer added in v0.1.3

type UnimplementedKubeConfigServiceServer struct {
}

UnimplementedKubeConfigServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedKubeConfigServiceServer) GetForClusterSystemSession added in v0.1.3

func (UnimplementedKubeConfigServiceServer) GetForClusterWebSession added in v0.1.3

func (UnimplementedKubeConfigServiceServer) GetForUser added in v0.1.3

func (UnimplementedKubeConfigServiceServer) GetOrganizationSetting added in v0.1.3

func (UnimplementedKubeConfigServiceServer) GetSSOUserSetting added in v0.1.3

func (UnimplementedKubeConfigServiceServer) GetUserSetting added in v0.1.3

func (UnimplementedKubeConfigServiceServer) RevokeKubeconfig added in v0.1.3

func (UnimplementedKubeConfigServiceServer) UpdateOrganizationSetting added in v0.1.3

func (UnimplementedKubeConfigServiceServer) UpdateSSOUserSetting added in v0.1.3

func (UnimplementedKubeConfigServiceServer) UpdateUserSetting added in v0.1.3

type UnimplementedKubectlClusterSettingsServiceServer added in v0.1.3

type UnimplementedKubectlClusterSettingsServiceServer struct {
}

UnimplementedKubectlClusterSettingsServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedKubectlClusterSettingsServiceServer) GetKubectlClusterSettings added in v0.1.3

func (UnimplementedKubectlClusterSettingsServiceServer) UpdateKubectlClusterSettings added in v0.1.3

type UnimplementedRelayPeerServiceServer

type UnimplementedRelayPeerServiceServer struct {
}

UnimplementedRelayPeerServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedRelayPeerServiceServer) RelayPeerHelloRPC

func (UnimplementedRelayPeerServiceServer) RelayPeerProbeRPC

func (UnimplementedRelayPeerServiceServer) RelayPeerSurveyRPC

type UnsafeAuditInformationServiceServer added in v0.1.3

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

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

type UnsafeBootstrapServiceServer added in v0.1.3

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

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

type UnsafeClusterAuthorizationServiceServer added in v0.1.3

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

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

type UnsafeKubeConfigServiceServer added in v0.1.3

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

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

type UnsafeKubectlClusterSettingsServiceServer added in v0.1.3

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

UnsafeKubectlClusterSettingsServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to KubectlClusterSettingsServiceServer 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"`
	SaValiditySeconds           int64            `protobuf:"varint,3,opt,name=saValiditySeconds,proto3" json:"saValiditySeconds,omitempty"`
	EnableSessionCheck          bool             `protobuf:"varint,4,opt,name=enableSessionCheck,proto3" json:"enableSessionCheck,omitempty"`
	EnablePrivateRelay          bool             `protobuf:"varint,5,opt,name=enablePrivateRelay,proto3" json:"enablePrivateRelay,omitempty"`
	EnforceOrgAdminSecretAccess bool             `protobuf:"varint,6,opt,name=enforceOrgAdminSecretAccess,proto3" json:"enforceOrgAdminSecretAccess,omitempty"`
	DisableWebKubectl           bool             `protobuf:"varint,7,opt,name=disableWebKubectl,proto3" json:"disableWebKubectl,omitempty"`
	DisableCLIKubectl           bool             `protobuf:"varint,8,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 (*UpdateKubeconfigSettingRequest) GetSaValiditySeconds added in v0.2.1

func (x *UpdateKubeconfigSettingRequest) GetSaValiditySeconds() int64

func (*UpdateKubeconfigSettingRequest) GetValiditySeconds

func (x *UpdateKubeconfigSettingRequest) GetValiditySeconds() int64

func (*UpdateKubeconfigSettingRequest) ProtoMessage

func (*UpdateKubeconfigSettingRequest) ProtoMessage()

func (*UpdateKubeconfigSettingRequest) ProtoReflect

func (*UpdateKubeconfigSettingRequest) Reset

func (x *UpdateKubeconfigSettingRequest) Reset()

func (*UpdateKubeconfigSettingRequest) 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 (*UpdateKubeconfigSettingResponse) Reset

func (*UpdateKubeconfigSettingResponse) 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 (*UpdateKubectlClusterSettingsRequest) ProtoMessage

func (*UpdateKubectlClusterSettingsRequest) ProtoMessage()

func (*UpdateKubectlClusterSettingsRequest) ProtoReflect

func (*UpdateKubectlClusterSettingsRequest) Reset

func (*UpdateKubectlClusterSettingsRequest) 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 (*UpdateKubectlClusterSettingsResponse) Reset

func (*UpdateKubectlClusterSettingsResponse) String

Jump to

Keyboard shortcuts

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