client

package
v1.8.7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 24, 2018 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Overview

Package client is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
var DefaultCircuitBreakerSettings = CircuitBreakerSettings{
	MaxConcurrentRequests:  100,
	RequestVolumeThreshold: 20,
	SleepWindow:            5000,
	ErrorPercentThreshold:  90,
}

DefaultCircuitBreakerSettings describes the default circuit parameters.

Functions

func WithRetryPolicy added in v0.2.0 

func WithRetryPolicy(ctx context.Context, retryPolicy RetryPolicy) context.Context

WithRetryPolicy returns a new context that overrides the client object's retry policy.

Types

type CircuitBreakerSettings added in v0.1.3 

type CircuitBreakerSettings struct {
	// MaxConcurrentRequests is the maximum number of concurrent requests
	// the client can make at the same time. Default: 100.
	MaxConcurrentRequests int
	// RequestVolumeThreshold is the minimum number of requests needed
	// before a circuit can be tripped due to health. Default: 20.
	RequestVolumeThreshold int
	// SleepWindow how long, in milliseconds, to wait after a circuit opens
	// before testing for recovery. Default: 5000.
	SleepWindow int
	// ErrorPercentThreshold is the threshold to place on the rolling error
	// rate. Once the error rate exceeds this percentage, the circuit opens.
	// Default: 90.
	ErrorPercentThreshold int
}

CircuitBreakerSettings are the parameters that govern the client's circuit breaker.

type Client 

type Client interface {

	// GetAuthors makes a GET request to /authors
	// Gets authors
	// 200: *models.AuthorsResponse
	// 400: *models.BadRequest
	// 500: *models.InternalError
	// default: client side HTTP errors, for example: context.DeadlineExceeded.
	GetAuthors(ctx context.Context, i *models.GetAuthorsInput) (*models.AuthorsResponse, error)

	NewGetAuthorsIter(ctx context.Context, i *models.GetAuthorsInput) (GetAuthorsIter, error)

	// GetAuthorsWithPut makes a PUT request to /authors
	// Gets authors, but needs to use the body so it's a PUT
	// 200: *models.AuthorsResponse
	// 400: *models.BadRequest
	// 500: *models.InternalError
	// default: client side HTTP errors, for example: context.DeadlineExceeded.
	GetAuthorsWithPut(ctx context.Context, i *models.GetAuthorsWithPutInput) (*models.AuthorsResponse, error)

	NewGetAuthorsWithPutIter(ctx context.Context, i *models.GetAuthorsWithPutInput) (GetAuthorsWithPutIter, error)

	// GetBooks makes a GET request to /books
	// Returns a list of books
	// 200: []models.Book
	// 400: *models.BadRequest
	// 500: *models.InternalError
	// default: client side HTTP errors, for example: context.DeadlineExceeded.
	GetBooks(ctx context.Context, i *models.GetBooksInput) ([]models.Book, error)

	NewGetBooksIter(ctx context.Context, i *models.GetBooksInput) (GetBooksIter, error)

	// CreateBook makes a POST request to /books
	// Creates a book
	// 200: *models.Book
	// 400: *models.BadRequest
	// 500: *models.InternalError
	// default: client side HTTP errors, for example: context.DeadlineExceeded.
	CreateBook(ctx context.Context, i *models.Book) (*models.Book, error)

	// PutBook makes a PUT request to /books
	// Puts a book
	// 200: *models.Book
	// 400: *models.BadRequest
	// 500: *models.InternalError
	// default: client side HTTP errors, for example: context.DeadlineExceeded.
	PutBook(ctx context.Context, i *models.Book) (*models.Book, error)

	// GetBookByID makes a GET request to /books/{book_id}
	// Returns a book
	// 200: *models.Book
	// 400: *models.BadRequest
	// 401: *models.Unathorized
	// 404: *models.Error
	// 500: *models.InternalError
	// default: client side HTTP errors, for example: context.DeadlineExceeded.
	GetBookByID(ctx context.Context, i *models.GetBookByIDInput) (*models.Book, error)

	// GetBookByID2 makes a GET request to /books2/{id}
	// Retrieve a book
	// 200: *models.Book
	// 400: *models.BadRequest
	// 404: *models.Error
	// 500: *models.InternalError
	// default: client side HTTP errors, for example: context.DeadlineExceeded.
	GetBookByID2(ctx context.Context, id string) (*models.Book, error)

	// HealthCheck makes a GET request to /health/check
	//
	// 200: nil
	// 400: *models.BadRequest
	// 500: *models.InternalError
	// default: client side HTTP errors, for example: context.DeadlineExceeded.
	HealthCheck(ctx context.Context) error
}

