types

type CfgMap map[string]interface{}

type Command = cli.Command

type Commands = []cli.Command

type Event struct {
	// Key sets the key of the message for routing policy
	Key string
	// Payload for the message
	Payload []byte
	// Properties attach application defined properties on the message
	Properties map[string]string
}

type EventType int32

type Flags = []cli.Flag

type Handler func(context.Context, Event) error

type Header = metadata.MD

type Healthy func(req *http.Request) error

type L = []interface{}

type M = map[string]interface{}

type MiddleNext func(ctx context.Context, req Request, resp func(rsp Response) error) error

type Middleware func(next MiddleNext) MiddleNext

type Publisher interface {
	Publish(ctx context.Context, event Event) error
	Close() error
}

type Request interface {
	// Client server or client
	Client() bool

	// Kind [http|grpc...]
	Kind() string

	// Service name requested
	Service() string

	// Method The action requested
	Method() string

	// Endpoint name requested
	Endpoint() string

	// ContentType Content type provided
	ContentType() string

	// Header of the request
	Header() Header

	// Codec The encoded message
	Codec() encoding.Codec

	// Payload is the decoded value
	Payload() interface{}

	// Read the encode request body
	Read() ([]byte, error)

	// Stream Indicates whether it's a stream
	Stream() bool
}

type Response interface {
	Header() Header
	Payload() interface{}
	Stream() bool
}

type Strs = []string

type Subscriber interface {
	Subscribe(ctx context.Context, h Handler) error
	Close() error
}

type Vars func(name string, data func() interface{})

type WatchResp struct {
	Type    string
	Event   EventType
	Key     string
	Value   []byte
	Version int64
}

type Watcher func(name string, r *WatchResp) error