Documentation
¶
Overview ¶
Copyright (c) 2017-2018 Uber Technologies, Inc.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. Code generated by mockery v1.0.0
Copyright (c) 2017-2018 Uber Technologies, Inc.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. Code generated by mockery v1.0.0
Copyright (c) 2017-2018 Uber Technologies, Inc.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. Code generated by mockery v1.0.0
Copyright (c) 2017-2018 Uber Technologies, Inc.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. Code generated by mockery v1.0.0
Copyright (c) 2017-2018 Uber Technologies, Inc.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. Code generated by mockery v1.0.0
Index ¶
- type EnumMutator
- type EnumReader
- type IngestionAssignmentMutator
- 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
- 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
- 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
- type SubscriberMutator
- type TableSchemaMutator
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EnumMutator ¶
EnumMutator is an autogenerated mock type for the EnumMutator type
func (*EnumMutator) ExtendEnumCases ¶
func (_m *EnumMutator) ExtendEnumCases(namespace string, table string, column string, enumCases []string) ([]int, error)
ExtendEnumCases provides a mock function with given fields: namespace, table, column, enumCases
func (*EnumMutator) GetEnumCases ¶
func (_m *EnumMutator) GetEnumCases(namespace string, table string, column string) ([]string, error)
GetEnumCases provides a mock function with given fields: namespace, table, column
type EnumReader ¶
EnumReader is an autogenerated mock type for the EnumReader type
func (*EnumReader) GetEnumCases ¶
GetEnumCases provides a mock function with given fields: namespace, table, column
type IngestionAssignmentMutator ¶
IngestionAssignmentMutator is an autogenerated mock type for the IngestionAssignmentMutator type
func (*IngestionAssignmentMutator) AddIngestionAssignment ¶
func (_m *IngestionAssignmentMutator) AddIngestionAssignment(namespace string, IngestionAssignment models.IngestionAssignment) error
AddIngestionAssignment provides a mock function with given fields: namespace, IngestionAssignment
func (*IngestionAssignmentMutator) DeleteIngestionAssignment ¶
func (_m *IngestionAssignmentMutator) DeleteIngestionAssignment(namespace string, name string) error
DeleteIngestionAssignment provides a mock function with given fields: namespace, name
func (*IngestionAssignmentMutator) GetHash ¶
func (_m *IngestionAssignmentMutator) GetHash(namespace string, subscriber string) (string, error)
GetHash provides a mock function with given fields: namespace, subscriber
func (*IngestionAssignmentMutator) GetIngestionAssignment ¶
func (_m *IngestionAssignmentMutator) GetIngestionAssignment(namespace string, name string) (models.IngestionAssignment, error)
GetIngestionAssignment provides a mock function with given fields: namespace, name
func (*IngestionAssignmentMutator) GetIngestionAssignments ¶
func (_m *IngestionAssignmentMutator) GetIngestionAssignments(namespace string) ([]models.IngestionAssignment, error)
GetIngestionAssignments provides a mock function with given fields: namespace
func (*IngestionAssignmentMutator) UpdateIngestionAssignment ¶
func (_m *IngestionAssignmentMutator) UpdateIngestionAssignment(namespace string, IngestionAssignment models.IngestionAssignment) error
UpdateIngestionAssignment provides a mock function with given fields: namespace, IngestionAssignment
type JobMutator ¶
JobMutator is an autogenerated mock type for the JobMutator type
func (*JobMutator) AddJob ¶
func (_m *JobMutator) AddJob(namespace string, job models.JobConfig) error
AddJob provides a mock function with given fields: namespace, job
func (*JobMutator) DeleteJob ¶
func (_m *JobMutator) DeleteJob(namespace string, name string) error
DeleteJob provides a mock function with given fields: namespace, name
func (*JobMutator) GetHash ¶
func (_m *JobMutator) GetHash(namespace string) (string, error)
GetHash provides a mock function with given fields: namespace
type MembershipMutator ¶
MembershipMutator is an autogenerated mock type for the MembershipMutator type
func (*MembershipMutator) GetHash ¶
func (_m *MembershipMutator) GetHash(namespace string) (string, error)
GetHash provides a mock function with given fields: namespace
func (*MembershipMutator) GetInstance ¶
func (_m *MembershipMutator) GetInstance(namespace string, instanceName string) (models.Instance, error)
GetInstance provides a mock function with given fields: namespace, instanceName
func (*MembershipMutator) GetInstances ¶
func (_m *MembershipMutator) GetInstances(namespace string) ([]models.Instance, error)
GetInstances provides a mock function with given fields: namespace
type NamespaceMutator ¶
NamespaceMutator is an autogenerated mock type for the NamespaceMutator type
func (*NamespaceMutator) CreateNamespace ¶
func (_m *NamespaceMutator) CreateNamespace(namespace string) error
CreateNamespace provides a mock function with given fields: namespace
func (*NamespaceMutator) ListNamespaces ¶
func (_m *NamespaceMutator) ListNamespaces() ([]string, error)
ListNamespaces provides a mock function with given fields:
type SubscriberMutator ¶
SubscriberMutator is an autogenerated mock type for the SubscriberMutator type
func (*SubscriberMutator) GetHash ¶
func (_m *SubscriberMutator) GetHash(namespace string) (string, error)
GetHash provides a mock function with given fields: namespace
func (*SubscriberMutator) GetSubscriber ¶
func (_m *SubscriberMutator) GetSubscriber(namespace string, subscriberName string) (models.Subscriber, error)
GetSubscriber provides a mock function with given fields: namespace, subscriberName
func (*SubscriberMutator) GetSubscribers ¶
func (_m *SubscriberMutator) GetSubscribers(namespace string) ([]models.Subscriber, error)
GetSubscribers provides a mock function with given fields: namespace
type TableSchemaMutator ¶
TableSchemaMutator is an autogenerated mock type for the TableSchemaMutator type
func (*TableSchemaMutator) CreateTable ¶
CreateTable provides a mock function with given fields: namespace, table, force
func (*TableSchemaMutator) DeleteTable ¶
func (_m *TableSchemaMutator) DeleteTable(namespace string, name string) error
DeleteTable provides a mock function with given fields: namespace, name
func (*TableSchemaMutator) GetHash ¶
func (_m *TableSchemaMutator) GetHash(namespace string) (string, error)
GetHash provides a mock function with given fields: namespace
func (*TableSchemaMutator) GetTable ¶
GetTable provides a mock function with given fields: namespace, name
func (*TableSchemaMutator) ListTables ¶
func (_m *TableSchemaMutator) ListTables(namespace string) ([]string, error)
ListTables provides a mock function with given fields: namespace
func (*TableSchemaMutator) UpdateTable ¶
UpdateTable provides a mock function with given fields: namespace, table, force