dynamodb

Documentation

Index

• Constants
• type Action
• type Connector
  • func (d *Connector) GetMetaInfo(resourceOptions map[string]interface{}) (common.MetaInfoResult, error)
  • func (d *Connector) Run(resourceOptions map[string]interface{}, actionOptions map[string]interface{}, ...) (common.RuntimeResult, error)
  • func (d *Connector) TestConnection(resourceOptions map[string]interface{}) (common.ConnectionResult, error)
  • func (d *Connector) ValidateActionTemplate(actionOptions map[string]interface{}) (common.ValidateResult, error)
  • func (d *Connector) ValidateResourceOptions(resourceOptions map[string]interface{}) (common.ValidateResult, error)
• type DeleteItemParams
• type GetItemParams
• type PutItemParams
• type QueryParams
• type Resource
• type ScanParams
• type UpdateItemParams

Constants

const (
	QUERY_METHOD       = "query"
	SCAN_METHOD        = "scan"
	PUT_ITEM_METHOD    = "putItem"
	GET_ITEM_METHOD    = "getItem"
	UPDATE_ITEM_METHOD = "updateItem"
	DELETE_ITEM_METHOD = "deleteItem"
)

Types

type Action

type Action struct {
	Method       string `validate:"required,oneof=query scan putItem getItem updateItem deleteItem"`
	Table        string
	UseJson      bool
	Parameters   string
	StructParams map[string]interface{}
}

type Connector

type Connector struct {
	ResourceOpts Resource
	ActionOpts   Action
}

func (*Connector) GetMetaInfo

func (d *Connector) GetMetaInfo(resourceOptions map[string]interface{}) (common.MetaInfoResult, error)

func (*Connector) Run

func (d *Connector) Run(resourceOptions map[string]interface{}, actionOptions map[string]interface{}, rawActionOptions map[string]interface{}) (common.RuntimeResult, error)

func (*Connector) TestConnection

func (d *Connector) TestConnection(resourceOptions map[string]interface{}) (common.ConnectionResult, error)

func (*Connector) ValidateActionTemplate

func (d *Connector) ValidateActionTemplate(actionOptions map[string]interface{}) (common.ValidateResult, error)

func (*Connector) ValidateResourceOptions

func (d *Connector) ValidateResourceOptions(resourceOptions map[string]interface{}) (common.ValidateResult, error)

type DeleteItemParams

type DeleteItemParams struct {
	Key                       map[string]interface{}
	ConditionExpression       string
	ExpressionAttributeNames  map[string]string
	ExpressionAttributeValues map[string]interface{}
}

type GetItemParams

type GetItemParams struct {
	Key                      map[string]interface{}
	ProjectionExpression     string
	ExpressionAttributeNames map[string]string
}

type PutItemParams

type PutItemParams struct {
	Item                      map[string]interface{}
	ConditionExpression       string
	ExpressionAttributeNames  map[string]string
	ExpressionAttributeValues map[string]interface{}
}

type QueryParams

type QueryParams struct {
	IndexName                 string
	KeyConditionExpression    string
	ProjectionExpression      string
	FilterExpression          string
	ExpressionAttributeNames  map[string]string
	ExpressionAttributeValues map[string]interface{}
	Limit                     int32
	Select                    string
}

type Resource

type Resource struct {
	Region          string `validate:"required"`
	AccessKeyID     string `validate:"required"`
	SecretAccessKey string `validate:"required"`
}

type ScanParams

type ScanParams struct {
	IndexName                 string
	ProjectionExpression      string
	FilterExpression          string
	ExpressionAttributeNames  map[string]string
	ExpressionAttributeValues map[string]interface{}
	Limit                     int32
	Select                    string
}

type UpdateItemParams

type UpdateItemParams struct {
	Key                       map[string]interface{}
	UpdateExpression          string
	ConditionExpression       string
	ExpressionAttributeNames  map[string]string
	ExpressionAttributeValues map[string]interface{}
}