plugins

Documentation

Index

• Constants
• func Add(name string, p Plugin)
• func Do(name string, ctx context.Context, key string, d interface{}) (interface{}, error)
• func DoWithError(name string, ctx context.Context, key string, d interface{}) error
• func Remove(name string)
• type Chan
  • func DoChan(name string, ctx context.Context, key string, d interface{}) (Chan, error)
• type Command
• type Data
• type Plugin
  • func Get(name string) Plugin
• type Plugins

Constants

const (
	KAlarm = "alarm"
)

Functions

func Add

func Add(name string, p Plugin)

func Do

func Do(name string, ctx context.Context, key string, d interface{}) (interface{}, error)

func DoWithError

func DoWithError(name string, ctx context.Context, key string, d interface{}) error

DoWithError 只关心error

func Remove

func Remove(name string)

Types

type Chan

type Chan chan Data

func DoChan

func DoChan(name string, ctx context.Context, key string, d interface{}) (Chan, error)

type Command

type Command struct {
	Cmd  string
	Data interface{}
}

type Data

type Data struct {
	Error error
	Data  interface{}
}

type Plugin

type Plugin interface {
	// Do
	// name is plugin's name
	// key parameter is custom defined
	// d parameter is can use Command or custom
	// return is custom
	Do(ctx context.Context, key string, d interface{}) (interface{}, error)
	DoChan(ctx context.Context, key string, d interface{}) (Chan, error)
}

func Get

func Get(name string) Plugin

type Plugins

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