plugins

Documentation

Index

• Constants
• Variables
• func Close()
• func Run(pluginNames []string, kind kind) error
• type MapPlugins
  • func Get(kind kind) *MapPlugins
  • func (m *MapPlugins) Add(name string, client *plugin.Client, rpcClient plugin.ClientProtocol)
  • func (m *MapPlugins) Close()
  • func (m *MapPlugins) Get(name string) (*PluginClient, bool)
• type PluginClient
  • func (p *PluginClient) GetClient() *plugin.Client
  • func (p *PluginClient) GetRpcClient() plugin.ClientProtocol

Constants

const (
	RequestTransport kind = "request_transport"
	ResponseModify   kind = "response_modify"
)

Variables

var Handshake = plugin.HandshakeConfig{
	ProtocolVersion:  1,
	MagicCookieKey:   "PROXY_SERVER_PLUGIN",
	MagicCookieValue: "e524367f551015d0f6e1df2d3158dbe9e30945fb",
}

var LoadPlugins map[kind]*MapPlugins = make(map[kind]*MapPlugins)

var VersionedPlugins = map[int]plugin.PluginSet{
	1: {
		"request_transport": &internal.TransportPlugin{},
		"response_modify":   &internal.ResponsePlugin{},
	},
}

Functions

func Close

func Close()

func Run

func Run(pluginNames []string, kind kind) error

Types

type MapPlugins

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

func Get

func Get(kind kind) *MapPlugins

func (*MapPlugins) Add

func (m *MapPlugins) Add(name string, client *plugin.Client, rpcClient plugin.ClientProtocol)

func (*MapPlugins) Close

func (m *MapPlugins) Close()

func (*MapPlugins) Get

func (m *MapPlugins) Get(name string) (*PluginClient, bool)

type PluginClient

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

func (*PluginClient) GetClient

func (p *PluginClient) GetClient() *plugin.Client

func (*PluginClient) GetRpcClient

func (p *PluginClient) GetRpcClient() plugin.ClientProtocol