util

Documentation

Index

• Variables
• func DialGRPC(ctx context.Context, proto, address string, timeout time.Duration, ...) (*grpc.ClientConn, error)
• func GRPCListenAndServe(server *grpc.Server, proto, address string) error
• func InitGraceUpgrade(exit context.CancelFunc, timeout time.Duration, sig os.Signal)
• func NotifyWhenConfigChanged(file string, out interface{}, unmarshalFunc func([]byte, interface{}) error) <-chan struct{}
• func ScanAnyAvail(data []byte, atEOF bool) (advance int, token []byte, err error)
• func UnWatchFileWrite(file string) error
• func Unmarshal(file string, out interface{}, unmarshalFunc func([]byte, interface{}) error) error
• type Command
  • func DefaultCmd(name string, optFromConfigFile interface{}, onConfigChanged func(interface{}), ...) *Command
• type FileEventChan
  • func WatchFileWrite(file string) (*FileEventChan, error)
• type StringInterfaceMap
  • func (ss *StringInterfaceMap) Del(s string)
  • func (ss *StringInterfaceMap) Get(s string) (interface{}, bool)
  • func (ss *StringInterfaceMap) Set(s string, val interface{})
• type Worker
• type WorkerChan

Variables

var (
	Net, _ = tableflip.New(tableflip.Options{UpgradeTimeout: tableflip.DefaultUpgradeTimeout})
	N      = Net.Fds
)

var (
	Workers = &workerGroup{}
)

Functions

func DialGRPC

func DialGRPC(ctx context.Context, proto, address string, timeout time.Duration, tlsConfig *tls.Config) (*grpc.ClientConn, error)

func GRPCListenAndServe

func GRPCListenAndServe(server *grpc.Server, proto, address string) error

func InitGraceUpgrade

func InitGraceUpgrade(exit context.CancelFunc, timeout time.Duration, sig os.Signal)

func NotifyWhenConfigChanged

func NotifyWhenConfigChanged(file string, out interface{}, unmarshalFunc func([]byte, interface{}) error) <-chan struct{}

func ScanAnyAvail

func ScanAnyAvail(data []byte, atEOF bool) (advance int, token []byte, err error)

ScanAnyAvail a split func to get all available bytes

func UnWatchFileWrite

func UnWatchFileWrite(file string) error

func Unmarshal

func Unmarshal(file string, out interface{}, unmarshalFunc func([]byte, interface{}) error) error

Types

type Command

type Command struct {
	Context context.Context
	Exit    context.CancelFunc
	cobra.Command
}

func DefaultCmd

func DefaultCmd(name string, optFromConfigFile interface{}, onConfigChanged func(interface{}), run func(context.Context, context.CancelFunc) error) *Command

type FileEventChan

type FileEventChan struct {
	Write chan struct{}
}

func WatchFileWrite

func WatchFileWrite(file string) (*FileEventChan, error)

type StringInterfaceMap

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

func (*StringInterfaceMap) Del

func (ss *StringInterfaceMap) Del(s string)

func (*StringInterfaceMap) Get

func (ss *StringInterfaceMap) Get(s string) (interface{}, bool)

func (*StringInterfaceMap) Set

func (ss *StringInterfaceMap) Set(s string, val interface{})

type Worker

type Worker func(sigContinue func()) (result interface{}, err error)

type WorkerChan

type WorkerChan struct {
	Continue chan struct{}
	Result   chan interface{}
	Error    chan error
}