seata

Documentation

Index

• Constants
• func CreateFilterFactory(conf map[string]interface{}) (api.StreamFilterChainFactory, error)
• func NewFilter(conf *Seata) (*filter, error)
• type RequestContext
  • func (ctx *RequestContext) Decode(b []byte)
  • 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 (
	SEATA        = "seata"
	XID          = "x_seata_xid"
	BranchID     = "x_seata_branch_id"
	ResponseFlag = 0x600
)

Functions

func CreateFilterFactory

func CreateFilterFactory(conf map[string]interface{}) (api.StreamFilterChainFactory, error)

func NewFilter

func NewFilter(conf *Seata) (*filter, error)

Types

type RequestContext

type RequestContext struct {
	ActionContext map[string]string
	Headers       protocol.CommonHeader
	Body          buffer.IoBuffer
	Trailers      protocol.CommonHeader
}

func (*RequestContext) Decode

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

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