plugin

package

Go to main page

Versions in this module

v0

v0.4.0

Apr 27, 2026

Changes in this version

type HostServiceClient

+ func (c *HostServiceClient) GetAuthGroups(ctx context.Context, handler string) ([]string, error)

v0.3.0

Apr 27, 2026

Changes in this version

+ func WithHostClient(ctx context.Context, client *HostServiceClient) context.Context

type HostServiceClient

+ func HostClientFromContext(ctx context.Context) *HostServiceClient

v0.2.0

Apr 24, 2026

v0.1.1

Apr 14, 2026

v0.1.0

Apr 14, 2026

Changes in this version

+ const AuthHandlerPluginName

+ const PluginName

+ const PluginProtocolVersion

+ var ErrStreamingNotSupported = errors.New("streaming execution not supported")

+ func ProtoToDescriptor(pd *proto.ProviderDescriptor) (*provider.Descriptor, error)

+ func Serve(impl ProviderPlugin)

+ func ServeAuthHandler(impl AuthHandlerPlugin)

+ type AuthHandlerGRPCClient struct

+ func (c *AuthHandlerGRPCClient) Client() proto.AuthHandlerServiceClient

+ type AuthHandlerGRPCPlugin struct

+ Impl AuthHandlerPlugin

+ func (p *AuthHandlerGRPCPlugin) GRPCClient(_ context.Context, _ *goplugin.GRPCBroker, c *grpc.ClientConn) (any, error)

+ func (p *AuthHandlerGRPCPlugin) GRPCServer(broker *goplugin.GRPCBroker, s *grpc.Server) error

+ type AuthHandlerGRPCServer struct

+ Impl AuthHandlerPlugin

+ func (s *AuthHandlerGRPCServer) ConfigureAuthHandler(ctx context.Context, req *proto.ConfigureAuthHandlerRequest) (*proto.ConfigureAuthHandlerResponse, error)

+ func (s *AuthHandlerGRPCServer) GetAuthHandlers(ctx context.Context, _ *proto.GetAuthHandlersRequest) (*proto.GetAuthHandlersResponse, error)

+ func (s *AuthHandlerGRPCServer) GetStatus(ctx context.Context, req *proto.GetStatusRequest) (*proto.GetStatusResponse, error)

+ func (s *AuthHandlerGRPCServer) GetToken(ctx context.Context, req *proto.GetTokenRequest) (*proto.GetTokenResponse, error)

+ func (s *AuthHandlerGRPCServer) ListCachedTokens(ctx context.Context, req *proto.ListCachedTokensRequest) (*proto.ListCachedTokensResponse, error)

+ func (s *AuthHandlerGRPCServer) Login(req *proto.LoginRequest, ...) error

+ func (s *AuthHandlerGRPCServer) Logout(ctx context.Context, req *proto.LogoutRequest) (*proto.LogoutResponse, error)

+ func (s *AuthHandlerGRPCServer) PurgeExpiredTokens(ctx context.Context, req *proto.PurgeExpiredTokensRequest) (*proto.PurgeExpiredTokensResponse, error)

+ func (s *AuthHandlerGRPCServer) StopAuthHandler(ctx context.Context, req *proto.StopAuthHandlerRequest) (*proto.StopAuthHandlerResponse, error)

+ type AuthHandlerInfo struct

+ Capabilities []auth.Capability

+ DisplayName string

+ Flows []auth.Flow

+ Name string

+ type AuthHandlerPlugin interface

+ ConfigureAuthHandler func(ctx context.Context, handlerName string, cfg ProviderConfig) error

+ GetAuthHandlers func(ctx context.Context) ([]AuthHandlerInfo, error)

+ GetStatus func(ctx context.Context, handlerName string) (*auth.Status, error)

+ GetToken func(ctx context.Context, handlerName string, req TokenRequest) (*TokenResponse, error)

+ ListCachedTokens func(ctx context.Context, handlerName string) ([]*auth.CachedTokenInfo, error)

+ Login func(ctx context.Context, handlerName string, req LoginRequest, ...) (*LoginResponse, error)

+ Logout func(ctx context.Context, handlerName string) error

+ PurgeExpiredTokens func(ctx context.Context, handlerName string) (int, error)

+ StopAuthHandler func(ctx context.Context, handlerName string) error

+ type DeviceCodePrompt struct

+ Message string

+ UserCode string

+ VerificationURI string

+ type GRPCClient struct

+ func (c *GRPCClient) Client() proto.PluginServiceClient

+ type GRPCPlugin struct

+ Impl ProviderPlugin

