// Code generated by MockGen. DO NOT EDIT. // Source: etcdclient.go // Package internal is a generated GoMock package. package internal import ( context "context" gomock "github.com/golang/mock/gomock" clientv3 "go.etcd.io/etcd/clientv3" grpc "google.golang.org/grpc" reflect "reflect" ) // MockEtcdClient is a mock of EtcdClient interface type MockEtcdClient struct { ctrl *gomock.Controller recorder *MockEtcdClientMockRecorder } // MockEtcdClientMockRecorder is the mock recorder for MockEtcdClient type MockEtcdClientMockRecorder struct { mock *MockEtcdClient } // NewMockEtcdClient creates a new mock instance func NewMockEtcdClient(ctrl *gomock.Controller) *MockEtcdClient { mock := &MockEtcdClient{ctrl: ctrl} mock.recorder = &MockEtcdClientMockRecorder{mock} return mock } // EXPECT returns an object that allows the caller to indicate expected use func (m *MockEtcdClient) EXPECT() *MockEtcdClientMockRecorder { return m.recorder } // ActiveConnection mocks base method func (m *MockEtcdClient) ActiveConnection() *grpc.ClientConn { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "ActiveConnection") ret0, _ := ret[0].(*grpc.ClientConn) return ret0 } // ActiveConnection indicates an expected call of ActiveConnection func (mr *MockEtcdClientMockRecorder) ActiveConnection() *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ActiveConnection", reflect.TypeOf((*MockEtcdClient)(nil).ActiveConnection)) } // Close mocks base method func (m *MockEtcdClient) Close() error { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "Close") ret0, _ := ret[0].(error) return ret0 } // Close indicates an expected call of Close func (mr *MockEtcdClientMockRecorder) Close() *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Close", reflect.TypeOf((*MockEtcdClient)(nil).Close)) } // Ctx mocks base method func (m *MockEtcdClient) Ctx() context.Context { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "Ctx") ret0, _ := ret[0].(context.Context) return ret0 } // Ctx indicates an expected call of Ctx func (mr *MockEtcdClientMockRecorder) Ctx() *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Ctx", reflect.TypeOf((*MockEtcdClient)(nil).Ctx)) } // Get mocks base method func (m *MockEtcdClient) Get(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error) { m.ctrl.T.Helper() varargs := []interface{}{ctx, key} for _, a := range opts { varargs = append(varargs, a) } ret := m.ctrl.Call(m, "Get", varargs...) ret0, _ := ret[0].(*clientv3.GetResponse) ret1, _ := ret[1].(error) return ret0, ret1 } // Get indicates an expected call of Get func (mr *MockEtcdClientMockRecorder) Get(ctx, key interface{}, opts ...interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() varargs := append([]interface{}{ctx, key}, opts...) return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Get", reflect.TypeOf((*MockEtcdClient)(nil).Get), varargs...) } // Grant mocks base method func (m *MockEtcdClient) Grant(ctx context.Context, ttl int64) (*clientv3.LeaseGrantResponse, error) { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "Grant", ctx, ttl) ret0, _ := ret[0].(*clientv3.LeaseGrantResponse) ret1, _ := ret[1].(error) return ret0, ret1 } // Grant indicates an expected call of Grant func (mr *MockEtcdClientMockRecorder) Grant(ctx, ttl interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Grant", reflect.TypeOf((*MockEtcdClient)(nil).Grant), ctx, ttl) } // KeepAlive mocks base method func (m *MockEtcdClient) KeepAlive(ctx context.Context, id clientv3.LeaseID) (<-chan *clientv3.LeaseKeepAliveResponse, error) { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "KeepAlive", ctx, id) ret0, _ := ret[0].(<-chan *clientv3.LeaseKeepAliveResponse) ret1, _ := ret[1].(error) return ret0, ret1 } // KeepAlive indicates an expected call of KeepAlive func (mr *MockEtcdClientMockRecorder) KeepAlive(ctx, id interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "KeepAlive", reflect.TypeOf((*MockEtcdClient)(nil).KeepAlive), ctx, id) } // Put mocks base method func (m *MockEtcdClient) Put(ctx context.Context, key, val string, opts ...clientv3.OpOption) (*clientv3.PutResponse, error) { m.ctrl.T.Helper() varargs := []interface{}{ctx, key, val} for _, a := range opts { varargs = append(varargs, a) } ret := m.ctrl.Call(m, "Put", varargs...) ret0, _ := ret[0].(*clientv3.PutResponse) ret1, _ := ret[1].(error) return ret0, ret1 } // Put indicates an expected call of Put func (mr *MockEtcdClientMockRecorder) Put(ctx, key, val interface{}, opts ...interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() varargs := append([]interface{}{ctx, key, val}, opts...) return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Put", reflect.TypeOf((*MockEtcdClient)(nil).Put), varargs...) } // Revoke mocks base method func (m *MockEtcdClient) Revoke(ctx context.Context, id clientv3.LeaseID) (*clientv3.LeaseRevokeResponse, error) { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "Revoke", ctx, id) ret0, _ := ret[0].(*clientv3.LeaseRevokeResponse) ret1, _ := ret[1].(error) return ret0, ret1 } // Revoke indicates an expected call of Revoke func (mr *MockEtcdClientMockRecorder) Revoke(ctx, id interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Revoke", reflect.TypeOf((*MockEtcdClient)(nil).Revoke), ctx, id) } // Watch mocks base method func (m *MockEtcdClient) Watch(ctx context.Context, key string, opts ...clientv3.OpOption) clientv3.WatchChan { m.ctrl.T.Helper() varargs := []interface{}{ctx, key} for _, a := range opts { varargs = append(varargs, a) } ret := m.ctrl.Call(m, "Watch", varargs...) ret0, _ := ret[0].(clientv3.WatchChan) return ret0 } // Watch indicates an expected call of Watch func (mr *MockEtcdClientMockRecorder) Watch(ctx, key interface{}, opts ...interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() varargs := append([]interface{}{ctx, key}, opts...) return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Watch", reflect.TypeOf((*MockEtcdClient)(nil).Watch), varargs...) }