seata

Documentation

Index

• Constants
• type Filter
  • func (f *Filter) Invoke(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation) protocol.Result
  • func (f *Filter) OnResponse(ctx context.Context, result protocol.Result, invoker protocol.Invoker, ...) protocol.Result

Constants

const (
	SEATA_XID = constant.DubboCtxKey("SEATA_XID")
)

Types

type Filter

type Filter struct{}

Filter when use seata-golang, use this filter to transfer xid

func (*Filter) Invoke

func (f *Filter) Invoke(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation) protocol.Result

Invoke Get Xid by attachment key `SEATA_XID`. When use Seata, transfer xid by attachments

func (*Filter) OnResponse

func (f *Filter) OnResponse(ctx context.Context, result protocol.Result, invoker protocol.Invoker, invocation protocol.Invocation) protocol.Result

OnResponse dummy process, returns the result directly