pkg

Documentation

Index

• type Glue
  • func (g Glue) StartJobRun(ctx context.Context, params *glue.StartJobRunInput, ...) (*glue.StartJobRunOutput, error)
• type GlueAccess
• type MockGlueAccess
  • func (g MockGlueAccess) StartJobRun(ctx context.Context, params *glue.StartJobRunInput, ...) (*glue.StartJobRunOutput, error)
• type MockS3Access
  • func (s MockS3Access) GetObject(ctx context.Context, params *s3.GetObjectInput, optFns ...func(*s3.Options)) (*s3.GetObjectOutput, error)
  • func (s MockS3Access) PutObject(ctx context.Context, params *s3.PutObjectInput, optFns ...func(*s3.Options)) (*s3.PutObjectOutput, error)
• type MockSQSAccess
  • func (s MockSQSAccess) DeleteMessage(ctx context.Context, params *sqs.DeleteMessageInput, ...) (*sqs.DeleteMessageOutput, error)
  • func (s MockSQSAccess) SendMessage(ctx context.Context, params *sqs.SendMessageInput, ...) (*sqs.SendMessageOutput, error)
• type MockSSMClient
  • func (s MockSSMClient) GetParameter(ctx context.Context, params *ssm.GetParameterInput, ...) (*ssm.GetParameterOutput, error)
• type S3
  • func (s S3) GetObject(ctx context.Context, params *s3.GetObjectInput, optFns ...func(*s3.Options)) (*s3.GetObjectOutput, error)
  • func (s S3) PutObject(ctx context.Context, params *s3.PutObjectInput, optFns ...func(*s3.Options)) (*s3.PutObjectOutput, error)
• type S3Access
• type SQS
  • func (s SQS) DeleteMessage(ctx context.Context, params *sqs.DeleteMessageInput, ...) (*sqs.DeleteMessageOutput, error)
  • func (s SQS) SendMessage(ctx context.Context, params *sqs.SendMessageInput, ...) (*sqs.SendMessageOutput, error)
• type SQSAccess
• type SSM
  • func (s SSM) GetParameter(ctx context.Context, params *ssm.GetParameterInput, ...) (*ssm.GetParameterOutput, error)
• type SSMAccess

Types

type Glue

type Glue struct {
	Client *glue.Client
}

Glue is a Concrete for Glue operations

func (Glue) StartJobRun

func (g Glue) StartJobRun(ctx context.Context, params *glue.StartJobRunInput, optFns ...func(*glue.Options)) (*glue.StartJobRunOutput, error)

StartJobRun starts a new AWS Glue job.

type GlueAccess

type GlueAccess interface {
	StartJobRun(ctx context.Context, params *glue.StartJobRunInput, optFns ...func(*glue.Options)) (*glue.StartJobRunOutput, error)
}

GlueAccess is an abstraction for AWS Glue

type MockGlueAccess

type MockGlueAccess struct {
	mock.Mock
}

MockGlueAccess mocks aws glue operations

func (MockGlueAccess) StartJobRun

func (g MockGlueAccess) StartJobRun(ctx context.Context, params *glue.StartJobRunInput, optFns ...func(*glue.Options)) (*glue.StartJobRunOutput, error)

StartJobRun mocks start a glue job.

type MockS3Access

type MockS3Access struct {
	mock.Mock
}

MockS3Access mocks S3 operations

func (MockS3Access) GetObject

func (s MockS3Access) GetObject(ctx context.Context, params *s3.GetObjectInput, optFns ...func(*s3.Options)) (*s3.GetObjectOutput, error)

GetObject mocks getting an object from S3

func (MockS3Access) PutObject

func (s MockS3Access) PutObject(ctx context.Context, params *s3.PutObjectInput, optFns ...func(*s3.Options)) (*s3.PutObjectOutput, error)

PutObject mocks putting an object to s3

type MockSQSAccess

type MockSQSAccess struct {
	mock.Mock
}

MockSQSAccess mocks SQS operations

func (MockSQSAccess) DeleteMessage

func (s MockSQSAccess) DeleteMessage(ctx context.Context, params *sqs.DeleteMessageInput, optFns ...func(*sqs.Options)) (*sqs.DeleteMessageOutput, error)

DeleteMessage mocks deleting a message to SQS.

func (MockSQSAccess) SendMessage

func (s MockSQSAccess) SendMessage(ctx context.Context, params *sqs.SendMessageInput, optFns ...func(*sqs.Options)) (*sqs.SendMessageOutput, error)

SendMessage mocks sending a message to SQS.

type MockSSMClient

type MockSSMClient struct {
	mock.Mock
}

MockSSMClient mocks SSM operations

func (MockSSMClient) GetParameter

func (s MockSSMClient) GetParameter(ctx context.Context, params *ssm.GetParameterInput, optFns ...func(*ssm.Options)) (*ssm.GetParameterOutput, error)

GetParameter mocks getting a parameter from SSM.

type S3

type S3 struct {
	Client *s3.Client
}

S3 is a Concrete Wrapper for S3 Operations

func (S3) GetObject

func (s S3) GetObject(ctx context.Context, params *s3.GetObjectInput, optFns ...func(*s3.Options)) (*s3.GetObjectOutput, error)

GetObject gets an object from S3

func (S3) PutObject

func (s S3) PutObject(ctx context.Context, params *s3.PutObjectInput, optFns ...func(*s3.Options)) (*s3.PutObjectOutput, error)

PutObject puts an object into S3

type S3Access

type S3Access interface {
	GetObject(ctx context.Context, params *s3.GetObjectInput, optFns ...func(*s3.Options)) (*s3.GetObjectOutput, error)
	PutObject(ctx context.Context, params *s3.PutObjectInput, optFns ...func(*s3.Options)) (*s3.PutObjectOutput, error)
}

S3Access is an abstraction for S3 Operations

type SQS

type SQS struct {
	Client *sqs.Client
}

SQS is a Concrete Wrapper for SQS

func (SQS) DeleteMessage

func (s SQS) DeleteMessage(ctx context.Context, params *sqs.DeleteMessageInput, optFns ...func(*sqs.Options)) (*sqs.DeleteMessageOutput, error)

DeleteMessage deletes a message from SQS

func (SQS) SendMessage

func (s SQS) SendMessage(ctx context.Context, params *sqs.SendMessageInput, optFns ...func(*sqs.Options)) (*sqs.SendMessageOutput, error)

SendMessage sends a message to SQS

type SQSAccess

type SQSAccess interface {
	SendMessage(ctx context.Context, params *sqs.SendMessageInput, optFns ...func(*sqs.Options)) (*sqs.SendMessageOutput, error)
	DeleteMessage(ctx context.Context, params *sqs.DeleteMessageInput, optFns ...func(*sqs.Options)) (*sqs.DeleteMessageOutput, error)
}

SQSAccess is an abstraction for SQS Operations

type SSM

type SSM struct {
	Client *ssm.Client
}

SSM is a Concrete Wrapper for SSM

func (SSM) GetParameter

func (s SSM) GetParameter(ctx context.Context, params *ssm.GetParameterInput, optFns ...func(*ssm.Options)) (*ssm.GetParameterOutput, error)

GetParameter gets a parameter from the SSM store.

type SSMAccess

type SSMAccess interface {
	GetParameter(ctx context.Context, params *ssm.GetParameterInput, optFns ...func(*ssm.Options)) (*ssm.GetParameterOutput, error)
}

SSMAccess is an abstraction for SSM Operations