util

Documentation

Index

• func ParseResourceEdge(resource string, operation string) (string, string, string, error)
• func ParseResourceMaster(resource string, operation string) (string, string, string, string, string, error)
• type UnixSocket
  • func NewUnixSocket(filename string, sizes ...int) *UnixSocket
  • func (us *UnixSocket) ClientSendContext(context string) string
  • func (us *UnixSocket) Connect() *net.UnixConn
  • func (us *UnixSocket) HandleServerConn(c net.Conn)
  • func (us *UnixSocket) HandleServerContext(context string) string
  • func (us *UnixSocket) Send(c *net.UnixConn, context string) string
  • func (us *UnixSocket) SetContextHandler(f func(string) string)
  • func (us *UnixSocket) StartServer()

Functions

func ParseResourceEdge

func ParseResourceEdge(resource string, operation string) (string, string, string, error)

ParseResourceEdge parses resource at edge and returns namespace, resource_type, resource_id. If operation of msg is query list, return namespace, pod.

func ParseResourceMaster

func ParseResourceMaster(resource string, operation string) (string, string, string, string, string, error)

ParseResourceMaster parses resource at master and returns cluster_id, node_id, namespace, resource_type, resource_id. If operation of msg is query list, return cluster_id, node_id, namespace, pod.

Types

type UnixSocket

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

UnixSocket struct

func NewUnixSocket

func NewUnixSocket(filename string, sizes ...int) *UnixSocket

NewUnixSocket create new socket

func (*UnixSocket) ClientSendContext

func (us *UnixSocket) ClientSendContext(context string) string

ClientSendContext side

func (*UnixSocket) Connect

func (us *UnixSocket) Connect() *net.UnixConn

Connect connect

func (*UnixSocket) HandleServerConn

func (us *UnixSocket) HandleServerConn(c net.Conn)

HandleServerConn handler sever

func (*UnixSocket) HandleServerContext

func (us *UnixSocket) HandleServerContext(context string) string

HandleServerContext handler ctx

func (*UnixSocket) Send

func (us *UnixSocket) Send(c *net.UnixConn, context string) string

Send msg

func (*UnixSocket) SetContextHandler

func (us *UnixSocket) SetContextHandler(f func(string) string)

SetContextHandler set handler

func (*UnixSocket) StartServer

func (us *UnixSocket) StartServer()

StartServer start server