+ func (p *GRPCPlugin) GRPCClient(_ context.Context, _ *goplugin.GRPCBroker, c *grpc.ClientConn) (any, error)

+ func (p *GRPCPlugin) GRPCServer(broker *goplugin.GRPCBroker, s *grpc.Server) error

+ type GRPCServer struct

+ Impl ProviderPlugin

+ func (s *GRPCServer) ConfigureProvider(ctx context.Context, req *proto.ConfigureProviderRequest) (*proto.ConfigureProviderResponse, error)

+ func (s *GRPCServer) DescribeWhatIf(ctx context.Context, req *proto.DescribeWhatIfRequest) (*proto.DescribeWhatIfResponse, error)

+ func (s *GRPCServer) ExecuteProvider(ctx context.Context, req *proto.ExecuteProviderRequest) (*proto.ExecuteProviderResponse, error)

+ func (s *GRPCServer) ExecuteProviderStream(req *proto.ExecuteProviderRequest, ...) error

+ func (s *GRPCServer) ExtractDependencies(ctx context.Context, req *proto.ExtractDependenciesRequest) (*proto.ExtractDependenciesResponse, error)

+ func (s *GRPCServer) GetProviderDescriptor(ctx context.Context, req *proto.GetProviderDescriptorRequest) (*proto.GetProviderDescriptorResponse, error)

+ func (s *GRPCServer) GetProviders(ctx context.Context, _ *proto.GetProvidersRequest) (*proto.GetProvidersResponse, error)

+ func (s *GRPCServer) StopProvider(ctx context.Context, req *proto.StopProviderRequest) (*proto.StopProviderResponse, error)

+ type HandshakeConfigData struct

+ MagicCookieKey string

+ MagicCookieValue string

+ ProtocolVersion uint

+ func AuthHandlerHandshakeConfig() HandshakeConfigData

+ func HandshakeConfig() HandshakeConfigData

+ type HostServiceClient struct

+ func NewHostServiceClient(conn *grpc.ClientConn) *HostServiceClient

+ func (c *HostServiceClient) DeleteSecret(ctx context.Context, name string) error

+ func (c *HostServiceClient) GetAuthIdentity(ctx context.Context, handler, scope string) (*proto.Claims, error)

+ func (c *HostServiceClient) GetAuthToken(ctx context.Context, handler, scope string, minValidFor int64, ...) (*proto.GetAuthTokenResponse, error)

+ func (c *HostServiceClient) GetSecret(ctx context.Context, name string) (string, bool, error)

+ func (c *HostServiceClient) ListAuthHandlers(ctx context.Context) (handlers []string, defaultHandler string, err error)

+ func (c *HostServiceClient) ListSecrets(ctx context.Context, pattern string) ([]string, error)

+ func (c *HostServiceClient) SetSecret(ctx context.Context, name, value string) error

+ type LoginRequest struct

+ Flow auth.Flow

+ Scopes []string

+ TenantID string

+ Timeout time.Duration

+ type LoginResponse struct

+ Claims *auth.Claims

+ ExpiresAt time.Time

+ type LoginStreamMessage struct

+ DeviceCodePrompt *DeviceCodePrompt

+ Error string

+ Result *LoginResponse

+ type ProviderConfig struct

+ BinaryName string

+ HostServiceID uint32

+ NoColor bool

+ Quiet bool

+ Settings map[string]json.RawMessage

+ type ProviderPlugin interface

+ ConfigureProvider func(ctx context.Context, providerName string, cfg ProviderConfig) error

+ DescribeWhatIf func(ctx context.Context, providerName string, input map[string]any) (string, error)

+ ExecuteProvider func(ctx context.Context, providerName string, input map[string]any) (*provider.Output, error)

+ ExecuteProviderStream func(ctx context.Context, providerName string, input map[string]any, ...) error

+ ExtractDependencies func(ctx context.Context, providerName string, inputs map[string]any) ([]string, error)

+ GetProviderDescriptor func(ctx context.Context, providerName string) (*provider.Descriptor, error)

+ GetProviders func(ctx context.Context) ([]string, error)

+ StopProvider func(ctx context.Context, providerName string) error

+ type StreamChunk struct

+ Error string

+ Result *provider.Output

+ Stderr []byte

+ Stdout []byte

+ type TokenRequest struct

+ ForceRefresh bool

+ MinValidFor time.Duration

+ Scope string

+ type TokenResponse struct

+ AccessToken string

+ CachedAt time.Time

+ ExpiresAt time.Time

+ Flow auth.Flow

+ Scope string

+ SessionID string

+ TokenType string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL