admin

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Sep 27, 2022 License: Apache-2.0 Imports: 39 Imported by: 0

Documentation

Overview

Package admin provides an Admin server for Kong Control-plane.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ListOptsFromReq 

func ListOptsFromReq(listOpts *pbModel.PaginationRequest) ([]store.ListOptsFunc, error)

ListOptsFromReq validates & transforms a Protobuf pagination request message to a list of persistence store options. When a nil Protobuf pagination request is passed in, an empty slice of persistence store options and no error is returned.

func NewHandler 

func NewHandler(opts HandlerOpts) (http.Handler, error)

func RegisterAdminService 

func RegisterAdminService(server *grpc.Server, opts HandlerOpts)

Types

type CACertificateService 

type CACertificateService struct {
	v1.UnimplementedCACertificateServiceServer
	CommonOpts
}

func (*CACertificateService) CreateCACertificate 

func (s *CACertificateService) CreateCACertificate(ctx context.Context,
	req *v1.CreateCACertificateRequest,
) (*v1.CreateCACertificateResponse, error)

func (*CACertificateService) DeleteCACertificate 

func (s *CACertificateService) DeleteCACertificate(ctx context.Context,
	req *v1.DeleteCACertificateRequest,
) (*v1.DeleteCACertificateResponse, error)

func (*CACertificateService) GetCACertificate 

func (s *CACertificateService) GetCACertificate(ctx context.Context,
	req *v1.GetCACertificateRequest,
) (*v1.GetCACertificateResponse, error)

func (*CACertificateService) ListCACertificates 

func (s *CACertificateService) ListCACertificates(ctx context.Context,
	req *v1.ListCACertificatesRequest,
) (*v1.ListCACertificatesResponse, error)

func (*CACertificateService) UpsertCACertificate 

func (s *CACertificateService) UpsertCACertificate(ctx context.Context,
	req *v1.UpsertCACertificateRequest,
) (*v1.UpsertCACertificateResponse, error)

type CertificateService 

type CertificateService struct {
	v1.UnimplementedCertificateServiceServer
	CommonOpts
}

func (*CertificateService) CreateCertificate 

func (s *CertificateService) CreateCertificate(ctx context.Context,
	req *v1.CreateCertificateRequest,
) (*v1.CreateCertificateResponse, error)

func (*CertificateService) DeleteCertificate 

func (s *CertificateService) DeleteCertificate(ctx context.Context,
	req *v1.DeleteCertificateRequest,
) (*v1.DeleteCertificateResponse, error)

func (*CertificateService) GetCertificate 

func (s *CertificateService) GetCertificate(ctx context.Context,
	req *v1.GetCertificateRequest,
) (*v1.GetCertificateResponse, error)

func (*CertificateService) ListCertificates 

func (s *CertificateService) ListCertificates(ctx context.Context,
	req *v1.ListCertificatesRequest,
) (*v1.ListCertificatesResponse, error)

func (*CertificateService) UpsertCertificate 

func (s *CertificateService) UpsertCertificate(ctx context.Context,
	req *v1.UpsertCertificateRequest,
) (*v1.UpsertCertificateResponse, error)

type CommonOpts 

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

type ConsumerService 

type ConsumerService struct {
	v1.UnimplementedConsumerServiceServer
	CommonOpts
}

func (*ConsumerService) CreateConsumer 

func (s *ConsumerService) CreateConsumer(ctx context.Context,
	req *v1.CreateConsumerRequest,
) (*v1.CreateConsumerResponse, error)

func (*ConsumerService) DeleteConsumer 

func (s *ConsumerService) DeleteConsumer(ctx context.Context,
	req *v1.DeleteConsumerRequest,
) (*v1.DeleteConsumerResponse, error)

func (*ConsumerService) GetConsumer 

func (s *ConsumerService) GetConsumer(ctx context.Context,
	req *v1.GetConsumerRequest,
) (*v1.GetConsumerResponse, error)

func (*ConsumerService) ListConsumers 

func (s *ConsumerService) ListConsumers(ctx context.Context,
	req *v1.ListConsumersRequest,
) (*v1.ListConsumersResponse, error)

func (*ConsumerService) UpsertConsumer 

func (s *ConsumerService) UpsertConsumer(ctx context.Context,
	req *v1.UpsertConsumerRequest,
) (*v1.UpsertConsumerResponse, error)

type ContextKey 

type ContextKey struct{}

ContextKey type must be used to manipulate the context of a request.

type HandlerOpts 

type HandlerOpts struct {
	Logger *zap.Logger

	StoreLoader util.StoreLoader

	Validator plugin.Validator
}

type HandlerWrapper 

type HandlerWrapper interface {
	Wrap(http.Handler) http.Handler
	server.GrpcInterceptorInjector
}

HandlerWrapper is used to wrap a http.Handler with another http.Handler.

type MetaService 

type MetaService struct {
	v1.UnimplementedMetaServiceServer
	Logger *zap.Logger
}

func (*MetaService) GetVersion 

func (m *MetaService) GetVersion(_ context.Context,
	_ *v1.GetVersionRequest,
) (*v1.GetVersionResponse, error)

type NodeService 

type NodeService struct {
	v1.UnimplementedNodeServiceServer
	CommonOpts
}

func (*NodeService) CreateNode 

func (s *NodeService) CreateNode(ctx context.Context,
	req *v1.CreateNodeRequest,
) (*v1.CreateNodeResponse, error)

func (*NodeService) DeleteNode 

func (s *NodeService) DeleteNode(ctx context.Context,
	req *v1.DeleteNodeRequest,
) (*v1.DeleteNodeResponse, error)

func (*NodeService) GetNode 

func (s *NodeService) GetNode(ctx context.Context,
	req *v1.GetNodeRequest,
) (*v1.GetNodeResponse, error)

func (*NodeService) ListNodes 

func (s *NodeService) ListNodes(ctx context.Context,
	req *v1.ListNodesRequest,
) (*v1.ListNodesResponse, error)

func (*NodeService) UpsertNode 

func (s *NodeService) UpsertNode(ctx context.Context,
	req *v1.UpsertNodeRequest,
) (*v1.UpsertNodeResponse, error)

type PluginSchemaService 

type PluginSchemaService struct {
	v1.UnimplementedPluginSchemaServiceServer
	CommonOpts
	// contains filtered or unexported fields
}

func (*PluginSchemaService) CreateLuaPluginSchema 

func (s *PluginSchemaService) CreateLuaPluginSchema(ctx context.Context,
	req *v1.CreateLuaPluginSchemaRequest,
) (*v1.CreateLuaPluginSchemaResponse, error)

func (*PluginSchemaService) DeleteLuaPluginSchema 

func (s *PluginSchemaService) DeleteLuaPluginSchema(ctx context.Context,
	req *v1.DeleteLuaPluginSchemaRequest,
) (*v1.DeleteLuaPluginSchemaResponse, error)

func (*PluginSchemaService) GetLuaPluginSchema 

func (s *PluginSchemaService) GetLuaPluginSchema(ctx context.Context,
	req *v1.GetLuaPluginSchemaRequest,
) (*v1.GetLuaPluginSchemaResponse, error)

func (*PluginSchemaService) ListLuaPluginSchemas 

func (s *PluginSchemaService) ListLuaPluginSchemas(ctx context.Context,
	req *v1.ListLuaPluginSchemasRequest,
) (*v1.ListLuaPluginSchemasResponse, error)

func (*PluginSchemaService) UpsertLuaPluginSchema 

func (s *PluginSchemaService) UpsertLuaPluginSchema(ctx context.Context,
	req *v1.UpsertLuaPluginSchemaRequest,
) (*v1.UpsertLuaPluginSchemaResponse, error)

type PluginService 

type PluginService struct {
	v1.UnimplementedPluginServiceServer
	CommonOpts
	// contains filtered or unexported fields
}

func (*PluginService) CreatePlugin 

func (s *PluginService) CreatePlugin(ctx context.Context,
	req *v1.CreatePluginRequest,
) (*v1.CreatePluginResponse, error)

func (*PluginService) DeletePlugin 

func (s *PluginService) DeletePlugin(ctx context.Context,
	req *v1.DeletePluginRequest,
) (*v1.DeletePluginResponse, error)

func (*PluginService) GetAvailablePlugins 

func (s *PluginService) GetAvailablePlugins(
	ctx context.Context,
	req *v1.GetAvailablePluginsRequest,
) (*v1.GetAvailablePluginsResponse, error)

func (*PluginService) GetConfiguredPlugins 

func (s *PluginService) GetConfiguredPlugins(ctx context.Context,
	req *v1.GetConfiguredPluginsRequest,
) (*v1.GetConfiguredPluginsResponse, error)

func (*PluginService) GetPlugin 

func (s *PluginService) GetPlugin(ctx context.Context,
	req *v1.GetPluginRequest,
) (*v1.GetPluginResponse, error)

func (*PluginService) ListPlugins 

func (s *PluginService) ListPlugins(ctx context.Context,
	req *v1.ListPluginsRequest,
) (*v1.ListPluginsResponse, error)

func (*PluginService) UpsertPlugin 

func (s *PluginService) UpsertPlugin(ctx context.Context,
	req *v1.UpsertPluginRequest,
) (*v1.UpsertPluginResponse, error)

type RouteService 

type RouteService struct {
	v1.UnimplementedRouteServiceServer
	CommonOpts
}

func (*RouteService) CreateRoute 

func (s *RouteService) CreateRoute(ctx context.Context,
	req *v1.CreateRouteRequest,
) (*v1.CreateRouteResponse, error)

func (*RouteService) DeleteRoute 

func (s *RouteService) DeleteRoute(ctx context.Context,
	req *v1.DeleteRouteRequest,
) (*v1.DeleteRouteResponse, error)

func (*RouteService) GetRoute 

func (s *RouteService) GetRoute(ctx context.Context,
	req *v1.GetRouteRequest,
) (*v1.GetRouteResponse, error)

func (*RouteService) ListRoutes 

func (s *RouteService) ListRoutes(ctx context.Context,
	req *v1.ListRoutesRequest,
) (*v1.ListRoutesResponse, error)

func (*RouteService) UpsertRoute 

func (s *RouteService) UpsertRoute(ctx context.Context,
	req *v1.UpsertRouteRequest,
) (*v1.UpsertRouteResponse, error)

type SNIService 

type SNIService struct {
	v1.UnimplementedSNIServiceServer
	CommonOpts
}

func (*SNIService) CreateSNI 

func (s *SNIService) CreateSNI(ctx context.Context, req *v1.CreateSNIRequest) (*v1.CreateSNIResponse, error)

func (*SNIService) DeleteSNI 

func (s *SNIService) DeleteSNI(ctx context.Context, req *v1.DeleteSNIRequest) (*v1.DeleteSNIResponse, error)

func (*SNIService) GetSNI 

func (s *SNIService) GetSNI(ctx context.Context, req *v1.GetSNIRequest) (*v1.GetSNIResponse, error)

func (*SNIService) ListSNIs 

func (s *SNIService) ListSNIs(ctx context.Context, req *v1.ListSNIsRequest) (*v1.ListSNIsResponse, error)

func (*SNIService) UpsertSNI 

func (s *SNIService) UpsertSNI(ctx context.Context, req *v1.UpsertSNIRequest) (*v1.UpsertSNIResponse, error)

type SchemasService 

type SchemasService struct {
	v1.UnimplementedSchemasServiceServer

	CommonOpts
	// contains filtered or unexported fields
}

func (*SchemasService) GetLuaSchemasPlugin 

func (s *SchemasService) GetLuaSchemasPlugin(ctx context.Context,
	req *v1.GetLuaSchemasPluginRequest,
) (*v1.GetLuaSchemasPluginResponse, error)

func (*SchemasService) GetSchemas 

func (s *SchemasService) GetSchemas(ctx context.Context,
	req *v1.GetSchemasRequest,
) (*v1.GetSchemasResponse, error)

func (*SchemasService) ValidateCACertificateSchema 

func (s *SchemasService) ValidateCACertificateSchema(
	ctx context.Context,
	req *v1.ValidateCACertificateSchemaRequest,
) (*v1.ValidateCACertificateSchemaResponse, error)

func (*SchemasService) ValidateCertificateSchema 

func (s *SchemasService) ValidateCertificateSchema(
	ctx context.Context,
	req *v1.ValidateCertificateSchemaRequest,
) (*v1.ValidateCertificateSchemaResponse, error)

func (*SchemasService) ValidateConsumerSchema 

func (s *SchemasService) ValidateConsumerSchema(
	ctx context.Context,
	req *v1.ValidateConsumerSchemaRequest,
) (*v1.ValidateConsumerSchemaResponse, error)

func (*SchemasService) ValidateLuaPlugin 

func (s *SchemasService) ValidateLuaPlugin(
	ctx context.Context,
	req *v1.ValidateLuaPluginRequest,
) (*v1.ValidateLuaPluginResponse, error)

func (*SchemasService) ValidatePluginSchema 

func (s *SchemasService) ValidatePluginSchema(
	ctx context.Context,
	req *v1.ValidatePluginSchemaRequest,
) (*v1.ValidatePluginSchemaResponse, error)

func (*SchemasService) ValidateRouteSchema 

func (s *SchemasService) ValidateRouteSchema(
	ctx context.Context,
	req *v1.ValidateRouteSchemaRequest,
) (*v1.ValidateRouteSchemaResponse, error)

func (*SchemasService) ValidateSNISchema 

