neo4j

package
v0.0.0-...-25bcdcd Latest Latest
Warning

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

Go to latest
Published: Aug 11, 2022 License: MPL-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func New

func New() (interface{}, error)

Types

type ConnectionProducer

type ConnectionProducer struct {
	ConnectionURL                   string      `json:"connection_url" mapstructure:"connection_url" structs:"connection_url"`
	MaxConnectionPoolSize           int         `json:"max_connection_pool_size" mapstructure:"max_connection_pool_size" structs:"max_connection_pool_size"`
	MaxTransactionRetryTimeRaw      interface{} `json:"max_transaction_retry_time" mapstructure:"max_transaction_retry_time" structs:"max_transaction_retry_time"`
	MaxConnectionLifetimeRaw        interface{} `json:"max_connection_lifetime" mapstructure:"max_connection_lifetime" structs:"max_connection_lifetime"`
	ConnectionAcquisitionTimeoutRaw interface{} `json:"connection_acquisition_timeout" mapstructure:"connection_acquisition_timeout" structs:"connection_acquisition_timeout"`
	SocketConnectTimeoutRaw         interface{} `json:"socket_connect_timeout" mapstructure:"socket_connect_timeout" structs:"socket_connect_timeout"`
	Username                        string      `json:"username" mapstructure:"username" structs:"username"`
	Password                        string      `json:"password" mapstructure:"password" structs:"password"`
	RootCAPemBundle                 string      `json:"root_ca_pem_bundle" structs:"root_ca_pem_bundle" mapstructure:"root_ca_pem_bundle"`
	TLSCertChainPEM                 string      `json:"tls_cert_chain_pem" structs:"tls_cert_chain_pem" mapstructure:"tls_cert_chain_pem"`
	TLSKeyPEM                       string      `json:"tls_key_pem" structs:"tls_key_pem" mapstructure:"tls_key_pem"`
	DatabaseName                    string      `json:"database_name" structs:"database_name" mapstructure:"database_name"`

	RawConfig map[string]interface{}

	Initialized bool

	sync.Mutex
	// contains filtered or unexported fields
}

func (*ConnectionProducer) Close

func (c *ConnectionProducer) Close() error

Close attempts to close the connection

func (*ConnectionProducer) Connection

func (c *ConnectionProducer) Connection(ctx context.Context) (interface{}, error)

func (*ConnectionProducer) Init

func (c *ConnectionProducer) Init(ctx context.Context, conf map[string]interface{}, verifyConnection bool) (map[string]interface{}, error)

func (*ConnectionProducer) Initialize

func (c *ConnectionProducer) Initialize(ctx context.Context, conf map[string]interface{}, verifyConnection bool) error

func (*ConnectionProducer) SecretValues

func (c *ConnectionProducer) SecretValues() map[string]string

type Neo4j

type Neo4j struct {
	*ConnectionProducer
	// contains filtered or unexported fields
}

func (*Neo4j) DeleteUser

func (n *Neo4j) DeleteUser(ctx context.Context, req dbplugin.DeleteUserRequest) (dbplugin.DeleteUserResponse, error)

func (*Neo4j) Initialize

func (n *Neo4j) Initialize(ctx context.Context, req dbplugin.InitializeRequest) (dbplugin.InitializeResponse, error)

func (*Neo4j) NewUser

func (n *Neo4j) NewUser(ctx context.Context, req dbplugin.NewUserRequest) (dbplugin.NewUserResponse, error)

func (*Neo4j) Type

func (n *Neo4j) Type() (string, error)

func (*Neo4j) UpdateUser

func (n *Neo4j) UpdateUser(ctx context.Context, req dbplugin.UpdateUserRequest) (dbplugin.UpdateUserResponse, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL