mongoprovider

Documentation

Index

• type Provider
  • func NewProvider() *Provider
  • func (p *Provider) CloseClientConnection(client neosync_benthos_mongodb.MongoClient) error
  • func (p *Provider) GetConnectionClient(cc *mgmtv1alpha1.ConnectionConfig) (neosync_benthos_mongodb.MongoClient, error)

Types

type Provider

type Provider struct{}

func NewProvider

func NewProvider() *Provider

func (*Provider) CloseClientConnection

func (p *Provider) CloseClientConnection(client neosync_benthos_mongodb.MongoClient) error

func (*Provider) GetConnectionClient

func (p *Provider) GetConnectionClient(cc *mgmtv1alpha1.ConnectionConfig) (neosync_benthos_mongodb.MongoClient, error)

this is currently untested as it isn't really used anywhere