Client defines the methods available to clients of the swagger-test service.

type ExponentialRetryPolicy added in v1.0.0 

type ExponentialRetryPolicy struct{}

ExponentialRetryPolicy defines an exponential retry policy

func (ExponentialRetryPolicy) Backoffs added in v1.0.0 

func (ExponentialRetryPolicy) Backoffs() []time.Duration

Backoffs returns five backoffs with exponentially increasing wait times between requests: 100, 200, 400, 800, and 1600 milliseconds +/- up to 5% jitter.

func (ExponentialRetryPolicy) Retry added in v1.0.0 

func (ExponentialRetryPolicy) Retry(req *http.Request, resp *http.Response, err error) bool

Retry will retry non-POST, non-PATCH requests that 5XX. TODO: It does not currently retry any errors returned by net/http.Client's `Do`.

type GetAuthorsIter added in v1.3.0 

type GetAuthorsIter interface {
	Next(*models.Author) bool
	Err() error
}

GetAuthorsIter defines the methods available on GetAuthors iterators.

type GetAuthorsWithPutIter added in v1.5.0 

type GetAuthorsWithPutIter interface {
	Next(*models.Author) bool
	Err() error
}

GetAuthorsWithPutIter defines the methods available on GetAuthorsWithPut iterators.

type GetBooksIter added in v1.3.0 

type GetBooksIter interface {
	Next(*models.Book) bool
	Err() error
}

GetBooksIter defines the methods available on GetBooks iterators.

type HystrixSSEEvent added in v0.1.3 

type HystrixSSEEvent struct {
	Type                            string `json:"type"`
	Name                            string `json:"name"`
	RequestCount                    int    `json:"requestCount"`
	ErrorCount                      int    `json:"errorCount"`
	ErrorPercentage                 int    `json:"errorPercentage"`
	IsCircuitBreakerOpen            bool   `json:"isCircuitBreakerOpen"`
	RollingCountFailure             int    `json:"rollingCountFailure"`
	RollingCountFallbackFailure     int    `json:"rollingCountFallbackFailure"`
	RollingCountFallbackSuccess     int    `json:"rollingCountFallbackSuccess"`
	RollingCountShortCircuited      int    `json:"rollingCountShortCircuited"`
	RollingCountSuccess             int    `json:"rollingCountSuccess"`
	RollingCountThreadPoolRejected  int    `json:"rollingCountThreadPoolRejected"`
	RollingCountTimeout             int    `json:"rollingCountTimeout"`
	CurrentConcurrentExecutionCount int    `json:"currentConcurrentExecutionCount"`
	LatencyTotalMean                int    `json:"latencyTotal_mean"`
}

HystrixSSEEvent is emitted by hystrix-go via server-sent events. It describes the state of a circuit.

type MockClient 

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

MockClient is a mock of Client interface

func NewMockClient 

func NewMockClient(ctrl *gomock.Controller) *MockClient

NewMockClient creates a new mock instance

func (*MockClient) CreateBook 

func (m *MockClient) CreateBook(ctx context.Context, i *models.Book) (*models.Book, error)

CreateBook mocks base method

func (*MockClient) EXPECT 

func (m *MockClient) EXPECT() *MockClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockClient) GetAuthors added in v1.3.0 

func (m *MockClient) GetAuthors(ctx context.Context, i *models.GetAuthorsInput) (*models.AuthorsResponse, error)

GetAuthors mocks base method

func (*MockClient) GetAuthorsWithPut added in v1.5.0 

func (m *MockClient) GetAuthorsWithPut(ctx context.Context, i *models.GetAuthorsWithPutInput) (*models.AuthorsResponse, error)

GetAuthorsWithPut mocks base method

func (*MockClient) GetBookByID 

func (m *MockClient) GetBookByID(ctx context.Context, i *models.GetBookByIDInput) (*models.Book, error)

GetBookByID mocks base method

func (*MockClient) GetBookByID2 

func (m *MockClient) GetBookByID2(ctx context.Context, id string) (*models.Book, error)

GetBookByID2 mocks base method

func (*MockClient) GetBooks 

func (m *MockClient) GetBooks(ctx context.Context, i *models.GetBooksInput) ([]models.Book, error)

GetBooks mocks base method

func (*MockClient) HealthCheck 

func (m *MockClient) HealthCheck(ctx context.Context) error

HealthCheck mocks base method

func (*MockClient) NewGetAuthorsIter added in v1.3.0 

func (m *MockClient) NewGetAuthorsIter(ctx context.Context, i *models.GetAuthorsInput) (GetAuthorsIter, error)

NewGetAuthorsIter mocks base method

func (*MockClient) NewGetAuthorsWithPutIter added in v1.5.0 

func (m *MockClient) NewGetAuthorsWithPutIter(ctx context.Context, i *models.GetAuthorsWithPutInput) (GetAuthorsWithPutIter, error)

NewGetAuthorsWithPutIter mocks base method

func (*MockClient) NewGetBooksIter added in v1.3.0 

func (m *MockClient) NewGetBooksIter(ctx context.Context, i *models.GetBooksInput) (GetBooksIter, error)

NewGetBooksIter mocks base method

func (*MockClient) PutBook added in v1.4.3 

func (m *MockClient) PutBook(ctx context.Context, i *models.Book) (*models.Book, error)

PutBook mocks base method

type MockClientMockRecorder added in v1.5.1 

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

MockClientMockRecorder is the mock recorder for MockClient

func (*MockClientMockRecorder) CreateBook added in v1.5.1 

func (mr *MockClientMockRecorder) CreateBook(ctx, i interface{}) *gomock.Call

CreateBook indicates an expected call of CreateBook

func (*MockClientMockRecorder) GetAuthors added in v1.5.1 

func (mr *MockClientMockRecorder) GetAuthors(ctx, i interface{}) *gomock.Call

GetAuthors indicates an expected call of GetAuthors

func (*MockClientMockRecorder) GetAuthorsWithPut added in v1.5.1 

func (mr *MockClientMockRecorder) GetAuthorsWithPut(ctx, i interface{}) *gomock.Call

GetAuthorsWithPut indicates an expected call of GetAuthorsWithPut

func (*MockClientMockRecorder) GetBookByID added in v1.5.1 

func (mr *MockClientMockRecorder) GetBookByID(ctx, i interface{}) *gomock.Call

GetBookByID indicates an expected call of GetBookByID

func (*MockClientMockRecorder) GetBookByID2 added in v1.5.1 

func (mr *MockClientMockRecorder) GetBookByID2(ctx, id interface{}) *gomock.Call

GetBookByID2 indicates an expected call of GetBookByID2

func (*MockClientMockRecorder) GetBooks added in v1.5.1 

func (mr *MockClientMockRecorder) GetBooks(ctx, i interface{}) *gomock.Call

GetBooks indicates an expected call of GetBooks

func (*MockClientMockRecorder) HealthCheck added in v1.5.1 

func (mr *MockClientMockRecorder) HealthCheck(ctx interface{}) *gomock.Call

HealthCheck indicates an expected call of HealthCheck

func (*MockClientMockRecorder) NewGetAuthorsIter added in v1.5.1 

func (mr *MockClientMockRecorder) NewGetAuthorsIter(ctx, i interface{}) *gomock.Call

NewGetAuthorsIter indicates an expected call of NewGetAuthorsIter

func (*MockClientMockRecorder) NewGetAuthorsWithPutIter added in v1.5.1 

func (mr *MockClientMockRecorder) NewGetAuthorsWithPutIter(ctx, i interface{}) *gomock.Call

NewGetAuthorsWithPutIter indicates an expected call of NewGetAuthorsWithPutIter

func (*MockClientMockRecorder) NewGetBooksIter added in v1.5.1 

func (mr *MockClientMockRecorder) NewGetBooksIter(ctx, i interface{}) *gomock.Call

NewGetBooksIter indicates an expected call of NewGetBooksIter

func (*MockClientMockRecorder) PutBook added in v1.5.1 

func (mr *MockClientMockRecorder) PutBook(ctx, i interface{}) *gomock.Call

PutBook indicates an expected call of PutBook

type MockGetAuthorsIter added in v1.3.0 

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

MockGetAuthorsIter is a mock of GetAuthorsIter interface

func NewMockGetAuthorsIter added in v1.3.0 

func NewMockGetAuthorsIter(ctrl *gomock.Controller) *MockGetAuthorsIter

NewMockGetAuthorsIter creates a new mock instance

func (*MockGetAuthorsIter) EXPECT added in v1.3.0 

func (m *MockGetAuthorsIter) EXPECT() *MockGetAuthorsIterMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockGetAuthorsIter) Err added in v1.3.0 

func (m *MockGetAuthorsIter) Err() error

Err mocks base method

func (*MockGetAuthorsIter) Next added in v1.3.0 

func (m *MockGetAuthorsIter) Next(arg0 *models.Author) bool

Next mocks base method

type MockGetAuthorsIterMockRecorder added in v1.5.1 

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

MockGetAuthorsIterMockRecorder is the mock recorder for MockGetAuthorsIter

func (*MockGetAuthorsIterMockRecorder) Err added in v1.5.1 

func (mr *MockGetAuthorsIterMockRecorder) Err() *gomock.Call

Err indicates an expected call of Err

func (*MockGetAuthorsIterMockRecorder) Next added in v1.5.1 

func (mr *MockGetAuthorsIterMockRecorder) Next(arg0 interface{}) *gomock.Call

Next indicates an expected call of Next

type MockGetAuthorsWithPutIter added in v1.5.0 

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

MockGetAuthorsWithPutIter is a mock of GetAuthorsWithPutIter interface

func NewMockGetAuthorsWithPutIter added in v1.5.0 

func NewMockGetAuthorsWithPutIter(ctrl *gomock.Controller) *MockGetAuthorsWithPutIter

NewMockGetAuthorsWithPutIter creates a new mock instance

func (*MockGetAuthorsWithPutIter) EXPECT added in v1.5.0 

func (m *MockGetAuthorsWithPutIter) EXPECT() *MockGetAuthorsWithPutIterMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockGetAuthorsWithPutIter) Err added in v1.5.0 

func (m *MockGetAuthorsWithPutIter) Err() error

Err mocks base method

func (*MockGetAuthorsWithPutIter) Next added in v1.5.0 

func (m *MockGetAuthorsWithPutIter) Next(arg0 *models.Author) bool

Next mocks base method

type MockGetAuthorsWithPutIterMockRecorder added in v1.5.1 

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

MockGetAuthorsWithPutIterMockRecorder is the mock recorder for MockGetAuthorsWithPutIter

func (*MockGetAuthorsWithPutIterMockRecorder) Err added in v1.5.1 

func (mr *MockGetAuthorsWithPutIterMockRecorder) Err() *gomock.Call

Err indicates an expected call of Err

func (*MockGetAuthorsWithPutIterMockRecorder) Next added in v1.5.1 

func (mr *MockGetAuthorsWithPutIterMockRecorder) Next(arg0 interface{}) *gomock.Call

Next indicates an expected call of Next

type MockGetBooksIter added in v1.3.0 

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

MockGetBooksIter is a mock of GetBooksIter interface

func NewMockGetBooksIter added in v1.3.0 

func NewMockGetBooksIter(ctrl *gomock.Controller) *MockGetBooksIter

NewMockGetBooksIter creates a new mock instance

func (*MockGetBooksIter) EXPECT added in v1.3.0 

func (m *MockGetBooksIter) EXPECT() *MockGetBooksIterMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockGetBooksIter) Err added in v1.3.0 

func (m *MockGetBooksIter) Err() error

Err mocks base method

func (*MockGetBooksIter) Next added in v1.3.0 

func (m *MockGetBooksIter) Next(arg0 *models.Book) bool

Next mocks base method

type MockGetBooksIterMockRecorder added in v1.5.1 

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

MockGetBooksIterMockRecorder is the mock recorder for MockGetBooksIter

func (*MockGetBooksIterMockRecorder) Err added in v1.5.1 

func (mr *MockGetBooksIterMockRecorder) Err() *gomock.Call

Err indicates an expected call of Err

func (*MockGetBooksIterMockRecorder) Next added in v1.5.1 

func (mr *MockGetBooksIterMockRecorder) Next(arg0 interface{}) *gomock.Call

Next indicates an expected call of Next

type NoRetryPolicy added in v0.2.0 

type NoRetryPolicy struct{}

NoRetryPolicy defines a policy of never retrying a request.

func (NoRetryPolicy) Backoffs added in v0.2.0 

func (NoRetryPolicy) Backoffs() []time.Duration

Backoffs returns an empty slice.

func (NoRetryPolicy) Retry added in v0.2.0 

func (NoRetryPolicy) Retry(*http.Request, *http.Response, error) bool

Retry always returns false.

type RetryPolicy added in v0.2.0 

type RetryPolicy interface {
	// Backoffs returns the number and timing of retry attempts.
	Backoffs() []time.Duration
	// Retry receives the http request, as well as the result of
	// net/http.Client's `Do` method.
	Retry(*http.Request, *http.Response, error) bool
}

RetryPolicy defines a retry policy.

type SingleRetryPolicy added in v1.0.0 

type SingleRetryPolicy struct{}

SingleRetryPolicy defines a retry that retries a request once

func (SingleRetryPolicy) Backoffs added in v1.0.0 

func (SingleRetryPolicy) Backoffs() []time.Duration

Backoffs returns that you should retry the request 1second after it fails.

func (SingleRetryPolicy) Retry added in v1.0.0 

func (SingleRetryPolicy) Retry(req *http.Request, resp *http.Response, err error) bool

Retry will retry non-POST, non-PATCH requests that 5XX. TODO: It does not currently retry any errors returned by net/http.Client's `Do`.

type WagClient 

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

WagClient is used to make requests to the swagger-test service.

func New 

func New(basePath string) *WagClient

New creates a new client. The base path and http transport are configurable.

func NewFromDiscovery 

func NewFromDiscovery() (*WagClient, error)

NewFromDiscovery creates a client from the discovery environment variables. This method requires the three env vars: SERVICE_SWAGGER_TEST_HTTP_(HOST/PORT/PROTO) to be set. Otherwise it returns an error.

func (*WagClient) CreateBook 

func (c *WagClient) CreateBook(ctx context.Context, i *models.Book) (*models.Book, error)

CreateBook makes a POST request to /books Creates a book 200: *models.Book 400: *models.BadRequest 500: *models.InternalError default: client side HTTP errors, for example: context.DeadlineExceeded.

func (*WagClient) GetAuthors added in v1.3.0 

func (c *WagClient) GetAuthors(ctx context.Context, i *models.GetAuthorsInput) (*models.AuthorsResponse, error)

GetAuthors makes a GET request to /authors Gets authors 200: *models.AuthorsResponse 400: *models.BadRequest 500: *models.InternalError default: client side HTTP errors, for example: context.DeadlineExceeded.

func (*WagClient) GetAuthorsWithPut added in v1.5.0 

func (c *WagClient) GetAuthorsWithPut(ctx context.Context, i *models.GetAuthorsWithPutInput) (*models.AuthorsResponse, error)

