imparse

type ActionFilter interface {
	FrameFilters(tp FrameType) []Filter
}

type Answer interface {
	Check(context.Context, Checker, Frame) error
	Filter(context.Context, Frame) (uint64, error)
	Transport(context.Context, Frame) error
	Ack(context.Context, Frame) (int64, error)
}

type BizProto interface {
	AckBody() ([]byte, error)
	PushBody() ([]byte, error)
}

type Cache interface {
	GetMsg(ctx context.Context, from, seq string) (*MsgIndex, error)
	AddMsg(ctx context.Context, uid string, m *MsgIndex) error
	GetMid(ctx context.Context) (id int64, err error)
}

type Channel int

type Checker interface {
	CheckFrame(frame Frame) error
}

type DB interface {
	SaveMsg(deviceType auth.Device, frame Frame) error
}

type Exec interface {
	Transport(ctx context.Context, id int64, key, from, target string, ch Channel, frameType FrameType, data []byte) error
	RevAck(ctx context.Context, id int64, keys []string, data []byte) error
}

type Filter func(ctx context.Context, frame Frame) error

type Frame interface {
	Type() FrameType
	Filter(ctx context.Context, db Cache, filters ...Filter) (uint64, error)
	Transport(ctx context.Context, exec Exec) error
	Ack(ctx context.Context, exec Exec) (int64, error)
}

type FrameType string

type MsgIndex struct {
	Mid        string
	Seq        string
	SenderId   string
	CreateTime uint64
}

type Pusher interface {
}

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

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

type Storage interface {
	SaveMsg(context.Context, auth.Device, Frame) error
}

type Trace interface {
	StartSpanFromContext(ctx context.Context, funcName string) (func(), context.Context)
}