Versions in this module Expand all Collapse all v0 v0.0.2 Sep 5, 2019 Changes in this version + type EnumMutator struct + func (_m *EnumMutator) ExtendEnumCases(namespace string, table string, column string, enumCases []string) ([]int, error) + func (_m *EnumMutator) GetEnumCases(namespace string, table string, column string) ([]string, error) + type EnumReader struct + func (_m *EnumReader) GetEnumCases(namespace string, table string, column string) ([]string, error) + type IngestionAssignmentMutator struct + func (_m *IngestionAssignmentMutator) AddIngestionAssignment(namespace string, IngestionAssignment models.IngestionAssignment) error + func (_m *IngestionAssignmentMutator) DeleteIngestionAssignment(namespace string, name string) error + func (_m *IngestionAssignmentMutator) GetHash(namespace string, subscriber string) (string, error) + func (_m *IngestionAssignmentMutator) GetIngestionAssignment(namespace string, name string) (models.IngestionAssignment, error) + func (_m *IngestionAssignmentMutator) GetIngestionAssignments(namespace string) ([]models.IngestionAssignment, error) + func (_m *IngestionAssignmentMutator) UpdateIngestionAssignment(namespace string, IngestionAssignment models.IngestionAssignment) error + type JobMutator struct + func (_m *JobMutator) AddJob(namespace string, job models.JobConfig) error + func (_m *JobMutator) DeleteJob(namespace string, name string) error + func (_m *JobMutator) GetHash(namespace string) (string, error) + func (_m *JobMutator) GetJob(namespace string, name string) (models.JobConfig, error) + func (_m *JobMutator) GetJobs(namespace string) ([]models.JobConfig, error) + func (_m *JobMutator) UpdateJob(namespace string, job models.JobConfig) error + type MembershipMutator struct + func (_m *MembershipMutator) GetHash(namespace string) (string, error) + func (_m *MembershipMutator) GetInstance(namespace string, instanceName string) (models.Instance, error) + func (_m *MembershipMutator) GetInstances(namespace string) ([]models.Instance, error) + func (_m *MembershipMutator) Join(namespace string, instance models.Instance) error + func (_m *MembershipMutator) Leave(namespace string, instanceName string) error + type NamespaceMutator struct + func (_m *NamespaceMutator) CreateNamespace(namespace string) error + func (_m *NamespaceMutator) ListNamespaces() ([]string, error) + type SubscriberMutator struct + func (_m *SubscriberMutator) GetHash(namespace string) (string, error) + func (_m *SubscriberMutator) GetSubscriber(namespace string, subscriberName string) (models.Subscriber, error) + func (_m *SubscriberMutator) GetSubscribers(namespace string) ([]models.Subscriber, error) + type TableSchemaMutator struct + func (_m *TableSchemaMutator) CreateTable(namespace string, table *common.Table, force bool) error + func (_m *TableSchemaMutator) DeleteTable(namespace string, name string) error + func (_m *TableSchemaMutator) GetHash(namespace string) (string, error) + func (_m *TableSchemaMutator) GetTable(namespace string, name string) (*common.Table, error) + func (_m *TableSchemaMutator) ListTables(namespace string) ([]string, error) + func (_m *TableSchemaMutator) UpdateTable(namespace string, table common.Table, force bool) error
Go to main page