cypher

package

v1.6.0 Latest Latest Go to latest Published: Mar 30, 2025 License: MIT Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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

func NewCypherInputFromConfig(conf *service.ParsedConfig, mgr *service.Resources) (*CypherInput, error)

func (cyp *CypherInput) Close(ctx context.Context) (err error)

func (cyp *CypherInput) Connect(ctx context.Context) error

func (cyp *CypherInput) Read(ctx context.Context) (*service.Message, service.AckFunc, error)

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

func NewCypherOutputFromConfig(conf *service.ParsedConfig, mgr *service.Resources) (*CypherOutput, error)

func (cyp *CypherOutput) Close(ctx context.Context) error

func (cyp *CypherOutput) Connect(ctx context.Context) error

func (cyp *CypherOutput) WriteBatch(ctx context.Context, batch service.MessageBatch) error