client

package

v0.0.0-...-22a1e08 Latest Latest Go to latest Published: Apr 9, 2024 License: BSD-3-Clause Imports: 16 Imported by: 6

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/tsuru/go-tsuruclient

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func ClientFromEnvironment(cfg *tsuru.Configuration) (*tsuru.APIClient, error)
func IsTsuruEventLocked(r *http.Response, err error) bool
func NewOIDCTokenSource(tokenV2 *config.TokenV2) oauth2.TokenSource
func NewTokenV1RoundTripper() http.RoundTripper
func RetryOnTsuruEventLocked(ctx context.Context, fn LikelyRetriableFunc) error
func RetryWithBackoff(ctx context.Context, backoff wait.Backoff, retriable IsRetriableFunc, ...) error
func RoundTripperAndTokenProvider() (http.RoundTripper, config.TokenProvider, error)
type IsRetriableFunc
type LikelyRetriableFunc
type OIDCTokenProvider
- func (ts *OIDCTokenProvider) Token() (string, error)
type TokenSourceFSStorage
- func (t *TokenSourceFSStorage) Token() (*oauth2.Token, error)
type TokenV1RoundTripper
- func (v *TokenV1RoundTripper) RoundTrip(req *http.Request) (*http.Response, error)
type TsuruProxyTransport
- func (tpt *TsuruProxyTransport) RoundTrip(r *http.Request) (*http.Response, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrTsuruTargetNotProvided       = errors.New("Tsuru target not provided")
	ErrTsuruTokenNotProvided        = errors.New("Tsuru token not provided")
	ErrTsuruServiceNameNotProvided  = errors.New("Tsuru service name not provided")
	ErrTsuruInstanceNameNotProvided = errors.New("Tsuru instance name not provided")
)

View Source

var DefaultBackoff = wait.Backoff{
	Steps:    100,
	Duration: 10 * time.Millisecond,
	Factor:   5.0,
	Jitter:   0.1,
}

Functions ¶

func ClientFromEnvironment ¶

func ClientFromEnvironment(cfg *tsuru.Configuration) (*tsuru.APIClient, error)

func IsTsuruEventLocked ¶

func IsTsuruEventLocked(r *http.Response, err error) bool

func NewOIDCTokenSource ¶

func NewOIDCTokenSource(tokenV2 *config.TokenV2) oauth2.TokenSource

func NewTokenV1RoundTripper ¶

func NewTokenV1RoundTripper() http.RoundTripper

func RetryOnTsuruEventLocked ¶

func RetryOnTsuruEventLocked(ctx context.Context, fn LikelyRetriableFunc) error

func RetryWithBackoff ¶

func RetryWithBackoff(ctx context.Context, backoff wait.Backoff, retriable IsRetriableFunc, fn LikelyRetriableFunc) error

func RoundTripperAndTokenProvider ¶

func RoundTripperAndTokenProvider() (http.RoundTripper, config.TokenProvider, error)

Types ¶

type IsRetriableFunc ¶

type IsRetriableFunc func(r *http.Response, err error) bool

type LikelyRetriableFunc ¶

type LikelyRetriableFunc func() (*http.Response, error)

type OIDCTokenProvider ¶

type OIDCTokenProvider struct {
	OAuthTokenSource oauth2.TokenSource
}

func (*OIDCTokenProvider) Token ¶

func (ts *OIDCTokenProvider) Token() (string, error)

type TokenSourceFSStorage ¶

type TokenSourceFSStorage struct {
	BaseTokenSource oauth2.TokenSource
	LastToken       *config.TokenV2
}

func (*TokenSourceFSStorage) Token ¶

func (t *TokenSourceFSStorage) Token() (*oauth2.Token, error)

type TokenV1RoundTripper ¶

type TokenV1RoundTripper struct {
	http.RoundTripper
}

func (*TokenV1RoundTripper) RoundTrip ¶

func (v *TokenV1RoundTripper) RoundTrip(req *http.Request) (*http.Response, error)

type TsuruProxyTransport ¶

type TsuruProxyTransport struct {
	Target   string
	Token    string
	Service  string
	Instance string

	Base http.RoundTripper
}

func (*TsuruProxyTransport) RoundTrip ¶

func (tpt *TsuruProxyTransport) RoundTrip(r *http.Request) (*http.Response, error)

Source Files ¶

View all Source files

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