handler

Documentation

Index

• Variables
• type Chain
  • func NewChain(name string, paincChain RpcHander, errChange ErrorChangeFun, ...) *Chain
  • func (this *Chain) Execute(ctx context.Context, req *vearchpb.PartitionData, ...) error
• type ErrorChangeFun
• type PanicHandler
  • func (PanicHandler) Execute(ctx context.Context, req *vearchpb.PartitionData, ...) error
• type RpcHander

Variables

var DefaultPanicHandler = new(PanicHandler)

Types

type Chain

type Chain struct {
	Name string
	// contains filtered or unexported fields
}

func NewChain

func NewChain(name string, paincChain RpcHander, errChange ErrorChangeFun, handlers ...RpcHander) *Chain

func (*Chain) Execute

func (this *Chain) Execute(ctx context.Context, req *vearchpb.PartitionData, reply *vearchpb.PartitionData) error

type ErrorChangeFun

type ErrorChangeFun func(ctx context.Context, err error, req *vearchpb.PartitionData, reply *vearchpb.PartitionData) error

type PanicHandler

type PanicHandler int

func (PanicHandler) Execute

func (PanicHandler) Execute(ctx context.Context, req *vearchpb.PartitionData, reply *vearchpb.PartitionData) error

type RpcHander

type RpcHander interface {
	Execute(ctx context.Context, req *vearchpb.PartitionData, resp *vearchpb.PartitionData) error
}