Documentation ¶
Index ¶
- func New() (interface{}, error)
- type ConnectionProducer
- func (c *ConnectionProducer) Close() error
- func (c *ConnectionProducer) Connection(ctx context.Context) (interface{}, error)
- func (c *ConnectionProducer) Init(ctx context.Context, conf map[string]interface{}, verifyConnection bool) (map[string]interface{}, error)
- func (c *ConnectionProducer) Initialize(ctx context.Context, conf map[string]interface{}, verifyConnection bool) error
- func (c *ConnectionProducer) SecretValues() map[string]string
- type Neo4j
- func (n *Neo4j) DeleteUser(ctx context.Context, req dbplugin.DeleteUserRequest) (dbplugin.DeleteUserResponse, error)
- func (n *Neo4j) Initialize(ctx context.Context, req dbplugin.InitializeRequest) (dbplugin.InitializeResponse, error)
- func (n *Neo4j) NewUser(ctx context.Context, req dbplugin.NewUserRequest) (dbplugin.NewUserResponse, error)
- func (n *Neo4j) Type() (string, error)
- func (n *Neo4j) UpdateUser(ctx context.Context, req dbplugin.UpdateUserRequest) (dbplugin.UpdateUserResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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) Initialize ¶
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 (*Neo4j) Initialize ¶
Click to show internal directories.
Click to hide internal directories.