output

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 22, 2024 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Overview

Package output is a generated GoMock package.

Package output is a generated GoMock package.

Index

Constants

View Source 
const Subsystem = "output"

Variables

This section is empty.

Functions

func ReadDocument 

func ReadDocument(ctx context.Context, result interface{}) (driver.DocumentMeta, error)

Types

type ArangoClient 

type ArangoClient interface {

	// ClientDatabases - Database functions
	// driver.ClientDatabases
	Database(ctx context.Context, name string) (driver.Database, error)
}

type ArangoClientMock 

type ArangoClientMock struct {
	// contains filtered or unexported fields
}

func NewArangoClientMock 

func NewArangoClientMock() *ArangoClientMock

func (*ArangoClientMock) Database 

func (client *ArangoClientMock) Database(ctx context.Context, name string) (driver.Database, error)

type ArangoCollectionMock 

type ArangoCollectionMock struct {
	// contains filtered or unexported fields
}

func NewArangoCollectionMock 

func NewArangoCollectionMock(wantUpdateErr bool) *ArangoCollectionMock

func (*ArangoCollectionMock) Checksum 

func (collection *ArangoCollectionMock) Checksum(ctx context.Context, withRevisions bool, withData bool) (driver.CollectionChecksum, error)

func (*ArangoCollectionMock) Count 

func (collection *ArangoCollectionMock) Count(ctx context.Context) (int64, error)

func (*ArangoCollectionMock) CreateDocument 

func (collection *ArangoCollectionMock) CreateDocument(ctx context.Context, document interface{}) (driver.DocumentMeta, error)

func (*ArangoCollectionMock) CreateDocuments 

func (collection *ArangoCollectionMock) CreateDocuments(ctx context.Context, documents interface{}) (driver.DocumentMetaSlice, driver.ErrorSlice, error)

func (*ArangoCollectionMock) Database 

func (collection *ArangoCollectionMock) Database() driver.Database

func (*ArangoCollectionMock) DocumentExists 

func (collection *ArangoCollectionMock) DocumentExists(ctx context.Context, key string) (bool, error)

func (*ArangoCollectionMock) EnsureFullTextIndex 

func (collection *ArangoCollectionMock) EnsureFullTextIndex(ctx context.Context, fields []string, options *driver.EnsureFullTextIndexOptions) (driver.Index, bool, error)

nolint // This method is not used anyway

func (*ArangoCollectionMock) EnsureGeoIndex 

func (collection *ArangoCollectionMock) EnsureGeoIndex(ctx context.Context, fields []string, options *driver.EnsureGeoIndexOptions) (driver.Index, bool, error)

func (*ArangoCollectionMock) EnsureHashIndex 

func (collection *ArangoCollectionMock) EnsureHashIndex(ctx context.Context, fields []string, options *driver.EnsureHashIndexOptions) (driver.Index, bool, error)

func (*ArangoCollectionMock) EnsureInvertedIndex 

func (collection *ArangoCollectionMock) EnsureInvertedIndex(ctx context.Context, options *driver.InvertedIndexOptions) (driver.Index, bool, error)

func (*ArangoCollectionMock) EnsurePersistentIndex 

func (collection *ArangoCollectionMock) EnsurePersistentIndex(ctx context.Context, fields []string, options *driver.EnsurePersistentIndexOptions) (driver.Index, bool, error)

func (*ArangoCollectionMock) EnsureSkipListIndex 

func (collection *ArangoCollectionMock) EnsureSkipListIndex(ctx context.Context, fields []string, options *driver.EnsureSkipListIndexOptions) (driver.Index, bool, error)

func (*ArangoCollectionMock) EnsureTTLIndex 

func (collection *ArangoCollectionMock) EnsureTTLIndex(ctx context.Context, field string, ttl int, options *driver.EnsureTTLIndexOptions) (driver.Index, bool, error)

func (*ArangoCollectionMock) EnsureZKDIndex 

func (collection *ArangoCollectionMock) EnsureZKDIndex(ctx context.Context, fields []string, options *driver.EnsureZKDIndexOptions) (driver.Index, bool, error)

func (*ArangoCollectionMock) ImportDocuments 

func (collection *ArangoCollectionMock) ImportDocuments(ctx context.Context, documents interface{}, options *driver.ImportDocumentOptions) (driver.ImportDocumentStatistics, error)

func (*ArangoCollectionMock) Index 

func (collection *ArangoCollectionMock) Index(ctx context.Context, index string) (driver.Index, error)

func (*ArangoCollectionMock) IndexExists 

func (collection *ArangoCollectionMock) IndexExists(ctx context.Context, index string) (bool, error)

func (*ArangoCollectionMock) Indexes 

func (collection *ArangoCollectionMock) Indexes(ctx context.Context) ([]driver.Index, error)

func (*ArangoCollectionMock) Load 

func (collection *ArangoCollectionMock) Load(ctx context.Context) error

func (*ArangoCollectionMock) Name 

func (collection *ArangoCollectionMock) Name() string

func (*ArangoCollectionMock) Properties 

func (collection *ArangoCollectionMock) Properties(ctx context.Context) (driver.CollectionProperties, error)

func (*ArangoCollectionMock) ReadDocument 

func (collection *ArangoCollectionMock) ReadDocument(ctx context.Context, key string, result interface{}) (driver.DocumentMeta, error)

func (*ArangoCollectionMock) ReadDocuments 

func (collection *ArangoCollectionMock) ReadDocuments(ctx context.Context, keys []string, result interface{}) (driver.DocumentMetaSlice, driver.ErrorSlice, error)

func (*ArangoCollectionMock) Remove 

func (collection *ArangoCollectionMock) Remove(ctx context.Context) error

func (*ArangoCollectionMock) RemoveDocument 

func (collection *ArangoCollectionMock) RemoveDocument(ctx context.Context, key string) (driver.DocumentMeta, error)

func (*ArangoCollectionMock) RemoveDocuments 

func (collection *ArangoCollectionMock) RemoveDocuments(ctx context.Context, keys []string) (driver.DocumentMetaSlice, driver.ErrorSlice, error)

func (*ArangoCollectionMock) Rename 

func (collection *ArangoCollectionMock) Rename(ctx context.Context, newName string) error

func (*ArangoCollectionMock) ReplaceDocument 

func (collection *ArangoCollectionMock) ReplaceDocument(ctx context.Context, key string, document interface{}) (driver.DocumentMeta, error)

func (*ArangoCollectionMock) ReplaceDocuments 

func (collection *ArangoCollectionMock) ReplaceDocuments(ctx context.Context, keys []string, documents interface{}) (driver.DocumentMetaSlice, driver.ErrorSlice, error)

func (*ArangoCollectionMock) Revision 

func (collection *ArangoCollectionMock) Revision(ctx context.Context) (string, error)

func (*ArangoCollectionMock) SetProperties 

func (collection *ArangoCollectionMock) SetProperties(ctx context.Context, options driver.SetCollectionPropertiesOptions) error

func (*ArangoCollectionMock) Shards 

func (collection *ArangoCollectionMock) Shards(ctx context.Context, details bool) (driver.CollectionShards, error)

func (*ArangoCollectionMock) Statistics 

func (collection *ArangoCollectionMock) Statistics(ctx context.Context) (driver.CollectionStatistics, error)

func (*ArangoCollectionMock) Status 

func (collection *ArangoCollectionMock) Status(ctx context.Context) (driver.CollectionStatus, error)

func (*ArangoCollectionMock) Truncate 

func (collection *ArangoCollectionMock) Truncate(ctx context.Context) error

func (*ArangoCollectionMock) Unload 

func (collection *ArangoCollectionMock) Unload(ctx context.Context) error

func (*ArangoCollectionMock) UpdateDocument 

func (collection *ArangoCollectionMock) UpdateDocument(ctx context.Context, key string, document interface{}) (driver.DocumentMeta, error)

func (*ArangoCollectionMock) UpdateDocuments 

func (collection *ArangoCollectionMock) UpdateDocuments(ctx context.Context, keys []string, documents interface{}) (driver.DocumentMetaSlice, driver.ErrorSlice, error)

type ArangoCursor 

type ArangoCursor interface {
	ReadDocument(ctx context.Context, result interface{}) (driver.DocumentMeta, error)
	Count() int64
}

type ArangoCursorMock 

type ArangoCursorMock struct {
	// contains filtered or unexported fields
}

func NewArangoCursorMock 

func NewArangoCursorMock() *ArangoCursorMock

func (*ArangoCursorMock) Close 

func (cursor *ArangoCursorMock) Close() error

func (*ArangoCursorMock) Count 

func (cursor *ArangoCursorMock) Count() int64

func (*ArangoCursorMock) Extra 

func (cursor *ArangoCursorMock) Extra() driver.QueryExtra

func (*ArangoCursorMock) HasMore 

