daemon_handler

Documentation

Index

• Constants
• func GetAllApplicationWithDefaultApp(namespace, kubeconfigPath string) []*appmeta.ApplicationMeta
• func GetAllValidApplicationWithDefaultApp(ns string, KubeConfigBytes []byte) []*appmeta.ApplicationMeta
• func GetDescriptionDaemon(ns, appName string, kubeconfigBytes []byte) *profile.AppProfileV2
• func GetReverseInfo() *sync.Map
• func HandleGetResourceInfoRequest(request *command.GetResourceInfoCommand) (interface{}, error)
• func HandleKubeconfigOperationRequest(request *command.KubeconfigOperationCommand) error
• func HandleSudoVPNOperate(cmd *command.VPNOperateCommand, writer io.WriteCloser) error
• func HandleSudoVPNStatus() (interface{}, error)
• func HandleVPNOperate(cmd *command.VPNOperateCommand, writer io.WriteCloser) (err error)
• func HandleVPNStatus() (interface{}, error)
• func InvalidCache(ns, nid, appName string)
• func ParseApplicationsResult(namespace string, metas []*appmeta.ApplicationMeta) []*model.Namespace
• func ReleaseWatcher(kubeconfigBytes []byte, namespace string)
• func SortApplication(metas []*appmeta.ApplicationMeta)
• func ToStatus(m map[string]string) *status
• type AppNameAndNid
• type ConfigMapWatcher
  • func GetOrGenerateConfigMapWatcher(kubeconfigBytes []byte, namespace string, getter cache.Getter) *ConfigMapWatcher
  • func NewConfigMapWatcher(kubeconfigBytes []byte, namespace string, getter cache.Getter) *ConfigMapWatcher
  • func (w *ConfigMapWatcher) Start()
  • func (w *ConfigMapWatcher) Stop()
• type ConnectInfo
  • func (c *ConnectInfo) GetKubeconfig() string
  • func (c *ConnectInfo) GetNamespace() string
  • func (c *ConnectInfo) GetUid() string
  • func (c *ConnectInfo) IsEmpty() bool
  • func (c *ConnectInfo) IsSameCluster(kubeconfigBytes []byte) bool
  • func (c *ConnectInfo) IsSameUid(uid string) bool
  • func (c ConnectInfo) Status() string
• type ConnectTotal
  • func FromStringToConnectInfo(str string) *ConnectTotal
  • func (c *ConnectTotal) IsConnected() bool
  • func (c *ConnectTotal) ToString() string
• type HealthEnum
  • func (e HealthEnum) String() string
• type ModeEnum
  • func (m ModeEnum) String() string
• type ReverseRecord
  • func NewReverseRecord(resourceType, resourceName string) ReverseRecord
  • func NewReverseRecordWithWorkloads(workloads string) *ReverseRecord
• type ReverseTotal
  • func FromStringToReverseTotal(s string) (t *ReverseTotal)
  • func (t *ReverseTotal) AddRecord(records ...*ReverseRecord) *ReverseTotal
  • func (t *ReverseTotal) GetBelongToMeResources() Set
  • func (t *ReverseTotal) LoadAndDeleteBelongToMeResources() Set
  • func (t *ReverseTotal) RemoveRecord(records ...*ReverseRecord) *ReverseTotal
  • func (t *ReverseTotal) ReversedResource() sets.String
  • func (t *ReverseTotal) ToString() string
• type Set
  • func NewSet(items ...*resourceInfo) Set
  • func NewSetByKeys(items ...string) Set
  • func (s Set) Delete(items ...*resourceInfo) Set
  • func (s Set) DeleteByKeys(items ...string) Set
  • func (s Set) ForEach(f func(k string, v *resourceInfo))
  • func (s Set) Get(item string) *resourceInfo
  • func (s Set) Has(item *resourceInfo) bool
  • func (s Set) HasKey(item string) bool
  • func (s Set) Insert(items ...*resourceInfo) Set
  • func (s Set) InsertByKeys(items ...string) Set
  • func (s Set) KeySet() []string
  • func (s Set) Len() int
  • func (s Set) List() []*resourceInfo

Constants

const (
	Unknown     HealthEnum = "unknown"
	UnHealthy   HealthEnum = "unHealthy"
	Healthy     HealthEnum = "healthy"
	ReverseMode ModeEnum   = "reverse"
	ConnectMode ModeEnum   = "connect"
)

Functions

func GetAllApplicationWithDefaultApp

func GetAllApplicationWithDefaultApp(namespace, kubeconfigPath string) []*appmeta.ApplicationMeta

GetAllApplicationWithDefaultApp will not to create default application if default application not found note: this func will return all app meta, includes invalid application(uninstalled)

func GetAllValidApplicationWithDefaultApp

func GetAllValidApplicationWithDefaultApp(ns string, KubeConfigBytes []byte) []*appmeta.ApplicationMeta

func GetDescriptionDaemon

func GetDescriptionDaemon(ns, appName string, kubeconfigBytes []byte) *profile.AppProfileV2

func GetReverseInfo

func GetReverseInfo() *sync.Map

func HandleGetResourceInfoRequest

func HandleGetResourceInfoRequest(request *command.GetResourceInfoCommand) (interface{}, error)

func HandleKubeconfigOperationRequest

