server

Documentation

Index

• func AddTableSubscriptionsPath() string
• func DecodeAddTableRequest(mux goahttp.Muxer, decoder func(*http.Request) goahttp.Decoder) func(*http.Request) (interface{}, error)
• func DecodeStopTableRequest(mux goahttp.Muxer, decoder func(*http.Request) goahttp.Decoder) func(*http.Request) (interface{}, error)
• func EncodeAddTableResponse(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder) func(context.Context, http.ResponseWriter, interface{}) error
• func EncodeGetResponse(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder) func(context.Context, http.ResponseWriter, interface{}) error
• func EncodeStopTableResponse(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder) func(context.Context, http.ResponseWriter, interface{}) error
• func GetSubscriptionsPath() string
• func Mount(mux goahttp.Muxer, h *Server)
• func MountAddTableHandler(mux goahttp.Muxer, h http.Handler)
• func MountGetHandler(mux goahttp.Muxer, h http.Handler)
• func MountStopTableHandler(mux goahttp.Muxer, h http.Handler)
• func NewAddTableHandler(endpoint goa.Endpoint, mux goahttp.Muxer, ...) http.Handler
• func NewAddTableSubscriptionPublishedTable(body *AddTableRequestBody) *subscriptions.SubscriptionPublishedTable
• func NewGetHandler(endpoint goa.Endpoint, mux goahttp.Muxer, ...) http.Handler
• func NewStopTableHandler(endpoint goa.Endpoint, mux goahttp.Muxer, ...) http.Handler
• func NewStopTableSubscriptionPublishedTable(body *StopTableRequestBody) *subscriptions.SubscriptionPublishedTable
• func StopTableSubscriptionsPath() string
• func ValidateAddTableRequestBody(body *AddTableRequestBody) (err error)
• func ValidateStopTableRequestBody(body *StopTableRequestBody) (err error)
• type AddTableRequestBody
• type AddTableResponseBody
  • func NewAddTableResponseBody(res *subscriptions.Subscription) *AddTableResponseBody
• type ErrorNamer
• type GetResponseBody
  • func NewGetResponseBody(res *subscriptions.Subscription) *GetResponseBody
• type MountPoint
• type Server
  • func New(e *subscriptions.Endpoints, mux goahttp.Muxer, ...) *Server
  • func (s *Server) Service() string
  • func (s *Server) Use(m func(http.Handler) http.Handler)
• type StopTableRequestBody
• type StopTableResponseBody
  • func NewStopTableResponseBody(res *subscriptions.Subscription) *StopTableResponseBody
• type SubscriptionPublishedTableResponseBody

Functions

func AddTableSubscriptionsPath

func AddTableSubscriptionsPath() string

AddTableSubscriptionsPath returns the URL path to the Subscriptions service AddTable HTTP endpoint.

func DecodeAddTableRequest

func DecodeAddTableRequest(mux goahttp.Muxer, decoder func(*http.Request) goahttp.Decoder) func(*http.Request) (interface{}, error)

DecodeAddTableRequest returns a decoder for requests sent to the Subscriptions AddTable endpoint.

func DecodeStopTableRequest

func DecodeStopTableRequest(mux goahttp.Muxer, decoder func(*http.Request) goahttp.Decoder) func(*http.Request) (interface{}, error)

DecodeStopTableRequest returns a decoder for requests sent to the Subscriptions StopTable endpoint.

func EncodeAddTableResponse

func EncodeAddTableResponse(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder) func(context.Context, http.ResponseWriter, interface{}) error

EncodeAddTableResponse returns an encoder for responses returned by the Subscriptions AddTable endpoint.

func EncodeGetResponse

func EncodeGetResponse(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder) func(context.Context, http.ResponseWriter, interface{}) error

EncodeGetResponse returns an encoder for responses returned by the Subscriptions Get endpoint.

func EncodeStopTableResponse

func EncodeStopTableResponse(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder) func(context.Context, http.ResponseWriter, interface{}) error

