cognitosync.go

// Generated by github.com/temporalio/temporal-aws-sdk-generator
// from github.com/aws/aws-sdk-go version 1.35.7

package cognitosync

import (
	"context"

	"github.com/aws/aws-sdk-go/aws"
	"github.com/aws/aws-sdk-go/aws/request"
	"github.com/aws/aws-sdk-go/aws/session"
	"github.com/aws/aws-sdk-go/service/cognitosync"
	"github.com/aws/aws-sdk-go/service/cognitosync/cognitosynciface"

	"github.com/banzaicloud/cadence-aws-sdk/internal"
)

// ensure that imports are valid even if not used by the generated code
var _ = internal.SetClientToken

type _ request.Option

// SessionFactory returns an aws.Session based on the activity context.
type SessionFactory interface {
	Session(ctx context.Context) (*session.Session, error)
}

type Activities struct {
	client cognitosynciface.CognitoSyncAPI

	sessionFactory SessionFactory
}

func NewActivities(sess *session.Session, config ...*aws.Config) *Activities {
	client := cognitosync.New(sess, config...)
	return &Activities{client: client}
}

func NewActivitiesWithSessionFactory(sessionFactory SessionFactory) *Activities {
	return &Activities{sessionFactory: sessionFactory}
}

func (a *Activities) getClient(ctx context.Context) (cognitosynciface.CognitoSyncAPI, error) {
	if a.client != nil { // No need to protect with mutex: we know the client never changes
		return a.client, nil
	}

	sess, err := a.sessionFactory.Session(ctx)
	if err != nil {
		return nil, internal.EncodeError(err)
	}

	return cognitosync.New(sess), nil
}

func (a *Activities) BulkPublish(ctx context.Context, input *cognitosync.BulkPublishInput) (*cognitosync.BulkPublishOutput, error) {
	client, err := a.getClient(ctx)
	if err != nil {
		return nil, internal.EncodeError(err)
	}
	output, err := client.BulkPublishWithContext(ctx, input)

	return output, internal.EncodeError(err)
}

func (a *Activities) DeleteDataset(ctx context.Context, input *cognitosync.DeleteDatasetInput) (*cognitosync.DeleteDatasetOutput, error) {
	client, err := a.getClient(ctx)
	if err != nil {
		return nil, internal.EncodeError(err)
	}
	output, err := client.DeleteDatasetWithContext(ctx, input)

	return output, internal.EncodeError(err)
}

func (a *Activities) DescribeDataset(ctx context.Context, input *cognitosync.DescribeDatasetInput) (*cognitosync.DescribeDatasetOutput, error) {
	client, err := a.getClient(ctx)
	if err != nil {
		return nil, internal.EncodeError(err)
	}
	output, err := client.DescribeDatasetWithContext(ctx, input)

	return output, internal.EncodeError(err)
}

func (a *Activities) DescribeIdentityPoolUsage(ctx context.Context, input *cognitosync.DescribeIdentityPoolUsageInput) (*cognitosync.DescribeIdentityPoolUsageOutput, error) {
	client, err := a.getClient(ctx)
	if err != nil {
		return nil, internal.EncodeError(err)
	}
	output, err := client.DescribeIdentityPoolUsageWithContext(ctx, input)

	return output, internal.EncodeError(err)
}

func (a *Activities) DescribeIdentityUsage(ctx context.Context, input *cognitosync.DescribeIdentityUsageInput) (*cognitosync.DescribeIdentityUsageOutput, error) {
	client, err := a.getClient(ctx)
	if err != nil {
		return nil, internal.EncodeError(err)
	}
	output, err := client.DescribeIdentityUsageWithContext(ctx, input)

	return output, internal.EncodeError(err)
}

func (a *Activities) GetBulkPublishDetails(ctx context.Context, input *cognitosync.GetBulkPublishDetailsInput) (*cognitosync.GetBulkPublishDetailsOutput, error) {
	client, err := a.getClient(ctx)
	if err != nil {
		return nil, internal.EncodeError(err)
	}
	output, err := client.GetBulkPublishDetailsWithContext(ctx, input)

	return output, internal.EncodeError(err)
}

func (a *Activities) GetCognitoEvents(ctx context.Context, input *cognitosync.GetCognitoEventsInput) (*cognitosync.GetCognitoEventsOutput, error) {
	client, err := a.getClient(ctx)
	if err != nil {
		return nil, internal.EncodeError(err)
	}
	output, err := client.GetCognitoEventsWithContext(ctx, input)

	return output, internal.EncodeError(err)
}

func (a *Activities) GetIdentityPoolConfiguration(ctx context.Context, input *cognitosync.GetIdentityPoolConfigurationInput) (*cognitosync.GetIdentityPoolConfigurationOutput, error) {
	client, err := a.getClient(ctx)
	if err != nil {
		return nil, internal.EncodeError(err)
	}
	output, err := client.GetIdentityPoolConfigurationWithContext(ctx, input)

	return output, internal.EncodeError(err)
}

func (a *Activities) ListDatasets(ctx context.Context, input *cognitosync.ListDatasetsInput) (*cognitosync.ListDatasetsOutput, error) {
	client, err := a.getClient(ctx)
	if err != nil {
		return nil, internal.EncodeError(err)
	}
	output, err := client.ListDatasetsWithContext(ctx, input)

	return output, internal.EncodeError(err)
}

func (a *Activities) ListIdentityPoolUsage(ctx context.Context, input *cognitosync.ListIdentityPoolUsageInput) (*cognitosync.ListIdentityPoolUsageOutput, error) {
	client, err := a.getClient(ctx)
	if err != nil {
		return nil, internal.EncodeError(err)
	}
	output, err := client.ListIdentityPoolUsageWithContext(ctx, input)

	return output, internal.EncodeError(err)
}

func (a *Activities) ListRecords(ctx context.Context, input *cognitosync.ListRecordsInput) (*cognitosync.ListRecordsOutput, error) {
	client, err := a.getClient(ctx)
	if err != nil {
		return nil, internal.EncodeError(err)
	}
	output, err := client.ListRecordsWithContext(ctx, input)

	return output, internal.EncodeError(err)
}

func (a *Activities) RegisterDevice(ctx context.Context, input *cognitosync.RegisterDeviceInput) (*cognitosync.RegisterDeviceOutput, error) {
	client, err := a.getClient(ctx)
	if err != nil {
		return nil, internal.EncodeError(err)
	}
	output, err := client.RegisterDeviceWithContext(ctx, input)

	return output, internal.EncodeError(err)
}

func (a *Activities) SetCognitoEvents(ctx context.Context, input *cognitosync.SetCognitoEventsInput) (*cognitosync.SetCognitoEventsOutput, error) {
	client, err := a.getClient(ctx)
	if err != nil {
		return nil, internal.EncodeError(err)
	}
	output, err := client.SetCognitoEventsWithContext(ctx, input)

	return output, internal.EncodeError(err)
}

func (a *Activities) SetIdentityPoolConfiguration(ctx context.Context, input *cognitosync.SetIdentityPoolConfigurationInput) (*cognitosync.SetIdentityPoolConfigurationOutput, error) {
	client, err := a.getClient(ctx)
	if err != nil {
		return nil, internal.EncodeError(err)
	}
	output, err := client.SetIdentityPoolConfigurationWithContext(ctx, input)

	return output, internal.EncodeError(err)
}

func (a *Activities) SubscribeToDataset(ctx context.Context, input *cognitosync.SubscribeToDatasetInput) (*cognitosync.SubscribeToDatasetOutput, error) {
	client, err := a.getClient(ctx)
	if err != nil {
		return nil, internal.EncodeError(err)
	}
	output, err := client.SubscribeToDatasetWithContext(ctx, input)

	return output, internal.EncodeError(err)
}

func (a *Activities) UnsubscribeFromDataset(ctx context.Context, input *cognitosync.UnsubscribeFromDatasetInput) (*cognitosync.UnsubscribeFromDatasetOutput, error) {
	client, err := a.getClient(ctx)
	if err != nil {
		return nil, internal.EncodeError(err)
	}
	output, err := client.UnsubscribeFromDatasetWithContext(ctx, input)

	return output, internal.EncodeError(err)
}

func (a *Activities) UpdateRecords(ctx context.Context, input *cognitosync.UpdateRecordsInput) (*cognitosync.UpdateRecordsOutput, error) {
	client, err := a.getClient(ctx)
	if err != nil {
		return nil, internal.EncodeError(err)
	}
	output, err := client.UpdateRecordsWithContext(ctx, input)

	return output, internal.EncodeError(err)
}