Documentation
¶
Index ¶
- func AddTableSubscriptionsPath() string
- func BuildAddTablePayload(subscriptionsAddTableBody string) (*subscriptions.SubscriptionPublishedTable, error)
- func BuildStopTablePayload(subscriptionsStopTableBody string) (*subscriptions.SubscriptionPublishedTable, error)
- func DecodeAddTableResponse(decoder func(*http.Response) goahttp.Decoder, restoreBody bool) func(*http.Response) (interface{}, error)
- func DecodeGetResponse(decoder func(*http.Response) goahttp.Decoder, restoreBody bool) func(*http.Response) (interface{}, error)
- func DecodeStopTableResponse(decoder func(*http.Response) goahttp.Decoder, restoreBody bool) func(*http.Response) (interface{}, error)
- func EncodeAddTableRequest(encoder func(*http.Request) goahttp.Encoder) func(*http.Request, interface{}) error
- func EncodeStopTableRequest(encoder func(*http.Request) goahttp.Encoder) func(*http.Request, interface{}) error
- func GetSubscriptionsPath() string
- func NewAddTableSubscriptionCreated(body *AddTableResponseBody) *subscriptions.Subscription
- func NewGetSubscriptionCreated(body *GetResponseBody) *subscriptions.Subscription
- func NewStopTableSubscriptionAccepted(body *StopTableResponseBody) *subscriptions.Subscription
- func StopTableSubscriptionsPath() string
- func ValidateAddTableResponseBody(body *AddTableResponseBody) (err error)
- func ValidateGetResponseBody(body *GetResponseBody) (err error)
- func ValidateStopTableResponseBody(body *StopTableResponseBody) (err error)
- func ValidateSubscriptionPublishedTableResponseBody(body *SubscriptionPublishedTableResponseBody) (err error)
- type AddTableRequestBody
- type AddTableResponseBody
- type Client
- func (c *Client) AddTable() goa.Endpoint
- func (c *Client) BuildAddTableRequest(ctx context.Context, v interface{}) (*http.Request, error)
- func (c *Client) BuildGetRequest(ctx context.Context, v interface{}) (*http.Request, error)
- func (c *Client) BuildStopTableRequest(ctx context.Context, v interface{}) (*http.Request, error)
- func (c *Client) Get() goa.Endpoint
- func (c *Client) StopTable() goa.Endpoint
- type GetResponseBody
- type StopTableRequestBody
- type StopTableResponseBody
- type SubscriptionPublishedTableResponseBody
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddTableSubscriptionsPath ¶
func AddTableSubscriptionsPath() string
AddTableSubscriptionsPath returns the URL path to the Subscriptions service AddTable HTTP endpoint.
func BuildAddTablePayload ¶
func BuildAddTablePayload(subscriptionsAddTableBody string) (*subscriptions.SubscriptionPublishedTable, error)
BuildAddTablePayload builds the payload for the Subscriptions AddTable endpoint from CLI flags.
func BuildStopTablePayload ¶
func BuildStopTablePayload(subscriptionsStopTableBody string) (*subscriptions.SubscriptionPublishedTable, error)
BuildStopTablePayload builds the payload for the Subscriptions StopTable endpoint from CLI flags.
func DecodeAddTableResponse ¶
func DecodeAddTableResponse(decoder func(*http.Response) goahttp.Decoder, restoreBody bool) func(*http.Response) (interface{}, error)
DecodeAddTableResponse returns a decoder for responses returned by the Subscriptions AddTable endpoint. restoreBody controls whether the response body should be restored after having been read.
func DecodeGetResponse ¶
func DecodeGetResponse(decoder func(*http.Response) goahttp.Decoder, restoreBody bool) func(*http.Response) (interface{}, error)
DecodeGetResponse returns a decoder for responses returned by the Subscriptions Get endpoint. restoreBody controls whether the response body should be restored after having been read.
func DecodeStopTableResponse ¶
func DecodeStopTableResponse(decoder func(*http.Response) goahttp.Decoder, restoreBody bool) func(*http.Response) (interface{}, error)
DecodeStopTableResponse returns a decoder for responses returned by the Subscriptions StopTable endpoint. restoreBody controls whether the response body should be restored after having been read.
func EncodeAddTableRequest ¶
func EncodeAddTableRequest(encoder func(*http.Request) goahttp.Encoder) func(*http.Request, interface{}) error
EncodeAddTableRequest returns an encoder for requests sent to the Subscriptions AddTable server.
func EncodeStopTableRequest ¶
func EncodeStopTableRequest(encoder func(*http.Request) goahttp.Encoder) func(*http.Request, interface{}) error
EncodeStopTableRequest returns an encoder for requests sent to the Subscriptions StopTable server.
func GetSubscriptionsPath ¶
func GetSubscriptionsPath() string
GetSubscriptionsPath returns the URL path to the Subscriptions service Get HTTP endpoint.
func NewAddTableSubscriptionCreated ¶
func NewAddTableSubscriptionCreated(body *AddTableResponseBody) *subscriptions.Subscription
NewAddTableSubscriptionCreated builds a "Subscriptions" service "AddTable" endpoint result from a HTTP "Created" response.
func NewGetSubscriptionCreated ¶
func NewGetSubscriptionCreated(body *GetResponseBody) *subscriptions.Subscription
NewGetSubscriptionCreated builds a "Subscriptions" service "Get" endpoint result from a HTTP "Created" response.
func NewStopTableSubscriptionAccepted ¶
func NewStopTableSubscriptionAccepted(body *StopTableResponseBody) *subscriptions.Subscription
NewStopTableSubscriptionAccepted builds a "Subscriptions" service "StopTable" endpoint result from a HTTP "Accepted" response.
func StopTableSubscriptionsPath ¶
func StopTableSubscriptionsPath() string
StopTableSubscriptionsPath returns the URL path to the Subscriptions service StopTable HTTP endpoint.
func ValidateAddTableResponseBody ¶
func ValidateAddTableResponseBody(body *AddTableResponseBody) (err error)
ValidateAddTableResponseBody runs the validations defined on AddTableResponseBody
func ValidateGetResponseBody ¶
func ValidateGetResponseBody(body *GetResponseBody) (err error)
ValidateGetResponseBody runs the validations defined on GetResponseBody
func ValidateStopTableResponseBody ¶
func ValidateStopTableResponseBody(body *StopTableResponseBody) (err error)
ValidateStopTableResponseBody runs the validations defined on StopTableResponseBody
func ValidateSubscriptionPublishedTableResponseBody ¶
func ValidateSubscriptionPublishedTableResponseBody(body *SubscriptionPublishedTableResponseBody) (err error)
ValidateSubscriptionPublishedTableResponseBody runs the validations defined on SubscriptionPublishedTableResponseBody
Types ¶
type AddTableRequestBody ¶
type AddTableRequestBody struct {
// Postgres table schema
Schema string `form:"schema" json:"schema" xml:"schema"`
// Postgres table name
Name string `form:"name" json:"name" xml:"name"`
}
AddTableRequestBody is the type of the "Subscriptions" service "AddTable" endpoint HTTP request body.
func NewAddTableRequestBody ¶
func NewAddTableRequestBody(p *subscriptions.SubscriptionPublishedTable) *AddTableRequestBody
NewAddTableRequestBody builds the HTTP request body from the payload of the "AddTable" endpoint of the "Subscriptions" service.
type AddTableResponseBody ¶
type AddTableResponseBody struct {
// ID of subscription
ID *string `form:"id,omitempty" json:"id,omitempty" xml:"id,omitempty"`
// List of published tables
PublishedTables []*SubscriptionPublishedTableResponseBody `form:"published_tables,omitempty" json:"published_tables,omitempty" xml:"published_tables,omitempty"`
}
AddTableResponseBody is the type of the "Subscriptions" service "AddTable" endpoint HTTP response body.
type Client ¶
type Client struct {
// Get Doer is the HTTP client used to make requests to the Get endpoint.
GetDoer goahttp.Doer
// AddTable Doer is the HTTP client used to make requests to the AddTable
// endpoint.
AddTableDoer goahttp.Doer
// StopTable Doer is the HTTP client used to make requests to the StopTable
// endpoint.
StopTableDoer 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 Subscriptions 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 Subscriptions service servers.
func (*Client) AddTable ¶
AddTable returns an endpoint that makes HTTP requests to the Subscriptions service AddTable server.
func (*Client) BuildAddTableRequest ¶
BuildAddTableRequest instantiates a HTTP request object with method and path set to call the "Subscriptions" service "AddTable" endpoint
func (*Client) BuildGetRequest ¶
BuildGetRequest instantiates a HTTP request object with method and path set to call the "Subscriptions" service "Get" endpoint
func (*Client) BuildStopTableRequest ¶
BuildStopTableRequest instantiates a HTTP request object with method and path set to call the "Subscriptions" service "StopTable" endpoint
type GetResponseBody ¶
type GetResponseBody struct {
// ID of subscription
ID *string `form:"id,omitempty" json:"id,omitempty" xml:"id,omitempty"`
// List of published tables
PublishedTables []*SubscriptionPublishedTableResponseBody `form:"published_tables,omitempty" json:"published_tables,omitempty" xml:"published_tables,omitempty"`
}
GetResponseBody is the type of the "Subscriptions" service "Get" endpoint HTTP response body.
type StopTableRequestBody ¶
type StopTableRequestBody struct {
// Postgres table schema
Schema string `form:"schema" json:"schema" xml:"schema"`
// Postgres table name
Name string `form:"name" json:"name" xml:"name"`
}
StopTableRequestBody is the type of the "Subscriptions" service "StopTable" endpoint HTTP request body.
func NewStopTableRequestBody ¶
func NewStopTableRequestBody(p *subscriptions.SubscriptionPublishedTable) *StopTableRequestBody
NewStopTableRequestBody builds the HTTP request body from the payload of the "StopTable" endpoint of the "Subscriptions" service.
type StopTableResponseBody ¶
type StopTableResponseBody struct {
// ID of subscription
ID *string `form:"id,omitempty" json:"id,omitempty" xml:"id,omitempty"`
// List of published tables
PublishedTables []*SubscriptionPublishedTableResponseBody `form:"published_tables,omitempty" json:"published_tables,omitempty" xml:"published_tables,omitempty"`
}
StopTableResponseBody is the type of the "Subscriptions" service "StopTable" endpoint HTTP response body.
type SubscriptionPublishedTableResponseBody ¶
type SubscriptionPublishedTableResponseBody 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"`
}
SubscriptionPublishedTableResponseBody is used to define fields on response body types.
Source Files