shared

package

v0.2.7 Latest Latest Go to latest Published: Oct 6, 2020 License: Apache-2.0 Imports: 7 Imported by: 3

Details

Package shared contains shared data between the host and plugins.

This section is empty.

View Source

var Handshake = plugin.HandshakeConfig{
	ProtocolVersion:  1,
	MagicCookieKey:   "GATEWAY_CLIENT_PLUGIN",
	MagicCookieValue: "hello",
}

Handshake is a common handshake that is shared by plugin and host.

View Source

var PluginMap = map[string]plugin.Plugin{
	"tokenProvider": &TokenProviderPlugin{},
}

This section is empty.

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

GRPCClient is an implementation of TokenProvider that talks over gRPC.

func (m *GRPCClient) GetToken(ctx context.Context, request apis.TokenRequest) (apis.TokenResponse, error)

type GRPCServer struct {
	Impl apis.TokenProvider
	// contains filtered or unexported fields
}

Here is the gRPC server that GRPCClient talks to.

func (m *GRPCServer) GetToken(
	ctx context.Context,
	req *proto.TokenRequest) (*proto.TokenResponse, error)

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

func (m *RPCClient) GetToken(request apis.TokenRequest) (apis.TokenResponse, error)

type RPCServer struct {
	Impl apis.TokenProvider
}

func (m *RPCServer) GetToken(args map[string]interface{}, resp *map[string]interface{}) error

type TokenProviderPlugin struct {
	Impl apis.TokenProvider
}

func (*TokenProviderPlugin) Client(b *plugin.MuxBroker, c *rpc.Client) (interface{}, error)

func (p *TokenProviderPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

func (p *TokenProviderPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

func (p *TokenProviderPlugin) Server(*plugin.MuxBroker) (interface{}, error)