func (cursor *ArangoCursorMock) HasMore() bool

func (*ArangoCursorMock) ReadDocument 

func (cursor *ArangoCursorMock) ReadDocument(ctx context.Context, result interface{}) (driver.DocumentMeta, error)

func (*ArangoCursorMock) RetryReadDocument 

func (cursor *ArangoCursorMock) RetryReadDocument(ctx context.Context, result interface{}) (driver.DocumentMeta, error)

func (*ArangoCursorMock) Statistics 

func (cursor *ArangoCursorMock) Statistics() driver.QueryStatistics

type ArangoDatabase 

type ArangoDatabase interface {
	Query(ctx context.Context, query string, bindVars map[string]interface{}) (driver.Cursor, error)
	Collection(ctx context.Context, name string) (driver.Collection, error)
}

type ArangoDatabaseMock 

type ArangoDatabaseMock struct {
	// contains filtered or unexported fields
}

func NewArangoDatabaseMock 

func NewArangoDatabaseMock() *ArangoDatabaseMock

func (*ArangoDatabaseMock) AbortTransaction 

func (db *ArangoDatabaseMock) AbortTransaction(ctx context.Context, transaction driver.TransactionID, opts *driver.AbortTransactionOptions) error

func (*ArangoDatabaseMock) Analyzer 

func (db *ArangoDatabaseMock) Analyzer(ctx context.Context, name string) (driver.ArangoSearchAnalyzer, error)

func (*ArangoDatabaseMock) Analyzers 

func (db *ArangoDatabaseMock) Analyzers(ctx context.Context) ([]driver.ArangoSearchAnalyzer, error)

func (*ArangoDatabaseMock) BeginTransaction 

func (db *ArangoDatabaseMock) BeginTransaction(ctx context.Context, transcactions driver.TransactionCollections, opts *driver.BeginTransactionOptions) (driver.TransactionID, error)

func (*ArangoDatabaseMock) CancelJob 

func (db *ArangoDatabaseMock) CancelJob(ctx context.Context, id string) error

func (*ArangoDatabaseMock) Collection 

func (db *ArangoDatabaseMock) Collection(ctx context.Context, name string) (driver.Collection, error)

func (*ArangoDatabaseMock) CollectionExists 

func (db *ArangoDatabaseMock) CollectionExists(ctx context.Context, name string) (bool, error)

func (*ArangoDatabaseMock) Collections 

func (db *ArangoDatabaseMock) Collections(ctx context.Context) ([]driver.Collection, error)

func (*ArangoDatabaseMock) CommitTransaction 

func (db *ArangoDatabaseMock) CommitTransaction(ctx context.Context, transaction driver.TransactionID, opts *driver.CommitTransactionOptions) error

func (*ArangoDatabaseMock) CreateArangoSearchAliasView 

func (db *ArangoDatabaseMock) CreateArangoSearchAliasView(ctx context.Context, name string, options *driver.ArangoSearchAliasViewProperties) (driver.ArangoSearchViewAlias, error)

func (*ArangoDatabaseMock) CreateArangoSearchView 

func (db *ArangoDatabaseMock) CreateArangoSearchView(ctx context.Context, name string, options *driver.ArangoSearchViewProperties) (driver.ArangoSearchView, error)

func (*ArangoDatabaseMock) CreateCollection 

func (db *ArangoDatabaseMock) CreateCollection(ctx context.Context, name string, opts *driver.CreateCollectionOptions) (driver.Collection, error)

func (*ArangoDatabaseMock) CreateGraph 

func (db *ArangoDatabaseMock) CreateGraph(ctx context.Context, name string, opts *driver.CreateGraphOptions) (driver.Graph, error)

func (*ArangoDatabaseMock) CreateGraphV2 

func (db *ArangoDatabaseMock) CreateGraphV2(ctx context.Context, name string, opts *driver.CreateGraphOptions) (driver.Graph, error)

func (*ArangoDatabaseMock) EngineInfo 

func (db *ArangoDatabaseMock) EngineInfo(ctx context.Context) (driver.EngineInfo, error)

func (*ArangoDatabaseMock) EnsureAnalyzer 

func (db *ArangoDatabaseMock) EnsureAnalyzer(ctx context.Context, definition driver.ArangoSearchAnalyzerDefinition) (bool, driver.ArangoSearchAnalyzer, error)

func (*ArangoDatabaseMock) ExplainQuery 

func (db *ArangoDatabaseMock) ExplainQuery(ctx context.Context, query string, bindVars map[string]interface{}, opts *driver.ExplainQueryOptions) (driver.ExplainQueryResult, error)

