sls

Documentation

Index

• type Callback
  • func (callback *Callback) Fail(result *producer.Result)
  • func (callback *Callback) Success(result *producer.Result)
• type Handler
  • func NewSLSHandler(config map[string][]byte) (*Handler, error)
  • func (s *Handler) Store(ctx monitorContext.Context, run *v1alpha1.WorkflowRun) error

Types

type Callback

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

Callback is for sls callback

func (*Callback) Fail

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

Fail is fail callback

func (*Callback) Success

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

Success is success callback

type Handler

type Handler struct {
	LogStoreName   string
	ProjectName    string
	ProducerConfig *producer.ProducerConfig
}

Handler is sls config.

func NewSLSHandler

func NewSLSHandler(config map[string][]byte) (*Handler, error)

NewSLSHandler create a new sls handler

func (*Handler) Store

func (s *Handler) Store(ctx monitorContext.Context, run *v1alpha1.WorkflowRun) error

Store is store workflowRun to sls