sls

Documentation

Index

• func NewAliCloudSlsLogstorage(logger logger.Logger) bindings.OutputBinding
• type AliCloudSlsLogstorage
  • func (s *AliCloudSlsLogstorage) Init(metadata bindings.Metadata) error
  • func (s *AliCloudSlsLogstorage) Invoke(ctx context.Context, req *bindings.InvokeRequest) (*bindings.InvokeResponse, error)
  • func (s *AliCloudSlsLogstorage) Operations() []bindings.OperationKind
• type Callback
  • func (callback *Callback) Fail(result *producer.Result)
  • func (callback *Callback) Success(result *producer.Result)
• type SlsLogstorageMetadata

Functions

func NewAliCloudSlsLogstorage

func NewAliCloudSlsLogstorage(logger logger.Logger) bindings.OutputBinding

Types

type AliCloudSlsLogstorage

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

func (*AliCloudSlsLogstorage) Init

func (s *AliCloudSlsLogstorage) Init(metadata bindings.Metadata) error

parse metadata field

func (*AliCloudSlsLogstorage) Invoke

func (s *AliCloudSlsLogstorage) Invoke(ctx context.Context, req *bindings.InvokeRequest) (*bindings.InvokeResponse, error)

func (*AliCloudSlsLogstorage) Operations

func (s *AliCloudSlsLogstorage) Operations() []bindings.OperationKind

type Callback

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

func (*Callback) Fail

func (callback *Callback) Fail(result *producer.Result)

func (*Callback) Success

func (callback *Callback) Success(result *producer.Result)

type SlsLogstorageMetadata

type SlsLogstorageMetadata struct {
	Endpoint        string `json:"endpoint"`
	AccessKeyID     string `json:"accessKeyID"`
	AccessKeySecret string `json:"accessKeySecret"`
}