func (s *SchemasService) ValidateSNISchema(
	ctx context.Context,
	req *v1.ValidateSNISchemaRequest,
) (*v1.ValidateSNISchemaResponse, error)

func (*SchemasService) ValidateServiceSchema 

func (s *SchemasService) ValidateServiceSchema(
	ctx context.Context,
	req *v1.ValidateServiceSchemaRequest,
) (*v1.ValidateServiceSchemaResponse, error)

func (*SchemasService) ValidateTargetSchema 

func (s *SchemasService) ValidateTargetSchema(
	ctx context.Context,
	req *v1.ValidateTargetSchemaRequest,
) (*v1.ValidateTargetSchemaResponse, error)

func (*SchemasService) ValidateUpstreamSchema 

func (s *SchemasService) ValidateUpstreamSchema(
	ctx context.Context,
	req *v1.ValidateUpstreamSchemaRequest,
) (*v1.ValidateUpstreamSchemaResponse, error)

type ServiceService 

type ServiceService struct {
	v1.UnimplementedServiceServiceServer
	CommonOpts
}

func (*ServiceService) CreateService 

func (s *ServiceService) CreateService(ctx context.Context,
	req *v1.CreateServiceRequest,
) (*v1.CreateServiceResponse, error)

func (*ServiceService) DeleteService 

func (s *ServiceService) DeleteService(ctx context.Context,
	req *v1.DeleteServiceRequest,
) (*v1.DeleteServiceResponse, error)

func (*ServiceService) GetService 

func (s *ServiceService) GetService(ctx context.Context,
	req *v1.GetServiceRequest,
) (*v1.GetServiceResponse, error)

func (*ServiceService) ListServices 

func (s *ServiceService) ListServices(ctx context.Context,
	req *v1.ListServicesRequest,
) (*v1.ListServicesResponse, error)

func (*ServiceService) UpsertService 

func (s *ServiceService) UpsertService(ctx context.Context,
	req *v1.UpsertServiceRequest,
) (*v1.UpsertServiceResponse, error)

type StatusService 

type StatusService struct {
	v1.UnimplementedStatusServiceServer
	CommonOpts
}

func (*StatusService) GetHash 

func (s *StatusService) GetHash(ctx context.Context,
	req *v1.GetHashRequest,
) (*v1.GetHashResponse, error)

type TargetService 

type TargetService struct {
	v1.UnimplementedTargetServiceServer
	CommonOpts
}

func (*TargetService) CreateTarget 

func (s *TargetService) CreateTarget(ctx context.Context,
	req *v1.CreateTargetRequest,
) (*v1.CreateTargetResponse, error)

func (*TargetService) DeleteTarget 

func (s *TargetService) DeleteTarget(ctx context.Context,
	req *v1.DeleteTargetRequest,
) (*v1.DeleteTargetResponse, error)

func (*TargetService) GetTarget 

func (s *TargetService) GetTarget(ctx context.Context,
	req *v1.GetTargetRequest,
) (*v1.GetTargetResponse, error)

func (*TargetService) ListTargets 

func (s *TargetService) ListTargets(ctx context.Context,
	req *v1.ListTargetsRequest,
) (*v1.ListTargetsResponse, error)

func (*TargetService) UpsertTarget 

func (s *TargetService) UpsertTarget(ctx context.Context,
	req *v1.UpsertTargetRequest,
) (*v1.UpsertTargetResponse, error)

type UpstreamService 

type UpstreamService struct {
	v1.UnimplementedUpstreamServiceServer
	CommonOpts
}

func (*UpstreamService) CreateUpstream 

func (s *UpstreamService) CreateUpstream(ctx context.Context,
	req *v1.CreateUpstreamRequest,
) (*v1.CreateUpstreamResponse, error)

func (*UpstreamService) DeleteUpstream 

func (s *UpstreamService) DeleteUpstream(ctx context.Context,
	req *v1.DeleteUpstreamRequest,
) (*v1.DeleteUpstreamResponse, error)

func (*UpstreamService) GetUpstream 

func (s *UpstreamService) GetUpstream(ctx context.Context,
	req *v1.GetUpstreamRequest,
) (*v1.GetUpstreamResponse, error)

func (*UpstreamService) ListUpstreams 

func (s *UpstreamService) ListUpstreams(ctx context.Context,
	req *v1.ListUpstreamsRequest,
) (*v1.ListUpstreamsResponse, error)

func (*UpstreamService) UpsertUpstream 

func (s *UpstreamService) UpsertUpstream(ctx context.Context,
	req *v1.UpsertUpstreamRequest,
) (*v1.UpsertUpstreamResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

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