Documentation ¶
Index ¶
- type AsyncEdgeWriter
- type AsyncEdgeWriter_Close_Call
- type AsyncEdgeWriter_Expecter
- type AsyncEdgeWriter_Flush_Call
- type AsyncEdgeWriter_Queue_Call
- func (_c *AsyncEdgeWriter_Queue_Call) Return(_a0 error) *AsyncEdgeWriter_Queue_Call
- func (_c *AsyncEdgeWriter_Queue_Call) Run(run func(ctx context.Context, e interface{})) *AsyncEdgeWriter_Queue_Call
- func (_c *AsyncEdgeWriter_Queue_Call) RunAndReturn(run func(context.Context, interface{}) error) *AsyncEdgeWriter_Queue_Call
- type AsyncVertexWriter
- type AsyncVertexWriter_Close_Call
- func (_c *AsyncVertexWriter_Close_Call) Return(_a0 error) *AsyncVertexWriter_Close_Call
- func (_c *AsyncVertexWriter_Close_Call) Run(run func(ctx context.Context)) *AsyncVertexWriter_Close_Call
- func (_c *AsyncVertexWriter_Close_Call) RunAndReturn(run func(context.Context) error) *AsyncVertexWriter_Close_Call
- type AsyncVertexWriter_Expecter
- type AsyncVertexWriter_Flush_Call
- func (_c *AsyncVertexWriter_Flush_Call) Return(_a0 error) *AsyncVertexWriter_Flush_Call
- func (_c *AsyncVertexWriter_Flush_Call) Run(run func(ctx context.Context)) *AsyncVertexWriter_Flush_Call
- func (_c *AsyncVertexWriter_Flush_Call) RunAndReturn(run func(context.Context) error) *AsyncVertexWriter_Flush_Call
- type AsyncVertexWriter_Queue_Call
- func (_c *AsyncVertexWriter_Queue_Call) Return(_a0 error) *AsyncVertexWriter_Queue_Call
- func (_c *AsyncVertexWriter_Queue_Call) Run(run func(ctx context.Context, v interface{})) *AsyncVertexWriter_Queue_Call
- func (_c *AsyncVertexWriter_Queue_Call) RunAndReturn(run func(context.Context, interface{}) error) *AsyncVertexWriter_Queue_Call
- type Provider
- func (_m *Provider) Clean(ctx context.Context, cluster string) error
- func (_m *Provider) Close(ctx context.Context) error
- func (_m *Provider) EXPECT() *Provider_Expecter
- func (_m *Provider) EdgeWriter(ctx context.Context, e edge.Builder, opts ...graphdb.WriterOption) (graphdb.AsyncEdgeWriter, error)
- func (_m *Provider) HealthCheck(ctx context.Context) (bool, error)
- func (_m *Provider) Name() string
- func (_m *Provider) Prepare(ctx context.Context) error
- func (_m *Provider) Raw() interface{}
- func (_m *Provider) VertexWriter(ctx context.Context, v vertex.Builder, c cache.CacheProvider, ...) (graphdb.AsyncVertexWriter, error)
- type Provider_Clean_Call
- type Provider_Close_Call
- type Provider_EdgeWriter_Call
- func (_c *Provider_EdgeWriter_Call) Return(_a0 graphdb.AsyncEdgeWriter, _a1 error) *Provider_EdgeWriter_Call
- func (_c *Provider_EdgeWriter_Call) Run(run func(ctx context.Context, e edge.Builder, opts ...graphdb.WriterOption)) *Provider_EdgeWriter_Call
- func (_c *Provider_EdgeWriter_Call) RunAndReturn(...) *Provider_EdgeWriter_Call
- type Provider_Expecter
- func (_e *Provider_Expecter) Clean(ctx interface{}, cluster interface{}) *Provider_Clean_Call
- func (_e *Provider_Expecter) Close(ctx interface{}) *Provider_Close_Call
- func (_e *Provider_Expecter) EdgeWriter(ctx interface{}, e interface{}, opts ...interface{}) *Provider_EdgeWriter_Call
- func (_e *Provider_Expecter) HealthCheck(ctx interface{}) *Provider_HealthCheck_Call
- func (_e *Provider_Expecter) Name() *Provider_Name_Call
- func (_e *Provider_Expecter) Prepare(ctx interface{}) *Provider_Prepare_Call
- func (_e *Provider_Expecter) Raw() *Provider_Raw_Call
- func (_e *Provider_Expecter) VertexWriter(ctx interface{}, v interface{}, c interface{}, opts ...interface{}) *Provider_VertexWriter_Call
- type Provider_HealthCheck_Call
- func (_c *Provider_HealthCheck_Call) Return(_a0 bool, _a1 error) *Provider_HealthCheck_Call
- func (_c *Provider_HealthCheck_Call) Run(run func(ctx context.Context)) *Provider_HealthCheck_Call
- func (_c *Provider_HealthCheck_Call) RunAndReturn(run func(context.Context) (bool, error)) *Provider_HealthCheck_Call
- type Provider_Name_Call
- type Provider_Prepare_Call
- type Provider_Raw_Call
- type Provider_VertexWriter_Call
- func (_c *Provider_VertexWriter_Call) Return(_a0 graphdb.AsyncVertexWriter, _a1 error) *Provider_VertexWriter_Call
- func (_c *Provider_VertexWriter_Call) Run(run func(ctx context.Context, v vertex.Builder, c cache.CacheProvider, ...)) *Provider_VertexWriter_Call
- func (_c *Provider_VertexWriter_Call) RunAndReturn(...) *Provider_VertexWriter_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AsyncEdgeWriter ¶
AsyncEdgeWriter is an autogenerated mock type for the AsyncEdgeWriter type
func NewAsyncEdgeWriter ¶
func NewAsyncEdgeWriter(t mockConstructorTestingTNewAsyncEdgeWriter) *AsyncEdgeWriter
NewAsyncEdgeWriter creates a new instance of AsyncEdgeWriter. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*AsyncEdgeWriter) Close ¶
func (_m *AsyncEdgeWriter) Close(ctx context.Context) error
Close provides a mock function with given fields: ctx
func (*AsyncEdgeWriter) EXPECT ¶
func (_m *AsyncEdgeWriter) EXPECT() *AsyncEdgeWriter_Expecter
type AsyncEdgeWriter_Close_Call ¶
AsyncEdgeWriter_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'
func (*AsyncEdgeWriter_Close_Call) Return ¶
func (_c *AsyncEdgeWriter_Close_Call) Return(_a0 error) *AsyncEdgeWriter_Close_Call
func (*AsyncEdgeWriter_Close_Call) Run ¶
func (_c *AsyncEdgeWriter_Close_Call) Run(run func(ctx context.Context)) *AsyncEdgeWriter_Close_Call
func (*AsyncEdgeWriter_Close_Call) RunAndReturn ¶
func (_c *AsyncEdgeWriter_Close_Call) RunAndReturn(run func(context.Context) error) *AsyncEdgeWriter_Close_Call
type AsyncEdgeWriter_Expecter ¶
type AsyncEdgeWriter_Expecter struct {
// contains filtered or unexported fields
}
func (*AsyncEdgeWriter_Expecter) Close ¶
func (_e *AsyncEdgeWriter_Expecter) Close(ctx interface{}) *AsyncEdgeWriter_Close_Call
Close is a helper method to define mock.On call
- ctx context.Context
func (*AsyncEdgeWriter_Expecter) Flush ¶
func (_e *AsyncEdgeWriter_Expecter) Flush(ctx interface{}) *AsyncEdgeWriter_Flush_Call
Flush is a helper method to define mock.On call
- ctx context.Context
func (*AsyncEdgeWriter_Expecter) Queue ¶
func (_e *AsyncEdgeWriter_Expecter) Queue(ctx interface{}, e interface{}) *AsyncEdgeWriter_Queue_Call
Queue is a helper method to define mock.On call
- ctx context.Context
- e interface{}
type AsyncEdgeWriter_Flush_Call ¶
AsyncEdgeWriter_Flush_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Flush'
func (*AsyncEdgeWriter_Flush_Call) Return ¶
func (_c *AsyncEdgeWriter_Flush_Call) Return(_a0 error) *AsyncEdgeWriter_Flush_Call
func (*AsyncEdgeWriter_Flush_Call) Run ¶
func (_c *AsyncEdgeWriter_Flush_Call) Run(run func(ctx context.Context)) *AsyncEdgeWriter_Flush_Call
func (*AsyncEdgeWriter_Flush_Call) RunAndReturn ¶
func (_c *AsyncEdgeWriter_Flush_Call) RunAndReturn(run func(context.Context) error) *AsyncEdgeWriter_Flush_Call
type AsyncEdgeWriter_Queue_Call ¶
AsyncEdgeWriter_Queue_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Queue'
func (*AsyncEdgeWriter_Queue_Call) Return ¶
func (_c *AsyncEdgeWriter_Queue_Call) Return(_a0 error) *AsyncEdgeWriter_Queue_Call
func (*AsyncEdgeWriter_Queue_Call) Run ¶
func (_c *AsyncEdgeWriter_Queue_Call) Run(run func(ctx context.Context, e interface{})) *AsyncEdgeWriter_Queue_Call
func (*AsyncEdgeWriter_Queue_Call) RunAndReturn ¶
func (_c *AsyncEdgeWriter_Queue_Call) RunAndReturn(run func(context.Context, interface{}) error) *AsyncEdgeWriter_Queue_Call
type AsyncVertexWriter ¶
AsyncVertexWriter is an autogenerated mock type for the AsyncVertexWriter type
func NewAsyncVertexWriter ¶
func NewAsyncVertexWriter(t mockConstructorTestingTNewAsyncVertexWriter) *AsyncVertexWriter
NewAsyncVertexWriter creates a new instance of AsyncVertexWriter. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*AsyncVertexWriter) Close ¶
func (_m *AsyncVertexWriter) Close(ctx context.Context) error
Close provides a mock function with given fields: ctx
func (*AsyncVertexWriter) EXPECT ¶
func (_m *AsyncVertexWriter) EXPECT() *AsyncVertexWriter_Expecter
type AsyncVertexWriter_Close_Call ¶
AsyncVertexWriter_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'
func (*AsyncVertexWriter_Close_Call) Return ¶
func (_c *AsyncVertexWriter_Close_Call) Return(_a0 error) *AsyncVertexWriter_Close_Call
func (*AsyncVertexWriter_Close_Call) Run ¶
func (_c *AsyncVertexWriter_Close_Call) Run(run func(ctx context.Context)) *AsyncVertexWriter_Close_Call
func (*AsyncVertexWriter_Close_Call) RunAndReturn ¶
func (_c *AsyncVertexWriter_Close_Call) RunAndReturn(run func(context.Context) error) *AsyncVertexWriter_Close_Call
type AsyncVertexWriter_Expecter ¶
type AsyncVertexWriter_Expecter struct {
// contains filtered or unexported fields
}
func (*AsyncVertexWriter_Expecter) Close ¶
func (_e *AsyncVertexWriter_Expecter) Close(ctx interface{}) *AsyncVertexWriter_Close_Call
Close is a helper method to define mock.On call
- ctx context.Context
func (*AsyncVertexWriter_Expecter) Flush ¶
func (_e *AsyncVertexWriter_Expecter) Flush(ctx interface{}) *AsyncVertexWriter_Flush_Call
Flush is a helper method to define mock.On call
- ctx context.Context
func (*AsyncVertexWriter_Expecter) Queue ¶
func (_e *AsyncVertexWriter_Expecter) Queue(ctx interface{}, v interface{}) *AsyncVertexWriter_Queue_Call
Queue is a helper method to define mock.On call
- ctx context.Context
- v interface{}
type AsyncVertexWriter_Flush_Call ¶
AsyncVertexWriter_Flush_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Flush'
func (*AsyncVertexWriter_Flush_Call) Return ¶
func (_c *AsyncVertexWriter_Flush_Call) Return(_a0 error) *AsyncVertexWriter_Flush_Call
func (*AsyncVertexWriter_Flush_Call) Run ¶
func (_c *AsyncVertexWriter_Flush_Call) Run(run func(ctx context.Context)) *AsyncVertexWriter_Flush_Call
func (*AsyncVertexWriter_Flush_Call) RunAndReturn ¶
func (_c *AsyncVertexWriter_Flush_Call) RunAndReturn(run func(context.Context) error) *AsyncVertexWriter_Flush_Call
type AsyncVertexWriter_Queue_Call ¶
AsyncVertexWriter_Queue_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Queue'
func (*AsyncVertexWriter_Queue_Call) Return ¶
func (_c *AsyncVertexWriter_Queue_Call) Return(_a0 error) *AsyncVertexWriter_Queue_Call
func (*AsyncVertexWriter_Queue_Call) Run ¶
func (_c *AsyncVertexWriter_Queue_Call) Run(run func(ctx context.Context, v interface{})) *AsyncVertexWriter_Queue_Call
func (*AsyncVertexWriter_Queue_Call) RunAndReturn ¶
func (_c *AsyncVertexWriter_Queue_Call) RunAndReturn(run func(context.Context, interface{}) error) *AsyncVertexWriter_Queue_Call
type Provider ¶
Provider is an autogenerated mock type for the Provider type
func NewProvider ¶
func NewProvider(t mockConstructorTestingTNewProvider) *Provider
NewProvider creates a new instance of Provider. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Provider) Clean ¶ added in v1.6.0
Clean provides a mock function with given fields: ctx, cluster
func (*Provider) EXPECT ¶
func (_m *Provider) EXPECT() *Provider_Expecter
func (*Provider) EdgeWriter ¶
func (_m *Provider) EdgeWriter(ctx context.Context, e edge.Builder, opts ...graphdb.WriterOption) (graphdb.AsyncEdgeWriter, error)
EdgeWriter provides a mock function with given fields: ctx, e, opts
func (*Provider) HealthCheck ¶
HealthCheck provides a mock function with given fields: ctx
func (*Provider) Raw ¶
func (_m *Provider) Raw() interface{}
Raw provides a mock function with given fields:
func (*Provider) VertexWriter ¶
func (_m *Provider) VertexWriter(ctx context.Context, v vertex.Builder, c cache.CacheProvider, opts ...graphdb.WriterOption) (graphdb.AsyncVertexWriter, error)
VertexWriter provides a mock function with given fields: ctx, v, c, opts
type Provider_Clean_Call ¶ added in v1.6.0
Provider_Clean_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Clean'
func (*Provider_Clean_Call) Return ¶ added in v1.6.0
func (_c *Provider_Clean_Call) Return(_a0 error) *Provider_Clean_Call
func (*Provider_Clean_Call) Run ¶ added in v1.6.0
func (_c *Provider_Clean_Call) Run(run func(ctx context.Context, cluster string)) *Provider_Clean_Call
func (*Provider_Clean_Call) RunAndReturn ¶ added in v1.6.0
func (_c *Provider_Clean_Call) RunAndReturn(run func(context.Context, string) error) *Provider_Clean_Call
type Provider_Close_Call ¶
Provider_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'
func (*Provider_Close_Call) Return ¶
func (_c *Provider_Close_Call) Return(_a0 error) *Provider_Close_Call
func (*Provider_Close_Call) Run ¶
func (_c *Provider_Close_Call) Run(run func(ctx context.Context)) *Provider_Close_Call
func (*Provider_Close_Call) RunAndReturn ¶
func (_c *Provider_Close_Call) RunAndReturn(run func(context.Context) error) *Provider_Close_Call
type Provider_EdgeWriter_Call ¶
Provider_EdgeWriter_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'EdgeWriter'
func (*Provider_EdgeWriter_Call) Return ¶
func (_c *Provider_EdgeWriter_Call) Return(_a0 graphdb.AsyncEdgeWriter, _a1 error) *Provider_EdgeWriter_Call
func (*Provider_EdgeWriter_Call) Run ¶
func (_c *Provider_EdgeWriter_Call) Run(run func(ctx context.Context, e edge.Builder, opts ...graphdb.WriterOption)) *Provider_EdgeWriter_Call
func (*Provider_EdgeWriter_Call) RunAndReturn ¶
func (_c *Provider_EdgeWriter_Call) RunAndReturn(run func(context.Context, edge.Builder, ...graphdb.WriterOption) (graphdb.AsyncEdgeWriter, error)) *Provider_EdgeWriter_Call
type Provider_Expecter ¶
type Provider_Expecter struct {
// contains filtered or unexported fields
}
func (*Provider_Expecter) Clean ¶ added in v1.6.0
func (_e *Provider_Expecter) Clean(ctx interface{}, cluster interface{}) *Provider_Clean_Call
Clean is a helper method to define mock.On call
- ctx context.Context
- cluster string
func (*Provider_Expecter) Close ¶
func (_e *Provider_Expecter) Close(ctx interface{}) *Provider_Close_Call
Close is a helper method to define mock.On call
- ctx context.Context
func (*Provider_Expecter) EdgeWriter ¶
func (_e *Provider_Expecter) EdgeWriter(ctx interface{}, e interface{}, opts ...interface{}) *Provider_EdgeWriter_Call
EdgeWriter is a helper method to define mock.On call
- ctx context.Context
- e edge.Builder
- opts ...graphdb.WriterOption
func (*Provider_Expecter) HealthCheck ¶
func (_e *Provider_Expecter) HealthCheck(ctx interface{}) *Provider_HealthCheck_Call
HealthCheck is a helper method to define mock.On call
- ctx context.Context
func (*Provider_Expecter) Name ¶
func (_e *Provider_Expecter) Name() *Provider_Name_Call
Name is a helper method to define mock.On call
func (*Provider_Expecter) Prepare ¶ added in v1.1.0
func (_e *Provider_Expecter) Prepare(ctx interface{}) *Provider_Prepare_Call
Prepare is a helper method to define mock.On call
- ctx context.Context
func (*Provider_Expecter) Raw ¶
func (_e *Provider_Expecter) Raw() *Provider_Raw_Call
Raw is a helper method to define mock.On call
func (*Provider_Expecter) VertexWriter ¶
func (_e *Provider_Expecter) VertexWriter(ctx interface{}, v interface{}, c interface{}, opts ...interface{}) *Provider_VertexWriter_Call
VertexWriter is a helper method to define mock.On call
- ctx context.Context
- v vertex.Builder
- c cache.CacheProvider
- opts ...graphdb.WriterOption
type Provider_HealthCheck_Call ¶
Provider_HealthCheck_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HealthCheck'
func (*Provider_HealthCheck_Call) Return ¶
func (_c *Provider_HealthCheck_Call) Return(_a0 bool, _a1 error) *Provider_HealthCheck_Call
func (*Provider_HealthCheck_Call) Run ¶
func (_c *Provider_HealthCheck_Call) Run(run func(ctx context.Context)) *Provider_HealthCheck_Call
func (*Provider_HealthCheck_Call) RunAndReturn ¶
func (_c *Provider_HealthCheck_Call) RunAndReturn(run func(context.Context) (bool, error)) *Provider_HealthCheck_Call
type Provider_Name_Call ¶
Provider_Name_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Name'
func (*Provider_Name_Call) Return ¶
func (_c *Provider_Name_Call) Return(_a0 string) *Provider_Name_Call
func (*Provider_Name_Call) Run ¶
func (_c *Provider_Name_Call) Run(run func()) *Provider_Name_Call
func (*Provider_Name_Call) RunAndReturn ¶
func (_c *Provider_Name_Call) RunAndReturn(run func() string) *Provider_Name_Call
type Provider_Prepare_Call ¶ added in v1.1.0
Provider_Prepare_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Prepare'
func (*Provider_Prepare_Call) Return ¶ added in v1.1.0
func (_c *Provider_Prepare_Call) Return(_a0 error) *Provider_Prepare_Call
func (*Provider_Prepare_Call) Run ¶ added in v1.1.0
func (_c *Provider_Prepare_Call) Run(run func(ctx context.Context)) *Provider_Prepare_Call
func (*Provider_Prepare_Call) RunAndReturn ¶ added in v1.1.0
func (_c *Provider_Prepare_Call) RunAndReturn(run func(context.Context) error) *Provider_Prepare_Call
type Provider_Raw_Call ¶
Provider_Raw_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Raw'
func (*Provider_Raw_Call) Return ¶
func (_c *Provider_Raw_Call) Return(_a0 interface{}) *Provider_Raw_Call
func (*Provider_Raw_Call) Run ¶
func (_c *Provider_Raw_Call) Run(run func()) *Provider_Raw_Call
func (*Provider_Raw_Call) RunAndReturn ¶
func (_c *Provider_Raw_Call) RunAndReturn(run func() interface{}) *Provider_Raw_Call
type Provider_VertexWriter_Call ¶
Provider_VertexWriter_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'VertexWriter'
func (*Provider_VertexWriter_Call) Return ¶
func (_c *Provider_VertexWriter_Call) Return(_a0 graphdb.AsyncVertexWriter, _a1 error) *Provider_VertexWriter_Call
func (*Provider_VertexWriter_Call) Run ¶
func (_c *Provider_VertexWriter_Call) Run(run func(ctx context.Context, v vertex.Builder, c cache.CacheProvider, opts ...graphdb.WriterOption)) *Provider_VertexWriter_Call
func (*Provider_VertexWriter_Call) RunAndReturn ¶
func (_c *Provider_VertexWriter_Call) RunAndReturn(run func(context.Context, vertex.Builder, cache.CacheProvider, ...graphdb.WriterOption) (graphdb.AsyncVertexWriter, error)) *Provider_VertexWriter_Call