Versions in this module Expand all Collapse all v0 v0.0.2 Sep 5, 2019 Changes in this version + var ErrIllegalJobConfigVersion = errors.New("Job config version is illegal") + var ErrIngestionAssignmentAlreadyExist = errors.New("Ingestion assignment already exists") + var ErrIngestionAssignmentDoesNotExist = NotExist("Ingestion assignment does not exist") + var ErrInstanceAlreadyExist = errors.New("Instance already exists") + var ErrInstanceDoesNotExist = NotExist("Instance does not exist") + var ErrInvalidJobConfig = errors.New("Job config is invalid") + var ErrJobConfigAlreadyExist = errors.New("Job config already exists") + var ErrJobConfigDoesNotExist = NotExist("Job config does not exist") + var ErrNamespaceAlreadyExists = errors.New("Namespace already exists") + var ErrNamespaceDoesNotExist = NotExist("Namespace does not exist") + var ErrSubscriberDoesNotExist = NotExist("Subscriber does not exist") + func IsNonExist(err error) bool + func Validate(newJobConfig, oldJobConfig *models.JobConfig) (err error) + type EnumMutator interface + ExtendEnumCases func(namespace, table, column string, enumCases []string) ([]int, error) + type EnumReader interface + GetEnumCases func(namespace, table, column string) ([]string, error) + type IngestionAssignmentMutator interface + AddIngestionAssignment func(namespace string, IngestionAssignment models.IngestionAssignment) error + DeleteIngestionAssignment func(namespace, name string) error + GetHash func(namespace, subscriber string) (string, error) + GetIngestionAssignment func(namespace, name string) (IngestionAssignment models.IngestionAssignment, err error) + GetIngestionAssignments func(namespace string) (IngestionAssignment []models.IngestionAssignment, err error) + UpdateIngestionAssignment func(namespace string, IngestionAssignment models.IngestionAssignment) error + type JobMutator interface + AddJob func(namespace string, job models.JobConfig) error + DeleteJob func(namespace, name string) error + GetHash func(namespace string) (string, error) + GetJob func(namespace, name string) (job models.JobConfig, err error) + GetJobs func(namespace string) (job []models.JobConfig, err error) + UpdateJob func(namespace string, job models.JobConfig) error + type MembershipMutator interface + GetHash func(namespace string) (string, error) + GetInstance func(namespace, instanceName string) (models.Instance, error) + GetInstances func(namespace string) ([]models.Instance, error) + Join func(namespace string, instance models.Instance) error + Leave func(namespace, instanceName string) error + type NamespaceMutator interface + CreateNamespace func(namespace string) error + ListNamespaces func() ([]string, error) + type NotExist string + func (e NotExist) Error() string + type SubscriberMutator interface + GetHash func(namespace string) (string, error) + GetSubscriber func(namespace, subscriberName string) (models.Subscriber, error) + GetSubscribers func(namespace string) ([]models.Subscriber, error) + type TableSchemaMutator interface + CreateTable func(namespace string, table *common.Table, force bool) error + DeleteTable func(namespace, name string) error + GetHash func(namespace string) (string, error) + GetTable func(namespace, name string) (*common.Table, error) + ListTables func(namespace string) ([]string, error) + UpdateTable func(namespace string, table common.Table, force bool) error
Go to main page