cypher

Documentation

Index

• type CypherBasicAuth
• type CypherOutput
  • 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

Types

type CypherBasicAuth

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

type CypherOutput

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

func NewCypherOutputFromConfig

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

func (*CypherOutput) Close

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

func (*CypherOutput) Connect

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

func (*CypherOutput) WriteBatch

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