seata

Documentation

Index

• Constants
• Variables
• type Filter
  • func (f *Filter) Decode(ctx *http.HttpContext) filter.FilterStatus
  • func (f *Filter) Encode(ctx *http.HttpContext) filter.FilterStatus
• type FilterFactory
  • func (factory *FilterFactory) Apply() error
  • func (factory *FilterFactory) Config() interface{}
  • func (factory *FilterFactory) PrepareFilterChain(ctx *http.HttpContext, chain filter.FilterChain) error
• type Plugin
  • func (ap *Plugin) CreateFilterFactory() (filter.HttpFilterFactory, error)
  • func (ap *Plugin) Kind() string
• type RequestContext
  • func (ctx *RequestContext) Decode(b []byte) error
  • func (ctx *RequestContext) Encode() ([]byte, error)
• type Seata
  • func (config *Seata) GetClientParameters() keepalive.ClientParameters
• type TCCResource
• type TransactionInfo

Constants

const (
	CommitRequestPath   = "tcc_commit_request_path"
	RollbackRequestPath = "tcc_rollback_request_path"
)

const (
	Kind = "dgp.filter.http.seata"

	SEATA    = "seata"
	XID      = "x_seata_xid"
	BranchID = "x_seata_branch_id"
)

Variables

var (
	VarHost        = "host"
	VarQueryString = "queryString"
)

Types

type Filter

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

Filter is http Filter instance

func (*Filter) Decode

func (f *Filter) Decode(ctx *http.HttpContext) filter.FilterStatus

func (*Filter) Encode

func (f *Filter) Encode(ctx *http.HttpContext) filter.FilterStatus

type FilterFactory

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

FilterFactory is http Filter instance

func (*FilterFactory) Apply

func (factory *FilterFactory) Apply() error

func (*FilterFactory) Config

func (factory *FilterFactory) Config() interface{}

func (*FilterFactory) PrepareFilterChain

func (factory *FilterFactory) PrepareFilterChain(ctx *http.HttpContext, chain filter.FilterChain) error

type Plugin

type Plugin struct {
}

MetricFilter is http Filter plugin.

func (*Plugin) CreateFilterFactory

func (ap *Plugin) CreateFilterFactory() (filter.HttpFilterFactory, error)

func (*Plugin) Kind

func (ap *Plugin) Kind() string

type RequestContext

type RequestContext struct {
	ActionContext map[string]string
	Headers       http.Header
	Body          []byte
	Trailers      http.Header
}

func (*RequestContext) Decode

func (ctx *RequestContext) Decode(b []byte) error

func (*RequestContext) Encode

func (ctx *RequestContext) Encode() ([]byte, error)

type Seata

type Seata struct {
	Addressing         string `yaml:"addressing" json:"addressing"`
	ServerAddressing   string `yaml:"serverAddressing" json:"serverAddressing"`
	CommitRetryCount   int32  `default:"5" yaml:"commitRetryCount" json:"commitRetryCount,omitempty"`
	RollbackRetryCount int32  `default:"5" yaml:"rollbackRetryCount" json:"rollbackRetryCount,omitempty"`

	ClientParameters struct {
		Time                time.Duration `yaml:"time" json:"time"`
		Timeout             time.Duration `yaml:"timeout" json:"timeout"`
		PermitWithoutStream bool          `yaml:"permitWithoutStream" json:"permitWithoutStream"`
	} `yaml:"clientParameters" json:"clientParameters"`

	TransactionInfos []*TransactionInfo `yaml:"transactionInfos" json:"transactionInfos"`
	TCCResources     []*TCCResource     `yaml:"tccResources" json:"tccResources"`
}

Seata seata config

func (*Seata) GetClientParameters

func (config *Seata) GetClientParameters() keepalive.ClientParameters

GetClientParameters used to config grpc connection keep alive

type TCCResource

type TCCResource struct {
	PrepareRequestPath  string `yaml:"prepareRequestPath" json:"prepareRequestPath"`
	CommitRequestPath   string `yaml:"commitRequestPath" json:"commitRequestPath"`
	RollbackRequestPath string `yaml:"rollbackRequestPath" json:"rollbackRequestPath"`
}

TCCResource tcc resource config

type TransactionInfo

type TransactionInfo struct {
	RequestPath string `yaml:"requestPath" json:"requestPath"`
	Timeout     int32  `yaml:"timeout" json:"timeout"`
}

TransactionInfo transaction info config