asynq_auxiliary

Documentation

Index

• Variables
• type BinaryMarshaler
• type BinaryUnmarshaler
• type ClientOption
  • func WithClientMarshaler(marshaler BinaryMarshaler) ClientOption
  • func WithClientMarshalerJSON() ClientOption
  • func WithClientMarshalerProtobuf() ClientOption
• type ClientSettings
  • func NewClientSettings(opts ...ClientOption) *ClientSettings
• type HandlerOption
  • func WithHandlerUnmarshaler(unmarshaler BinaryUnmarshaler) HandlerOption
  • func WithHandlerUnmarshalerJSON() HandlerOption
  • func WithHandlerUnmarshalerProtobuf() HandlerOption
• type HandlerSettings
  • func NewHandlerSettings(opts ...HandlerOption) *HandlerSettings
• type JSON
  • func (JSON) MarshalBinary(v any) ([]byte, error)
  • func (JSON) UnmarshalBinary(b []byte, v any) error
• type Protobuf
  • func (Protobuf) MarshalBinary(v any) ([]byte, error)
  • func (Protobuf) UnmarshalBinary(b []byte, v any) error

Variables

var BinaryJSON = JSON{}

var BinaryProtobuf = Protobuf{}

Types

type BinaryMarshaler

type BinaryMarshaler interface {
	MarshalBinary(v any) (data []byte, err error)
}

type BinaryUnmarshaler

type BinaryUnmarshaler interface {
	UnmarshalBinary(data []byte, v any) error
}

type ClientOption

type ClientOption func(*ClientSettings)

ClientOption 客户端选项

func WithClientMarshaler

func WithClientMarshaler(marshaler BinaryMarshaler) ClientOption

WithClientMarshaler 使用指定序列化

func WithClientMarshalerJSON

func WithClientMarshalerJSON() ClientOption

WithClientMarshalerJSON 使用 json.Marshal Marshaler

func WithClientMarshalerProtobuf

func WithClientMarshalerProtobuf() ClientOption

WithClientMarshalerProtobuf 使用 proto.Marshal Marshaler

type ClientSettings

type ClientSettings struct {
	Marshaler BinaryMarshaler
}

ClientSettings 客户端配置

func NewClientSettings

func NewClientSettings(opts ...ClientOption) *ClientSettings

NewClientSettings 新建配置, 默认使用 json.Marshal

type HandlerOption

type HandlerOption func(*HandlerSettings)

HandlerOption 处理器选项

func WithHandlerUnmarshaler

func WithHandlerUnmarshaler(unmarshaler BinaryUnmarshaler) HandlerOption

WithHandlerUnmarshaler 指定反序列化

func WithHandlerUnmarshalerJSON

func WithHandlerUnmarshalerJSON() HandlerOption

WithHandlerUnmarshalerJSON 使用 json.Unmarshal Unmarshaler

func WithHandlerUnmarshalerProtobuf

func WithHandlerUnmarshalerProtobuf() HandlerOption

WithHandlerUnmarshalerProtobuf 使用 proto.Unmarshal Unmarshaler

type HandlerSettings

type HandlerSettings struct {
	Unmarshaler BinaryUnmarshaler
}

HandlerSettings 处理器配置

func NewHandlerSettings

func NewHandlerSettings(opts ...HandlerOption) *HandlerSettings

NewHandlerSettings 新建处理器选项, 默认使用 proto.Unmarshal

type JSON

type JSON struct{}

func (JSON) MarshalBinary

func (JSON) MarshalBinary(v any) ([]byte, error)

func (JSON) UnmarshalBinary

func (JSON) UnmarshalBinary(b []byte, v any) error

type Protobuf

type Protobuf struct{}

func (Protobuf) MarshalBinary

func (Protobuf) MarshalBinary(v any) ([]byte, error)

func (Protobuf) UnmarshalBinary

func (Protobuf) UnmarshalBinary(b []byte, v any) error