endpoint

Documentation

Index

• func DecodeAuthenticationStrategyHookFunc() mapstructure.DecodeHookFunc
• func DecodeEndpointHookFunc() mapstructure.DecodeHookFunc
• type APIKeyStrategy
  • func (c *APIKeyStrategy) Apply(_ context.Context, req *http.Request) error
  • func (c *APIKeyStrategy) Hash() []byte
• type AuthenticationStrategy
• type BasicAuthStrategy
  • func (c *BasicAuthStrategy) Apply(_ context.Context, req *http.Request) error
  • func (c *BasicAuthStrategy) Hash() []byte
• type ClientCredentialsStrategy
  • func (c *ClientCredentialsStrategy) Apply(ctx context.Context, req *http.Request) error
  • func (c *ClientCredentialsStrategy) Hash() []byte
• type Endpoint
  • func (e Endpoint) CreateClient(peerName string) *http.Client
  • func (e Endpoint) CreateRequest(ctx context.Context, body io.Reader, rndr Renderer) (*http.Request, error)
  • func (e Endpoint) Hash() []byte
  • func (e Endpoint) SendRequest(ctx context.Context, body io.Reader, renderer Renderer) ([]byte, error)
  • func (e Endpoint) Validate() error
• type RenderFunc
  • func (f RenderFunc) Render(template string, values map[string]string) (string, error)
• type Renderer
• type Retry
• type Values
  • func (v Values) Merge(other Values) Values

Functions

func DecodeAuthenticationStrategyHookFunc

func DecodeAuthenticationStrategyHookFunc() mapstructure.DecodeHookFunc

func DecodeEndpointHookFunc

func DecodeEndpointHookFunc() mapstructure.DecodeHookFunc

Types

type APIKeyStrategy

type APIKeyStrategy struct {
	In    string `mapstructure:"in"`
	Name  string `mapstructure:"name"`
	Value string `mapstructure:"value"`
}

func (*APIKeyStrategy) Apply

func (c *APIKeyStrategy) Apply(_ context.Context, req *http.Request) error

func (*APIKeyStrategy) Hash

func (c *APIKeyStrategy) Hash() []byte

type AuthenticationStrategy

type AuthenticationStrategy interface {
	Apply(context.Context, *http.Request) error
	Hash() []byte
}

type BasicAuthStrategy

type BasicAuthStrategy struct {
	User     string `mapstructure:"user"`
	Password string `mapstructure:"password"`
}

func (*BasicAuthStrategy) Apply

func (c *BasicAuthStrategy) Apply(_ context.Context, req *http.Request) error

func (*BasicAuthStrategy) Hash

func (c *BasicAuthStrategy) Hash() []byte

type ClientCredentialsStrategy

type ClientCredentialsStrategy struct {
	ClientID     string   `mapstructure:"client_id"`
	ClientSecret string   `mapstructure:"client_secret"`
	Scopes       []string `mapstructure:"scopes"`
	TokenURL     string   `mapstructure:"token_url"`
}

func (*ClientCredentialsStrategy) Apply

func (c *ClientCredentialsStrategy) Apply(ctx context.Context, req *http.Request) error

func (*ClientCredentialsStrategy) Hash

func (c *ClientCredentialsStrategy) Hash() []byte

type Endpoint

type Endpoint struct {
	URL              string                 `mapstructure:"url"`
	Method           string                 `mapstructure:"method"`
	Retry            *Retry                 `mapstructure:"retry"`
	AuthStrategy     AuthenticationStrategy `mapstructure:"auth"`
	Headers          map[string]string      `mapstructure:"headers"`
	HTTPCacheEnabled *bool                  `mapstructure:"enable_http_cache"`
	Values           Values                 `mapstructure:"values"`
}

func (Endpoint) CreateClient

func (e Endpoint) CreateClient(peerName string) *http.Client

func (Endpoint) CreateRequest

func (e Endpoint) CreateRequest(ctx context.Context, body io.Reader, rndr Renderer) (*http.Request, error)

func (Endpoint) Hash

func (e Endpoint) Hash() []byte

func (Endpoint) SendRequest

func (e Endpoint) SendRequest(ctx context.Context, body io.Reader, renderer Renderer) ([]byte, error)

func (Endpoint) Validate

func (e Endpoint) Validate() error

type RenderFunc

type RenderFunc func(template string, values map[string]string) (string, error)

func (RenderFunc) Render

func (f RenderFunc) Render(template string, values map[string]string) (string, error)

type Renderer

type Renderer interface {
	Render(template string, values map[string]string) (string, error)
}

type Retry

type Retry struct {
	GiveUpAfter time.Duration `mapstructure:"give_up_after"`
	MaxDelay    time.Duration `mapstructure:"max_delay"`
}

type Values

type Values map[string]string

func (Values) Merge

func (v Values) Merge(other Values) Values