clients

Documentation

Index

• type DynamoDbClient
  • func (c DynamoDbClient) CreateTable(input *dynamodb.CreateTableInput) error
  • func (c DynamoDbClient) GetItemsInTable(table string) ([]map[string]types.AttributeValue, error)
  • func (c DynamoDbClient) New(hostname string, port int) (DynamoDbClient, error)
  • func (c DynamoDbClient) PutItem(input *dynamodb.PutItemInput) error
  • func (c DynamoDbClient) PutObject(table string, object interface{}) error
• type IDynamoDbClient
• type ISqsClient
• type SqsClient
  • func (s SqsClient) GetMessagesFrom(queue string) ([]types.Message, error)
  • func (s SqsClient) New(port int) (SqsClient, error)

Types

type DynamoDbClient

type DynamoDbClient struct {
	// contains filtered or unexported fields
}

func (DynamoDbClient) CreateTable

func (c DynamoDbClient) CreateTable(input *dynamodb.CreateTableInput) error

func (DynamoDbClient) GetItemsInTable

func (c DynamoDbClient) GetItemsInTable(table string) ([]map[string]types.AttributeValue, error)

func (DynamoDbClient) New

func (c DynamoDbClient) New(hostname string, port int) (DynamoDbClient, error)

func (DynamoDbClient) PutItem

func (c DynamoDbClient) PutItem(input *dynamodb.PutItemInput) error

func (DynamoDbClient) PutObject

func (c DynamoDbClient) PutObject(table string, object interface{}) error

type IDynamoDbClient

type IDynamoDbClient interface {
	Scan(ctx context.Context, params *dynamodb.ScanInput, optFns ...func(*dynamodb.Options)) (*dynamodb.ScanOutput, error)
	CreateTable(ctx context.Context, params *dynamodb.CreateTableInput, optFns ...func(*dynamodb.Options)) (*dynamodb.CreateTableOutput, error)
	PutItem(ctx context.Context, params *dynamodb.PutItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.PutItemOutput, error)
}

type ISqsClient

type ISqsClient interface {
	GetQueueUrl(ctx context.Context, params *sqs.GetQueueUrlInput, optFns ...func(*sqs.Options)) (*sqs.GetQueueUrlOutput, error)
	ReceiveMessage(ctx context.Context, params *sqs.ReceiveMessageInput, optFns ...func(*sqs.Options)) (*sqs.ReceiveMessageOutput, error)
}

type SqsClient

type SqsClient struct {
	// contains filtered or unexported fields
}

func (SqsClient) GetMessagesFrom

func (s SqsClient) GetMessagesFrom(queue string) ([]types.Message, error)

func (SqsClient) New

func (s SqsClient) New(port int) (SqsClient, error)