resourcemanage

Documentation

Index

• func ConstructLogDetails(podID string, rawLogs string, container string, logSelector *log.Selection) *log.LogDetails
• func Filter(c *gin.Context, result []byte) []byte
• func FilterToMap(c *gin.Context, result []byte) filter.K8sJson
• func GetConfigMap(c *gin.Context)
• func GetFeatureConfig(c *gin.Context)
• func GetLogDetails(client kubernetes.Interface, namespace, podID string, container string, ...) (*log.LogDetails, error)
• func GetPodContainerLog(c *gin.Context)
• func IngressDomainSuffix(c *gin.Context)
• func SetExtendHandler(resource enum.ResourceTypeEnum, extendFunc ExtendFunc)
• type ExtendFunc
• type ExtendHandler
  • func NewExtendHandler(namespace string, tcpCm string, udpCm string) *ExtendHandler
  • func (e *ExtendHandler) ExtendHandle(c *gin.Context)
• type ExtendParams
• type PodLog
  • func NewPodLog(client client.Client, namespace string, filter filter.Filter) PodLog
  • func (podLog *PodLog) HandleLogs(c *gin.Context)
• type ProxyHandler
  • func NewProxyHandler(enableConvert bool) *ProxyHandler
  • func (h *ProxyHandler) ProxyHandle(c *gin.Context)

Functions

func ConstructLogDetails

func ConstructLogDetails(podID string, rawLogs string, container string, logSelector *log.Selection) *log.LogDetails

ConstructLogDetails creates a new log details structure for given parameters.

func Filter

func Filter(c *gin.Context, result []byte) []byte

product match/sort/page to other function

func FilterToMap

func FilterToMap(c *gin.Context, result []byte) filter.K8sJson

product match/sort/page to other function

func GetConfigMap

func GetConfigMap(c *gin.Context)

GetConfigMap show system configMap all users have read-only access ability

func GetFeatureConfig

func GetFeatureConfig(c *gin.Context)

GetFeatureConfig shows layout of integrated components all users have read-only access ability

func GetLogDetails

func GetLogDetails(client kubernetes.Interface, namespace, podID string, container string,
	logSelector *log.Selection, usePreviousLogs bool) (*log.LogDetails, error)

GetLogDetails returns logs for particular pod and container. When container is null, logs for the first one are returned. Previous indicates to read archived logs created by log rotation or container crash

func GetPodContainerLog

func GetPodContainerLog(c *gin.Context)

func IngressDomainSuffix

func IngressDomainSuffix(c *gin.Context)

IngressDomainSuffix Get Ingress Domain Suffix by cluster and project

func SetExtendHandler

func SetExtendHandler(resource enum.ResourceTypeEnum, extendFunc ExtendFunc)

SetExtendHandler the func to register real handler func

Types

type ExtendFunc

type ExtendFunc func(param ExtendParams) (interface{}, error)

type ExtendHandler

type ExtendHandler struct {
	NginxNamespace           string
	NginxTcpServiceConfigMap string
	NginxUdpServiceConfigMap string
}

func NewExtendHandler

func NewExtendHandler(namespace string, tcpCm string, udpCm string) *ExtendHandler

func (*ExtendHandler) ExtendHandle

func (e *ExtendHandler) ExtendHandle(c *gin.Context)

ExtendHandle api/v1/cube/extend/clusters/{cluster}/namespaces/{namespace}/{resourceType}

type ExtendParams

type ExtendParams struct {
	Cluster                  string
	Namespace                string
	ResourceName             string
	Filter                   filter.Filter
	Action                   string
	Username                 string
	NginxNamespace           string
	NginxTcpServiceConfigMap string
	NginxUdpServiceConfigMap string
	Body                     []byte
}

type PodLog

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

func NewPodLog

func NewPodLog(client client.Client, namespace string, filter filter.Filter) PodLog

func (*PodLog) HandleLogs

func (podLog *PodLog) HandleLogs(c *gin.Context)

type ProxyHandler

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

func NewProxyHandler

func NewProxyHandler(enableConvert bool) *ProxyHandler

func (*ProxyHandler) ProxyHandle

func (h *ProxyHandler) ProxyHandle(c *gin.Context)

ProxyHandle proxy all requests access to k8s, request uri format like below api/v1/cube/proxy/clusters/{cluster}/{k8s_url}