authv2

Documentation

Index

• Constants
• func NewClientChallenge(kr keyring.Keyring, clientId string, logger *slog.Logger) (challenges.ChallengeHandler, error)
• func NewServerChallenge(verifier challenges.KeyringVerifier, logger *slog.Logger, ...) challenges.ChallengeHandler
• func ShouldEnableIncoming(streamContext context.Context) (bool, error)
• type ChallengeOption
  • func WithChallengeTimeout(challengeTimeout time.Duration) ChallengeOption
• type ChallengeOptions
• type Client
  • func (a *Client) DoChallenge(clientStream streams.Stream) (context.Context, error)
  • func (a *Client) InterceptContext(ctx context.Context) context.Context
• type Server
  • func (a *Server) DoChallenge(ss streams.Stream) (context.Context, error)
  • func (a *Server) InterceptContext(ctx context.Context) context.Context

Constants

const (
	DomainString = "agent auth v2"
)

Functions

func NewClientChallenge

func NewClientChallenge(kr keyring.Keyring, clientId string, logger *slog.Logger) (challenges.ChallengeHandler, error)

func NewServerChallenge

func NewServerChallenge(verifier challenges.KeyringVerifier, logger *slog.Logger, opts ...ChallengeOption) challenges.ChallengeHandler

func ShouldEnableIncoming

func ShouldEnableIncoming(streamContext context.Context) (bool, error)

Checks if the incoming context has the challenge version metadata key set to v2.

Types

type ChallengeOption

type ChallengeOption func(*ChallengeOptions)

func WithChallengeTimeout

func WithChallengeTimeout(challengeTimeout time.Duration) ChallengeOption

type ChallengeOptions

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

type Client

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

func (*Client) DoChallenge

func (a *Client) DoChallenge(clientStream streams.Stream) (context.Context, error)

func (*Client) InterceptContext

func (a *Client) InterceptContext(ctx context.Context) context.Context

type Server

type Server struct {
	ChallengeOptions
	// contains filtered or unexported fields
}

func (*Server) DoChallenge

func (a *Server) DoChallenge(ss streams.Stream) (context.Context, error)

func (*Server) InterceptContext

func (a *Server) InterceptContext(ctx context.Context) context.Context