GetAuthorsWithPut makes a PUT request to /authors Gets authors, but needs to use the body so it's a PUT 200: *models.AuthorsResponse 400: *models.BadRequest 500: *models.InternalError default: client side HTTP errors, for example: context.DeadlineExceeded.

func (*WagClient) GetBookByID 

func (c *WagClient) GetBookByID(ctx context.Context, i *models.GetBookByIDInput) (*models.Book, error)

GetBookByID makes a GET request to /books/{book_id} Returns a book 200: *models.Book 400: *models.BadRequest 401: *models.Unathorized 404: *models.Error 500: *models.InternalError default: client side HTTP errors, for example: context.DeadlineExceeded.

func (*WagClient) GetBookByID2 

func (c *WagClient) GetBookByID2(ctx context.Context, id string) (*models.Book, error)

GetBookByID2 makes a GET request to /books2/{id} Retrieve a book 200: *models.Book 400: *models.BadRequest 404: *models.Error 500: *models.InternalError default: client side HTTP errors, for example: context.DeadlineExceeded.

func (*WagClient) GetBooks 

func (c *WagClient) GetBooks(ctx context.Context, i *models.GetBooksInput) ([]models.Book, error)

GetBooks makes a GET request to /books Returns a list of books 200: []models.Book 400: *models.BadRequest 500: *models.InternalError default: client side HTTP errors, for example: context.DeadlineExceeded.

func (*WagClient) HealthCheck 

func (c *WagClient) HealthCheck(ctx context.Context) error

HealthCheck makes a GET request to /health/check

200: nil 400: *models.BadRequest 500: *models.InternalError default: client side HTTP errors, for example: context.DeadlineExceeded.

func (*WagClient) NewGetAuthorsIter added in v1.3.0 

func (c *WagClient) NewGetAuthorsIter(ctx context.Context, i *models.GetAuthorsInput) (GetAuthorsIter, error)

NewgetAuthorsIter constructs an iterator that makes calls to getAuthors for each page.

func (*WagClient) NewGetAuthorsWithPutIter added in v1.5.0 

func (c *WagClient) NewGetAuthorsWithPutIter(ctx context.Context, i *models.GetAuthorsWithPutInput) (GetAuthorsWithPutIter, error)

NewgetAuthorsWithPutIter constructs an iterator that makes calls to getAuthorsWithPut for each page.

func (*WagClient) NewGetBooksIter added in v1.3.0 

func (c *WagClient) NewGetBooksIter(ctx context.Context, i *models.GetBooksInput) (GetBooksIter, error)

NewgetBooksIter constructs an iterator that makes calls to getBooks for each page.

func (*WagClient) PutBook added in v1.4.3 

func (c *WagClient) PutBook(ctx context.Context, i *models.Book) (*models.Book, error)

PutBook makes a PUT request to /books Puts a book 200: *models.Book 400: *models.BadRequest 500: *models.InternalError default: client side HTTP errors, for example: context.DeadlineExceeded.

func (*WagClient) SetCircuitBreakerDebug added in v0.1.3 

func (c *WagClient) SetCircuitBreakerDebug(b bool)

SetCircuitBreakerDebug puts the circuit

func (*WagClient) SetCircuitBreakerSettings added in v0.1.3 

func (c *WagClient) SetCircuitBreakerSettings(settings CircuitBreakerSettings)

SetCircuitBreakerSettings sets parameters on the circuit breaker. It must be called on application startup.

func (*WagClient) SetLogger added in v1.0.3 

func (c *WagClient) SetLogger(logger logger.KayveeLogger)

SetLogger allows for setting a custom logger

func (*WagClient) SetRetryPolicy added in v1.0.0 

func (c *WagClient) SetRetryPolicy(retryPolicy RetryPolicy)

SetRetryPolicy sets a the given retry policy for all requests.

func (*WagClient) SetTimeout added in v1.0.0 

func (c *WagClient) SetTimeout(timeout time.Duration)

SetTimeout sets a timeout on all operations for the client. To make a single request with a timeout use context.WithTimeout as described here: https://godoc.org/golang.org/x/net/context#WithTimeout.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.