func (*ArangoDatabaseMock) GetJob 

func (db *ArangoDatabaseMock) GetJob(ctx context.Context, id string) (*driver.PregelJob, error)

func (*ArangoDatabaseMock) GetJobs 

func (db *ArangoDatabaseMock) GetJobs(ctx context.Context) ([]*driver.PregelJob, error)

func (*ArangoDatabaseMock) Graph 

func (db *ArangoDatabaseMock) Graph(ctx context.Context, name string) (driver.Graph, error)

func (*ArangoDatabaseMock) GraphExists 

func (db *ArangoDatabaseMock) GraphExists(ctx context.Context, name string) (bool, error)

func (*ArangoDatabaseMock) Graphs 

func (db *ArangoDatabaseMock) Graphs(ctx context.Context) ([]driver.Graph, error)

func (*ArangoDatabaseMock) Info 

func (db *ArangoDatabaseMock) Info(ctx context.Context) (driver.DatabaseInfo, error)

func (*ArangoDatabaseMock) Name 

func (db *ArangoDatabaseMock) Name() string

func (*ArangoDatabaseMock) OptimizerRulesForQueries 

func (db *ArangoDatabaseMock) OptimizerRulesForQueries(ctx context.Context) ([]driver.QueryRule, error)

func (*ArangoDatabaseMock) Query 

func (db *ArangoDatabaseMock) Query(ctx context.Context, query string, bindVars map[string]interface{}) (driver.Cursor, error)

func (*ArangoDatabaseMock) Remove 

func (db *ArangoDatabaseMock) Remove(ctx context.Context) error

func (*ArangoDatabaseMock) StartJob 

func (db *ArangoDatabaseMock) StartJob(ctx context.Context, job driver.PregelJobOptions) (string, error)

func (*ArangoDatabaseMock) Transaction 

func (db *ArangoDatabaseMock) Transaction(ctx context.Context, action string, opts *driver.TransactionOptions) (interface{}, error)

func (*ArangoDatabaseMock) TransactionStatus 

func (db *ArangoDatabaseMock) TransactionStatus(ctx context.Context, id driver.TransactionID) (driver.TransactionStatusRecord, error)

func (*ArangoDatabaseMock) ValidateQuery 

func (db *ArangoDatabaseMock) ValidateQuery(ctx context.Context, query string) error

func (*ArangoDatabaseMock) View 

func (db *ArangoDatabaseMock) View(ctx context.Context, name string) (driver.View, error)

func (*ArangoDatabaseMock) ViewExists 

func (db *ArangoDatabaseMock) ViewExists(ctx context.Context, name string) (bool, error)

func (*ArangoDatabaseMock) Views 

func (db *ArangoDatabaseMock) Views(ctx context.Context) ([]driver.View, error)

type ArangoOutput 

type ArangoOutput struct {
	// contains filtered or unexported fields
}

func NewArangoOutput 

func NewArangoOutput(config config.ArangoOutputConfig, commandChan chan message.Command, resultChan chan message.Result) *ArangoOutput

func (*ArangoOutput) Init 

func (output *ArangoOutput) Init() error

func (*ArangoOutput) Start 

func (output *ArangoOutput) Start()

func (*ArangoOutput) Stop 

func (output *ArangoOutput) Stop() error

type DefaultOutputManager 

type DefaultOutputManager struct {
	// contains filtered or unexported fields
}

func NewDefaultOutputManager 

func NewDefaultOutputManager(config config.Config) *DefaultOutputManager

func (*DefaultOutputManager) GetOutputResource 

func (manager *DefaultOutputManager) GetOutputResource(name string) (*OutputResource, error)

func (*DefaultOutputManager) InitOutputs 

func (manager *DefaultOutputManager) InitOutputs() error

func (*DefaultOutputManager) StartOutputs 

func (manager *DefaultOutputManager) StartOutputs()

func (*DefaultOutputManager) StopOutputs 

func (manager *DefaultOutputManager) StopOutputs()

type KafkaOutput 

type KafkaOutput struct {
	// contains filtered or unexported fields
}

func NewKafkaOutput 

func NewKafkaOutput(config config.KafkaOutputConfig, commandChan chan message.Command, resultChan chan message.Result) *KafkaOutput

func (*KafkaOutput) Init 

func (output *KafkaOutput) Init() error

func (*KafkaOutput) Start 

func (output *KafkaOutput) Start()

