subscriptions

type Client struct {
	GetEndpoint       goa.Endpoint
	AddTableEndpoint  goa.Endpoint
	StopTableEndpoint goa.Endpoint
}

type Endpoints struct {
	Get       goa.Endpoint
	AddTable  goa.Endpoint
	StopTable goa.Endpoint
}

type Service interface {
	// Get current subscription data
	Get(context.Context) (res *Subscription, err error)
	// Add table to publication, relying on an import manager to schedule the job
	AddTable(context.Context, *SubscriptionPublishedTable) (res *Subscription, err error)
	// Stop a table by removing it from the publication, and expiring any import
	// jobs
	StopTable(context.Context, *SubscriptionPublishedTable) (res *Subscription, err error)
}

type Subscription struct {
	// ID of subscription
	ID string
	// List of published tables
	PublishedTables []*SubscriptionPublishedTable
}

type SubscriptionPublishedTable struct {
	// Postgres table schema
	Schema string
	// Postgres table name
	Name string
}