EncodeStopTableResponse returns an encoder for responses returned by the Subscriptions StopTable endpoint.

func GetSubscriptionsPath

func GetSubscriptionsPath() string

GetSubscriptionsPath returns the URL path to the Subscriptions service Get HTTP endpoint.

func Mount

func Mount(mux goahttp.Muxer, h *Server)

Mount configures the mux to serve the Subscriptions endpoints.

func MountAddTableHandler

func MountAddTableHandler(mux goahttp.Muxer, h http.Handler)

MountAddTableHandler configures the mux to serve the "Subscriptions" service "AddTable" endpoint.

func MountGetHandler

func MountGetHandler(mux goahttp.Muxer, h http.Handler)

MountGetHandler configures the mux to serve the "Subscriptions" service "Get" endpoint.

func MountStopTableHandler

func MountStopTableHandler(mux goahttp.Muxer, h http.Handler)

MountStopTableHandler configures the mux to serve the "Subscriptions" service "StopTable" endpoint.

func NewAddTableHandler

func NewAddTableHandler(
	endpoint goa.Endpoint,
	mux goahttp.Muxer,
	decoder func(*http.Request) goahttp.Decoder,
	encoder func(context.Context, http.ResponseWriter) goahttp.Encoder,
	errhandler func(context.Context, http.ResponseWriter, error),
	formatter func(err error) goahttp.Statuser,
) http.Handler

NewAddTableHandler creates a HTTP handler which loads the HTTP request and calls the "Subscriptions" service "AddTable" endpoint.

func NewAddTableSubscriptionPublishedTable

func NewAddTableSubscriptionPublishedTable(body *AddTableRequestBody) *subscriptions.SubscriptionPublishedTable

NewAddTableSubscriptionPublishedTable builds a Subscriptions service AddTable endpoint payload.

func NewGetHandler

func NewGetHandler(
	endpoint goa.Endpoint,
	mux goahttp.Muxer,
	decoder func(*http.Request) goahttp.Decoder,
	encoder func(context.Context, http.ResponseWriter) goahttp.Encoder,
	errhandler func(context.Context, http.ResponseWriter, error),
	formatter func(err error) goahttp.Statuser,
) http.Handler

NewGetHandler creates a HTTP handler which loads the HTTP request and calls the "Subscriptions" service "Get" endpoint.

func NewStopTableHandler

func NewStopTableHandler(
	endpoint goa.Endpoint,
	mux goahttp.Muxer,
	decoder func(*http.Request) goahttp.Decoder,
	encoder func(context.Context, http.ResponseWriter) goahttp.Encoder,
	errhandler func(context.Context, http.ResponseWriter, error),
	formatter func(err error) goahttp.Statuser,
) http.Handler

NewStopTableHandler creates a HTTP handler which loads the HTTP request and calls the "Subscriptions" service "StopTable" endpoint.

func NewStopTableSubscriptionPublishedTable

func NewStopTableSubscriptionPublishedTable(body *StopTableRequestBody) *subscriptions.SubscriptionPublishedTable

NewStopTableSubscriptionPublishedTable builds a Subscriptions service StopTable endpoint payload.

func StopTableSubscriptionsPath

func StopTableSubscriptionsPath() string

StopTableSubscriptionsPath returns the URL path to the Subscriptions service StopTable HTTP endpoint.

func ValidateAddTableRequestBody

func ValidateAddTableRequestBody(body *AddTableRequestBody) (err error)

ValidateAddTableRequestBody runs the validations defined on AddTableRequestBody

func ValidateStopTableRequestBody

func ValidateStopTableRequestBody(body *StopTableRequestBody) (err error)

ValidateStopTableRequestBody runs the validations defined on StopTableRequestBody

Types

type AddTableRequestBody

type AddTableRequestBody 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"`
}

AddTableRequestBody is the type of the "Subscriptions" service "AddTable" endpoint HTTP request body.

type AddTableResponseBody

