service

README

Service

Documentation

Index

• Constants
• type KsMetricsService
  • func NewKsMetricsService(c *ksclient.KApisClient) KsMetricsService
  • func (svc KsMetricsService) MetricsPlugins(name, status, sortBy, ascending, limit, page string) ([]byte, error)
  • func (svc KsMetricsService) PluginPods(plugin string) ([]byte, error)
  • func (svc KsMetricsService) PluginStatusAddr(plugin string) (string, error)
  • func (svc KsMetricsService) PodsCpuMem(plugin, resources, start, end, step, times string) ([]byte, error)
• type OpenapiService
  • func NewOpenapiService() *OpenapiService
  • func (s *OpenapiService) AddonsIdentify(ctx context.Context, in *openapi_v1.AddonsIdentifyRequest) (*openapi_v1.AddonsIdentifyResponse, error)
  • func (s *OpenapiService) Identify(ctx context.Context, in *emptypb.Empty) (*openapi_v1.IdentifyResponse, error)
  • func (s *OpenapiService) Status(ctx context.Context, in *emptypb.Empty) (*openapi_v1.StatusResponse, error)
  • func (s *OpenapiService) TenantDisable(ctx context.Context, in *openapi_v1.TenantDisableRequest) (*openapi_v1.TenantDisableResponse, error)
  • func (s *OpenapiService) TenantEnable(ctx context.Context, in *openapi_v1.TenantEnableRequest) (*openapi_v1.TenantEnableResponse, error)
• type PrometheusService
  • func NewPrometheusService(promNamespace, tKeelNamespace string) *PrometheusService
  • func (s *PrometheusService) BatchQuery(ctx context.Context, req *pb.BatchQueryRequest) (*pb.BatchQueryResponse, error)
  • func (s *PrometheusService) BatchTKMeter(ctx context.Context, req *pb.TKMeterBatchRequest) (*pb.BatchQueryResponse, error)
  • func (s *PrometheusService) Query(ctx context.Context, req *pb.QueryRequest) (*pb.QueryResponse, error)
  • func (s *PrometheusService) TKMeter(ctx context.Context, req *pb.TKMeterRequest) (*pb.QueryResponse, error)

Constants

const (
	KSPATH_V1ALPHA3_DEPLOYMENT   = "/kapis/resources.kubesphere.io/v1alpha3/namespaces/%s/deployments"
	KSPATH_V1ALPHA3_STATEFULSETS = "/kapis/resources.kubesphere.io/v1alpha3/namespaces/%s/statefulsets"
	KSPATH_V1ALPHA3_PODS         = "/kapis/resources.kubesphere.io/v1alpha3/namespaces/%s/pods"
	KSPATH_V1ALPHA3_PODS_MONITOR = "/kapis/monitoring.kubesphere.io/v1alpha3/namespaces/%s/pods"
	KSPATH_LOGIN                 = "/login"
	KSPATH_RESOURCE_STATUS       = "%s/clusters/%s/projects/%s/%s/%s/resource-status"
)

Types

type KsMetricsService

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

func NewKsMetricsService

func NewKsMetricsService(c *ksclient.KApisClient) KsMetricsService

func (KsMetricsService) MetricsPlugins

func (svc KsMetricsService) MetricsPlugins(name, status, sortBy, ascending, limit, page string) ([]byte, error)

func (KsMetricsService) PluginPods

func (svc KsMetricsService) PluginPods(plugin string) ([]byte, error)

func (KsMetricsService) PluginStatusAddr

func (svc KsMetricsService) PluginStatusAddr(plugin string) (string, error)

func (KsMetricsService) PodsCpuMem

func (svc KsMetricsService) PodsCpuMem(plugin, resources, start, end, step, times string) ([]byte, error)

type OpenapiService

type OpenapiService struct {
	v1.UnimplementedOpenapiServer
}

OpenapiService is a openapi service.

func NewOpenapiService

func NewOpenapiService() *OpenapiService

NewOpenapiService new a openapi service.

func (*OpenapiService) AddonsIdentify

func (s *OpenapiService) AddonsIdentify(ctx context.Context, in *openapi_v1.AddonsIdentifyRequest) (*openapi_v1.AddonsIdentifyResponse, error)

AddonsIdentify implements AddonsIdentify.OpenapiServer.

func (*OpenapiService) Identify

func (s *OpenapiService) Identify(ctx context.Context, in *emptypb.Empty) (*openapi_v1.IdentifyResponse, error)

Identify implements Identify.OpenapiServer.

func (*OpenapiService) Status

func (s *OpenapiService) Status(ctx context.Context, in *emptypb.Empty) (*openapi_v1.StatusResponse, error)

Status implements Status.OpenapiServer.

func (*OpenapiService) TenantDisable

func (s *OpenapiService) TenantDisable(ctx context.Context, in *openapi_v1.TenantDisableRequest) (*openapi_v1.TenantDisableResponse, error)

TenantDisable implements TenantDisable.OpenapiServer.

func (*OpenapiService) TenantEnable

func (s *OpenapiService) TenantEnable(ctx context.Context, in *openapi_v1.TenantEnableRequest) (*openapi_v1.TenantEnableResponse, error)

TenantEnable implements TenantEnable.OpenapiServer.

type PrometheusService

type PrometheusService struct {
	PromNS  string
	TKeelNS string
	// contains filtered or unexported fields
}

func NewPrometheusService

func NewPrometheusService(promNamespace, tKeelNamespace string) *PrometheusService

func (*PrometheusService) BatchQuery

func (s *PrometheusService) BatchQuery(ctx context.Context, req *pb.BatchQueryRequest) (*pb.BatchQueryResponse, error)

func (*PrometheusService) BatchTKMeter

func (s *PrometheusService) BatchTKMeter(ctx context.Context, req *pb.TKMeterBatchRequest) (*pb.BatchQueryResponse, error)

func (*PrometheusService) Query

func (s *PrometheusService) Query(ctx context.Context, req *pb.QueryRequest) (*pb.QueryResponse, error)

func (*PrometheusService) TKMeter

func (s *PrometheusService) TKMeter(ctx context.Context, req *pb.TKMeterRequest) (*pb.QueryResponse, error)