client

Documentation

Index

• func BuildListPayload(tablesListSchema string) (*tables.ListPayload, error)
• func DecodeListResponse(decoder func(*http.Response) goahttp.Decoder, restoreBody bool) func(*http.Response) (interface{}, error)
• func EncodeListRequest(encoder func(*http.Request) goahttp.Encoder) func(*http.Request, interface{}) error
• func ListTablesPath() string
• func NewListTableOK(body []*TableResponse) []*tables.Table
• func ValidateTableResponse(body *TableResponse) (err error)
• type Client
  • func NewClient(scheme string, host string, doer goahttp.Doer, ...) *Client
  • func (c *Client) BuildListRequest(ctx context.Context, v interface{}) (*http.Request, error)
  • func (c *Client) List() goa.Endpoint
• type ListResponseBody
• type TableResponse

Functions

func BuildListPayload

func BuildListPayload(tablesListSchema string) (*tables.ListPayload, error)

BuildListPayload builds the payload for the Tables List endpoint from CLI flags.

func DecodeListResponse

func DecodeListResponse(decoder func(*http.Response) goahttp.Decoder, restoreBody bool) func(*http.Response) (interface{}, error)

DecodeListResponse returns a decoder for responses returned by the Tables List endpoint. restoreBody controls whether the response body should be restored after having been read.

func EncodeListRequest

func EncodeListRequest(encoder func(*http.Request) goahttp.Encoder) func(*http.Request, interface{}) error

EncodeListRequest returns an encoder for requests sent to the Tables List server.

func ListTablesPath

func ListTablesPath() string

ListTablesPath returns the URL path to the Tables service List HTTP endpoint.

func NewListTableOK

func NewListTableOK(body []*TableResponse) []*tables.Table

NewListTableOK builds a "Tables" service "List" endpoint result from a HTTP "OK" response.

func ValidateTableResponse

func ValidateTableResponse(body *TableResponse) (err error)

ValidateTableResponse runs the validations defined on TableResponse

Types

type Client

type Client struct {
	// List Doer is the HTTP client used to make requests to the List endpoint.
	ListDoer goahttp.Doer

	// RestoreResponseBody controls whether the response bodies are reset after
	// decoding so they can be read again.
	RestoreResponseBody bool
	// contains filtered or unexported fields
}

Client lists the Tables service endpoint HTTP clients.

func NewClient

func NewClient(
	scheme string,
	host string,
	doer goahttp.Doer,
	enc func(*http.Request) goahttp.Encoder,
	dec func(*http.Response) goahttp.Decoder,
	restoreBody bool,
) *Client

NewClient instantiates HTTP clients for all the Tables service servers.

func (*Client) BuildListRequest

func (c *Client) BuildListRequest(ctx context.Context, v interface{}) (*http.Request, error)

BuildListRequest instantiates a HTTP request object with method and path set to call the "Tables" service "List" endpoint

func (*Client) List

func (c *Client) List() goa.Endpoint

List returns an endpoint that makes HTTP requests to the Tables service List server.

type ListResponseBody

type ListResponseBody []*TableResponse

ListResponseBody is the type of the "Tables" service "List" endpoint HTTP response body.

type TableResponse

type TableResponse struct {
	// Postgres table schema
	Schema *string `form:"schema,omitempty" json:"schema,omitempty" xml:"schema,omitempty"`
	// Postgres table name
	Name *string `form:"name,omitempty" json:"name,omitempty" xml:"name,omitempty"`
	// Table row estimate, using pg_stats
	ApproximateRowCount *int64 `form:"approximate_row_count,omitempty" json:"approximate_row_count,omitempty" xml:"approximate_row_count,omitempty"`
	// Status of the publication, set to active when table is streaming
	PublicationStatus *string `form:"publication_status,omitempty" json:"publication_status,omitempty" xml:"publication_status,omitempty"`
	// Status of table imports
	ImportStatus *string `form:"import_status,omitempty" json:"import_status,omitempty" xml:"import_status,omitempty"`
	// Last active import rows processed total
	ImportRowsProcessedTotal *int64 `` /* 133-byte string literal not displayed */
}

TableResponse is used to define fields on response body types.