func HandleKubeconfigOperationRequest(request *command.KubeconfigOperationCommand) error

HandleKubeconfigOperationRequest this method will operate informer cache, remove or add informer

func HandleSudoVPNOperate

func HandleSudoVPNOperate(cmd *command.VPNOperateCommand, writer io.WriteCloser) error

HandleSudoVPNOperate sudo daemon, vpn executor

func HandleSudoVPNStatus

func HandleSudoVPNStatus() (interface{}, error)

func HandleVPNOperate

func HandleVPNOperate(cmd *command.VPNOperateCommand, writer io.WriteCloser) (err error)

HandleVPNOperate not sudo daemon, vpn controller

func HandleVPNStatus

func HandleVPNStatus() (interface{}, error)

func InvalidCache

func InvalidCache(ns, nid, appName string)

func ParseApplicationsResult

func ParseApplicationsResult(namespace string, metas []*appmeta.ApplicationMeta) []*model.Namespace

func ReleaseWatcher

func ReleaseWatcher(kubeconfigBytes []byte, namespace string)

func SortApplication

func SortApplication(metas []*appmeta.ApplicationMeta)

func ToStatus

func ToStatus(m map[string]string) *status

Types

type AppNameAndNid

type AppNameAndNid struct {
	Name string
	Nid  string
}

type ConfigMapWatcher

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

func GetOrGenerateConfigMapWatcher

func GetOrGenerateConfigMapWatcher(kubeconfigBytes []byte, namespace string, getter cache.Getter) *ConfigMapWatcher

func NewConfigMapWatcher

func NewConfigMapWatcher(kubeconfigBytes []byte, namespace string, getter cache.Getter) *ConfigMapWatcher

func (*ConfigMapWatcher) Start

func (w *ConfigMapWatcher) Start()

func (*ConfigMapWatcher) Stop

func (w *ConfigMapWatcher) Stop()

type ConnectInfo

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

func (*ConnectInfo) GetKubeconfig

func (c *ConnectInfo) GetKubeconfig() string

func (*ConnectInfo) GetNamespace

func (c *ConnectInfo) GetNamespace() string

func (*ConnectInfo) GetUid

func (c *ConnectInfo) GetUid() string

func (*ConnectInfo) IsEmpty

func (c *ConnectInfo) IsEmpty() bool

func (*ConnectInfo) IsSameCluster

func (c *ConnectInfo) IsSameCluster(kubeconfigBytes []byte) bool

func (*ConnectInfo) IsSameUid

func (c *ConnectInfo) IsSameUid(uid string) bool

func (ConnectInfo) Status

func (c ConnectInfo) Status() string

type ConnectTotal

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

func FromStringToConnectInfo

func FromStringToConnectInfo(str string) *ConnectTotal

func (*ConnectTotal) IsConnected

func (c *ConnectTotal) IsConnected() bool

func (*ConnectTotal) ToString

func (c *ConnectTotal) ToString() string

type HealthEnum

type HealthEnum string

func (HealthEnum) String

func (e HealthEnum) String() string

type ModeEnum

type ModeEnum string

func (ModeEnum) String

func (m ModeEnum) String() string

type ReverseRecord

type ReverseRecord struct {
	MacAddress string
	Resources  sets.String
}

func NewReverseRecord

func NewReverseRecord(resourceType, resourceName string) ReverseRecord

func NewReverseRecordWithWorkloads

func NewReverseRecordWithWorkloads(workloads string) *ReverseRecord

type ReverseTotal

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

func FromStringToReverseTotal

func FromStringToReverseTotal(s string) (t *ReverseTotal)

func (*ReverseTotal) AddRecord

func (t *ReverseTotal) AddRecord(records ...*ReverseRecord) *ReverseTotal

func (*ReverseTotal) GetBelongToMeResources

func (t *ReverseTotal) GetBelongToMeResources() Set

func (*ReverseTotal) LoadAndDeleteBelongToMeResources

func (t *ReverseTotal) LoadAndDeleteBelongToMeResources() Set

func (*ReverseTotal) RemoveRecord

func (t *ReverseTotal) RemoveRecord(records ...*ReverseRecord) *ReverseTotal

func (*ReverseTotal) ReversedResource

func (t *ReverseTotal) ReversedResource() sets.String

func (*ReverseTotal) ToString

func (t *ReverseTotal) ToString() string

type Set

type Set map[string]*resourceInfo

func NewSet

func NewSet(items ...*resourceInfo) Set

func NewSetByKeys

func NewSetByKeys(items ...string) Set

func (Set) Delete

func (s Set) Delete(items ...*resourceInfo) Set

func (Set) DeleteByKeys

func (s Set) DeleteByKeys(items ...string) Set

func (Set) ForEach

func (s Set) ForEach(f func(k string, v *resourceInfo))

func (Set) Get

func (s Set) Get(item string) *resourceInfo

func (Set) Has

func (s Set) Has(item *resourceInfo) bool

func (Set) HasKey

func (s Set) HasKey(item string) bool

func (Set) Insert

func (s Set) Insert(items ...*resourceInfo) Set

func (Set) InsertByKeys

func (s Set) InsertByKeys(items ...string) Set

func (Set) KeySet

func (s Set) KeySet() []string

func (Set) Len

func (s Set) Len() int

func (Set) List

func (s Set) List() []*resourceInfo