func (*KafkaOutput) Stop 

func (output *KafkaOutput) Stop() error

type KafkaProducer 

type KafkaProducer interface {
	Close() error
	Input() chan<- *sarama.ProducerMessage
	Errors() <-chan *sarama.ProducerError
}

type KafkaProducerMock 

type KafkaProducerMock struct {
	// contains filtered or unexported fields
}

func NewKafkaProducerMock 

func NewKafkaProducerMock() *KafkaProducerMock

func (*KafkaProducerMock) Close 

func (producer *KafkaProducerMock) Close() error

func (*KafkaProducerMock) Errors 

func (producer *KafkaProducerMock) Errors() <-chan *sarama.ProducerError

func (*KafkaProducerMock) Input 

func (producer *KafkaProducerMock) Input() chan<- *sarama.ProducerMessage

type MockOutput 

type MockOutput struct {
	// contains filtered or unexported fields
}

MockOutput is a mock of Output interface.

func NewMockOutput 

func NewMockOutput(ctrl *gomock.Controller) *MockOutput

NewMockOutput creates a new mock instance.

func (*MockOutput) EXPECT 

func (m *MockOutput) EXPECT() *MockOutputMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockOutput) Init 

func (m *MockOutput) Init() error

Init mocks base method.

func (*MockOutput) Start 

func (m *MockOutput) Start()

Start mocks base method.

func (*MockOutput) Stop 

func (m *MockOutput) Stop() error

Stop mocks base method.

type MockOutputManager 

type MockOutputManager struct {
	// contains filtered or unexported fields
}

MockOutputManager is a mock of OutputManager interface.

func NewMockOutputManager 

func NewMockOutputManager(ctrl *gomock.Controller) *MockOutputManager

NewMockOutputManager creates a new mock instance.

func (*MockOutputManager) EXPECT 

func (m *MockOutputManager) EXPECT() *MockOutputManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockOutputManager) GetOutputResource 

func (m *MockOutputManager) GetOutputResource(arg0 string) (*OutputResource, error)

GetOutputResource mocks base method.

func (*MockOutputManager) InitOutputs 

func (m *MockOutputManager) InitOutputs() error

InitOutputs mocks base method.

func (*MockOutputManager) StartOutputs 

func (m *MockOutputManager) StartOutputs()

StartOutputs mocks base method.

func (*MockOutputManager) StopOutputs 

func (m *MockOutputManager) StopOutputs()

StopOutputs mocks base method.

type MockOutputManagerMockRecorder 

type MockOutputManagerMockRecorder struct {
	// contains filtered or unexported fields
}

MockOutputManagerMockRecorder is the mock recorder for MockOutputManager.

func (*MockOutputManagerMockRecorder) GetOutputResource 

func (mr *MockOutputManagerMockRecorder) GetOutputResource(arg0 any) *gomock.Call

GetOutputResource indicates an expected call of GetOutputResource.

func (*MockOutputManagerMockRecorder) InitOutputs 

func (mr *MockOutputManagerMockRecorder) InitOutputs() *gomock.Call

InitOutputs indicates an expected call of InitOutputs.

func (*MockOutputManagerMockRecorder) StartOutputs 

func (mr *MockOutputManagerMockRecorder) StartOutputs() *gomock.Call

StartOutputs indicates an expected call of StartOutputs.

func (*MockOutputManagerMockRecorder) StopOutputs 

func (mr *MockOutputManagerMockRecorder) StopOutputs() *gomock.Call

StopOutputs indicates an expected call of StopOutputs.

type MockOutputMockRecorder 

type MockOutputMockRecorder struct {
	// contains filtered or unexported fields
}

MockOutputMockRecorder is the mock recorder for MockOutput.

func (*MockOutputMockRecorder) Init 

func (mr *MockOutputMockRecorder) Init() *gomock.Call

Init indicates an expected call of Init.

func (*MockOutputMockRecorder) Start 

func (mr *MockOutputMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start.

func (*MockOutputMockRecorder) Stop 

func (mr *MockOutputMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop.

type Output 

type Output interface {
	Init() error
	Start()
	Stop() error
}

type OutputManager 

type OutputManager interface {
	InitOutputs() error
	GetOutputResource(string) (*OutputResource, error)
	StartOutputs()
	StopOutputs()
}

type OutputResource 

type OutputResource struct {
	Output      Output
	ResultChan  chan message.Result
	CommandChan chan message.Command
}

func NewOutputResource 

func NewOutputResource() OutputResource

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.