providers

package

v1.1.13 Latest Latest Go to latest Published: May 29, 2025 License: MIT Imports: 18 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/zzliekkas/flow

Links

Open Source Insights

Documentation ¶

Index ¶

type AWSConfig
- func DefaultAWSConfig() AWSConfig
type AWSProvider
- func NewAWSProvider(cfg AWSConfig) (*AWSProvider, error)
type Kd100Provider
type Kd100Service
- func NewKd100Service(cfg config.Kd100Config) *Kd100Service
- func (s *Kd100Service) QueryTrack(com, num string) (string, error)
- func (s *Kd100Service) Sign(param string) string
type Provider

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type AWSConfig ¶

type AWSConfig struct {
	// 区域
	Region string

	// 访问密钥ID
	AccessKeyID string

	// 访问密钥
	SecretAccessKey string

	// 会话令牌
	SessionToken string

	// 使用ECS容器凭证
	UseECSContainerCredential bool

	// 使用EC2实例配置文件
	UseEC2InstanceProfile bool

	// 使用SSO
	UseSSO bool

	// SSO配置文件
	SSOProfile string

	// 配置文件名
	ProfileName string

	// 配置文件路径
	ConfigurationPath string

	// 是否使用共享配置文件
	UseSharedConfig bool

	// 最大重试次数
	MaxRetries int

	// 端点URL（模拟本地使用）
	EndpointURL string

	// 连接超时（秒）
	ConnectionTimeout int
}

AWSConfig AWS配置

func DefaultAWSConfig ¶

func DefaultAWSConfig() AWSConfig

DefaultAWSConfig 返回默认AWS配置

type AWSProvider ¶

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

AWSProvider AWS云服务提供商适配器

func NewAWSProvider ¶

func NewAWSProvider(cfg AWSConfig) (*AWSProvider, error)

NewAWSProvider 创建AWS提供商适配器

func (*AWSProvider) CheckConnectionHealth ¶

func (p *AWSProvider) CheckConnectionHealth(ctx context.Context) error

CheckConnectionHealth 检查AWS连接健康状态

func (*AWSProvider) DetectRegion ¶

func (p *AWSProvider) DetectRegion() string

DetectRegion 自动检测当前区域

func (*AWSProvider) GetSecret ¶

func (p *AWSProvider) GetSecret(ctx context.Context, secretName string) (string, error)

GetSecret 从SecretsManager获取密钥

func (*AWSProvider) Init ¶

func (p *AWSProvider) Init(ctx context.Context) error

Init 初始化AWS提供商

func (*AWSProvider) IsRunningInEC2 ¶

func (p *AWSProvider) IsRunningInEC2() bool

IsRunningInEC2 检查是否在EC2环境中运行

func (*AWSProvider) IsRunningInECS ¶

func (p *AWSProvider) IsRunningInECS() bool

IsRunningInECS 检查是否在ECS环境中运行

func (*AWSProvider) Provider ¶

func (p *AWSProvider) Provider() string

Provider 返回提供商名称

func (*AWSProvider) S3 ¶

func (p *AWSProvider) S3() (*s3.Client, error)

S3 获取S3客户端

func (*AWSProvider) SQS ¶

func (p *AWSProvider) SQS() (*sqs.Client, error)

SQS 获取SQS客户端

func (*AWSProvider) SecretsManager ¶

func (p *AWSProvider) SecretsManager() (*secretsmanager.Client, error)

SecretsManager 获取SecretsManager客户端

func (*AWSProvider) SendSQSMessage ¶

func (p *AWSProvider) SendSQSMessage(ctx context.Context, queueURL, message string) error

SendSQSMessage 发送消息到SQS

func (*AWSProvider) UploadToS3 ¶

func (p *AWSProvider) UploadToS3(ctx context.Context, bucket, key string, data []byte) error

UploadToS3 上传文件到S3

type Kd100Provider ¶ added in v1.1.9

type Kd100Provider struct{}

func (*Kd100Provider) Boot ¶ added in v1.1.9

func (p *Kd100Provider) Boot(application interface{}) error

func (*Kd100Provider) Name ¶ added in v1.1.9

func (p *Kd100Provider) Name() string

func (*Kd100Provider) Priority ¶ added in v1.1.9

func (p *Kd100Provider) Priority() int

func (*Kd100Provider) Register ¶ added in v1.1.9

func (p *Kd100Provider) Register(application interface{}) error

type Kd100Service ¶ added in v1.1.9

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

Kd100Service 封装快递100相关API

func NewKd100Service ¶ added in v1.1.9

func NewKd100Service(cfg config.Kd100Config) *Kd100Service

NewKd100Service 创建服务实例

func (*Kd100Service) QueryTrack ¶ added in v1.1.9

func (s *Kd100Service) QueryTrack(com, num string) (string, error)

QueryTrack 查询物流轨迹

func (*Kd100Service) Sign ¶ added in v1.1.9

func (s *Kd100Service) Sign(param string) string

Sign 生成快递100签名

type Provider ¶

type Provider interface {
	// Provider 返回提供商名称
	Provider() string

	// Init 初始化提供商
	Init(ctx context.Context) error

	// CheckConnectionHealth 检查连接健康状态
	CheckConnectionHealth(ctx context.Context) error
}

Provider 云服务提供商接口

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL