Documentation
¶
Index ¶
- type CantabularClient
- type DatasetAPIClient
- type Error
- type ImportAPIClient
- type InstanceStarted
- func (h *InstanceStarted) CreateUpdateInstanceRequest(ctx context.Context, vars gql.Variables, e *event.InstanceStarted, ...) dataset.UpdateInstance
- func (h *InstanceStarted) Handle(ctx context.Context, workerID int, msg kafka.Message) error
- func (h *InstanceStarted) TriggerImportDimensionOptions(r *recipe.Recipe, codelists []recipe.CodeList, e *event.InstanceStarted) []error
- type RecipeAPIClient
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CantabularClient ¶ added in v0.5.0
type CantabularClient interface {
GetDimensionsByName(ctx context.Context, req cantabular.GetDimensionsByNameRequest) (*cantabular.GetDimensionsResponse, error)
}
type DatasetAPIClient ¶ added in v0.5.0
type DatasetAPIClient interface { PutInstance(ctx context.Context, userAuthToken, serviceAuthToken, collectionID, instanceID string, i dataset.UpdateInstance, ifMatch string) (eTag string, err error) PutInstanceState(ctx context.Context, serviceAuthToken, instanceID string, state dataset.State, ifMatch string) (eTag string, err error) }
type Error ¶
type Error struct {
// contains filtered or unexported fields
}
Error is the handler package's error type. Is not meant to be compared as a type, but information should be extracted via the interfaces it implements with callback functions. Is not guaranteed to remain exported so shouldn't be treated as such.
func (*Error) InstanceCompleted ¶ added in v0.5.0
InstanceCompleted implements the instanceCompleteder interface and allows you to extract the instanceCompleted flag from an error. Is specific to this application and unlikely to be found elsewhere
type ImportAPIClient ¶ added in v1.7.0
type InstanceStarted ¶
type InstanceStarted struct {
// contains filtered or unexported fields
}
InstanceStarted is the handler for the InstanceStarted event
func NewInstanceStarted ¶
func NewInstanceStarted(cfg config.Config, c CantabularClient, r RecipeAPIClient, i ImportAPIClient, d DatasetAPIClient, p kafka.IProducer) *InstanceStarted
func (*InstanceStarted) CreateUpdateInstanceRequest ¶ added in v1.9.0
func (h *InstanceStarted) CreateUpdateInstanceRequest(ctx context.Context, vars gql.Variables, e *event.InstanceStarted, r *recipe.Recipe, codelists []recipe.CodeList, edition string) dataset.UpdateInstance
func (*InstanceStarted) TriggerImportDimensionOptions ¶ added in v1.9.0
func (h *InstanceStarted) TriggerImportDimensionOptions(r *recipe.Recipe, codelists []recipe.CodeList, e *event.InstanceStarted) []error
Click to show internal directories.
Click to hide internal directories.