auth

Documentation

Index

• Variables
• type AccessTokenProvider
• type TokenProviderPlugin
  • func (TokenProviderPlugin) Client(_ *plugin.MuxBroker, c *rpc.Client) (interface{}, error)
  • func (p *TokenProviderPlugin) Server(*plugin.MuxBroker) (interface{}, error)
• type TokenProviderRPC
  • func (g *TokenProviderRPC) Init(options map[string]any, brokers []string) error
  • func (g *TokenProviderRPC) Token() (string, error)
• type TokenProviderRPCServer
  • func (s *TokenProviderRPCServer) Init(args map[string]interface{}, _ *interface{}) error
  • func (s *TokenProviderRPCServer) Token(_ interface{}, resp *string) error

Variables

var TokenProviderPluginSpec = plugins.PluginSpec[*TokenProviderPlugin, AccessTokenProvider]{
	PluginImpl: &TokenProviderPlugin{},
	Handshake: plugin.HandshakeConfig{
		ProtocolVersion:  1,
		MagicCookieKey:   "KAFKACTL_PLUGIN",
		MagicCookieValue: "TOKEN_PROVIDER_PLUGIN",
	},
}

Types

type AccessTokenProvider

type AccessTokenProvider interface {
	Token() (string, error)
	Init(options map[string]any, brokers []string) error
}

type TokenProviderPlugin

type TokenProviderPlugin struct {
	Impl AccessTokenProvider
}

func (TokenProviderPlugin) Client

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

func (*TokenProviderPlugin) Server

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

type TokenProviderRPC

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

TokenProviderRPC is the rpc implementation i.e. the one that is used by kafkactl

func (*TokenProviderRPC) Init

func (g *TokenProviderRPC) Init(options map[string]any, brokers []string) error

func (*TokenProviderRPC) Token

func (g *TokenProviderRPC) Token() (string, error)

type TokenProviderRPCServer

type TokenProviderRPCServer struct {
	Impl AccessTokenProvider
}

TokenProviderRPCServer is the rpc server, which is a wrapper around the actual plugin implementation

func (*TokenProviderRPCServer) Init

func (s *TokenProviderRPCServer) Init(args map[string]interface{}, _ *interface{}) error

func (*TokenProviderRPCServer) Token

func (s *TokenProviderRPCServer) Token(_ interface{}, resp *string) error