connections

Documentation

Index

• func New(c Connections) sdkservices.Connections
• type Connections
  • func (c *Connections) Create(ctx context.Context, conn sdktypes.Connection) (sdktypes.ConnectionID, error)
  • func (c *Connections) Delete(ctx context.Context, id sdktypes.ConnectionID) error
  • func (c *Connections) Get(ctx context.Context, id sdktypes.ConnectionID) (sdktypes.Connection, error)
  • func (c *Connections) List(ctx context.Context, filter sdkservices.ListConnectionsFilter) ([]sdktypes.Connection, error)
  • func (c *Connections) RefreshStatus(ctx context.Context, id sdktypes.ConnectionID) (sdktypes.Status, error)
  • func (c *Connections) Test(ctx context.Context, id sdktypes.ConnectionID) (sdktypes.Status, error)
  • func (c *Connections) Update(ctx context.Context, conn sdktypes.Connection) error

Functions

func New

func New(c Connections) sdkservices.Connections

Types

type Connections

type Connections struct {
	fx.In

	Z            *zap.Logger
	DB           db.DB
	Integrations sdkservices.Integrations
}

func (*Connections) Create

func (c *Connections) Create(ctx context.Context, conn sdktypes.Connection) (sdktypes.ConnectionID, error)

func (*Connections) Delete

func (c *Connections) Delete(ctx context.Context, id sdktypes.ConnectionID) error

func (*Connections) Get

func (c *Connections) Get(ctx context.Context, id sdktypes.ConnectionID) (sdktypes.Connection, error)

func (*Connections) List

func (c *Connections) List(ctx context.Context, filter sdkservices.ListConnectionsFilter) ([]sdktypes.Connection, error)

func (*Connections) RefreshStatus

func (c *Connections) RefreshStatus(ctx context.Context, id sdktypes.ConnectionID) (sdktypes.Status, error)

func (*Connections) Test

func (c *Connections) Test(ctx context.Context, id sdktypes.ConnectionID) (sdktypes.Status, error)

func (*Connections) Update

func (c *Connections) Update(ctx context.Context, conn sdktypes.Connection) error