type AddTableResponseBody struct {
	// ID of subscription
	ID string `form:"id" json:"id" xml:"id"`
	// List of published tables
	PublishedTables []*SubscriptionPublishedTableResponseBody `form:"published_tables" json:"published_tables" xml:"published_tables"`
}

AddTableResponseBody is the type of the "Subscriptions" service "AddTable" endpoint HTTP response body.

func NewAddTableResponseBody

func NewAddTableResponseBody(res *subscriptions.Subscription) *AddTableResponseBody

NewAddTableResponseBody builds the HTTP response body from the result of the "AddTable" endpoint of the "Subscriptions" service.

type ErrorNamer

type ErrorNamer interface {
	ErrorName() string
}

ErrorNamer is an interface implemented by generated error structs that exposes the name of the error as defined in the design.

type GetResponseBody

type GetResponseBody struct {
	// ID of subscription
	ID string `form:"id" json:"id" xml:"id"`
	// List of published tables
	PublishedTables []*SubscriptionPublishedTableResponseBody `form:"published_tables" json:"published_tables" xml:"published_tables"`
}

GetResponseBody is the type of the "Subscriptions" service "Get" endpoint HTTP response body.

func NewGetResponseBody

func NewGetResponseBody(res *subscriptions.Subscription) *GetResponseBody

NewGetResponseBody builds the HTTP response body from the result of the "Get" endpoint of the "Subscriptions" service.

type MountPoint

type MountPoint struct {
	// Method is the name of the service method served by the mounted HTTP handler.
	Method string
	// Verb is the HTTP method used to match requests to the mounted handler.
	Verb string
	// Pattern is the HTTP request path pattern used to match requests to the
	// mounted handler.
	Pattern string
}

MountPoint holds information about the mounted endpoints.

type Server

type Server struct {
	Mounts    []*MountPoint
	Get       http.Handler
	AddTable  http.Handler
	StopTable http.Handler
}

Server lists the Subscriptions service endpoint HTTP handlers.

func New

func New(
	e *subscriptions.Endpoints,
	mux goahttp.Muxer,
	decoder func(*http.Request) goahttp.Decoder,
	encoder func(context.Context, http.ResponseWriter) goahttp.Encoder,
	errhandler func(context.Context, http.ResponseWriter, error),
	formatter func(err error) goahttp.Statuser,
) *Server

New instantiates HTTP handlers for all the Subscriptions service endpoints using the provided encoder and decoder. The handlers are mounted on the given mux using the HTTP verb and path defined in the design. errhandler is called whenever a response fails to be encoded. formatter is used to format errors returned by the service methods prior to encoding. Both errhandler and formatter are optional and can be nil.

func (*Server) Service

func (s *Server) Service() string

Service returns the name of the service served.

func (*Server) Use

func (s *Server) Use(m func(http.Handler) http.Handler)

Use wraps the server handlers with the given middleware.

type StopTableRequestBody

type StopTableRequestBody 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"`
}

StopTableRequestBody is the type of the "Subscriptions" service "StopTable" endpoint HTTP request body.

type StopTableResponseBody

type StopTableResponseBody struct {
	// ID of subscription
	ID string `form:"id" json:"id" xml:"id"`
	// List of published tables
	PublishedTables []*SubscriptionPublishedTableResponseBody `form:"published_tables" json:"published_tables" xml:"published_tables"`
}

StopTableResponseBody is the type of the "Subscriptions" service "StopTable" endpoint HTTP response body.

func NewStopTableResponseBody

func NewStopTableResponseBody(res *subscriptions.Subscription) *StopTableResponseBody

NewStopTableResponseBody builds the HTTP response body from the result of the "StopTable" endpoint of the "Subscriptions" service.

type SubscriptionPublishedTableResponseBody

type SubscriptionPublishedTableResponseBody struct {
	// Postgres table schema
	Schema string `form:"schema" json:"schema" xml:"schema"`
	// Postgres table name
	Name string `form:"name" json:"name" xml:"name"`
}

SubscriptionPublishedTableResponseBody is used to define fields on response body types.