asynq

Documentation

Index

• Constants
• Variables
• func RegisterUserTaskHandler(mux *asynq.ServeMux, srv UserTaskHandler)
• type CreateUserPayload
  • func (*CreateUserPayload) Descriptor() ([]byte, []int)
  • func (x *CreateUserPayload) GetName() string
  • func (*CreateUserPayload) ProtoMessage()
  • func (x *CreateUserPayload) ProtoReflect() protoreflect.Message
  • func (x *CreateUserPayload) Reset()
  • func (x *CreateUserPayload) String() string
• type UnimplementedUserTaskHandlerImpl
  • func (*UnimplementedUserTaskHandlerImpl) UnmarshalBinary(b []byte, v any) error
• type UpdateUserPayload
  • func (*UpdateUserPayload) Descriptor() ([]byte, []int)
  • func (x *UpdateUserPayload) GetName() string
  • func (*UpdateUserPayload) ProtoMessage()
  • func (x *UpdateUserPayload) ProtoReflect() protoreflect.Message
  • func (x *UpdateUserPayload) Reset()
  • func (x *UpdateUserPayload) String() string
• type UserTaskClient
  • func NewUserTaskClient(client *asynq.Client) UserTaskClient
• type UserTaskClientImpl
  • func (c *UserTaskClientImpl) CreateUser(ctx context.Context, in *CreateUserPayload, opts ...asynq.Option) (*asynq.TaskInfo, error)
  • func (c *UserTaskClientImpl) SetMarshaler(marshaler func(any) ([]byte, error)) UserTaskClient
  • func (c *UserTaskClientImpl) UpdateUser(ctx context.Context, in *UpdateUserPayload, opts ...asynq.Option) (*asynq.TaskInfo, error)
• type UserTaskHandler

Constants

const Pattern_User_CreateUser = "user:create"

const Pattern_User_UpdateUser = "user:update"

Variables

var File_asynq_proto protoreflect.FileDescriptor

Functions

func RegisterUserTaskHandler

func RegisterUserTaskHandler(mux *asynq.ServeMux, srv UserTaskHandler)

Types

type CreateUserPayload

type CreateUserPayload struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateUserPayload) Descriptor

func (*CreateUserPayload) Descriptor() ([]byte, []int)

Deprecated: Use CreateUserPayload.ProtoReflect.Descriptor instead.

func (*CreateUserPayload) GetName

func (x *CreateUserPayload) GetName() string

func (*CreateUserPayload) ProtoMessage

func (*CreateUserPayload) ProtoMessage()

func (*CreateUserPayload) ProtoReflect

func (x *CreateUserPayload) ProtoReflect() protoreflect.Message

func (*CreateUserPayload) Reset

func (x *CreateUserPayload) Reset()

func (*CreateUserPayload) String

func (x *CreateUserPayload) String() string

type UnimplementedUserTaskHandlerImpl

type UnimplementedUserTaskHandlerImpl struct{}

func (*UnimplementedUserTaskHandlerImpl) UnmarshalBinary

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

type UpdateUserPayload

type UpdateUserPayload struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateUserPayload) Descriptor

func (*UpdateUserPayload) Descriptor() ([]byte, []int)

Deprecated: Use UpdateUserPayload.ProtoReflect.Descriptor instead.

func (*UpdateUserPayload) GetName

func (x *UpdateUserPayload) GetName() string

func (*UpdateUserPayload) ProtoMessage

func (*UpdateUserPayload) ProtoMessage()

func (*UpdateUserPayload) ProtoReflect

func (x *UpdateUserPayload) ProtoReflect() protoreflect.Message

func (*UpdateUserPayload) Reset

func (x *UpdateUserPayload) Reset()

func (*UpdateUserPayload) String

func (x *UpdateUserPayload) String() string

type UserTaskClient

type UserTaskClient interface {
	// SetMarshaler set marshal the binary encoding of v function.
	SetMarshaler(func(any) ([]byte, error)) UserTaskClient
	// CreateUser 异步创建用户
	CreateUser(context.Context, *CreateUserPayload, ...asynq.Option) (*asynq.TaskInfo, error)
	// UpdateUser 异步更新用户
	UpdateUser(context.Context, *UpdateUserPayload, ...asynq.Option) (*asynq.TaskInfo, error)
}

func NewUserTaskClient

func NewUserTaskClient(client *asynq.Client) UserTaskClient

NewUserTaskClient new client. use default proto.Marhsal.

type UserTaskClientImpl

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

func (*UserTaskClientImpl) CreateUser

func (c *UserTaskClientImpl) CreateUser(ctx context.Context, in *CreateUserPayload, opts ...asynq.Option) (*asynq.TaskInfo, error)

CreateUser 异步创建用户

func (*UserTaskClientImpl) SetMarshaler

func (c *UserTaskClientImpl) SetMarshaler(marshaler func(any) ([]byte, error)) UserTaskClient

SetMarshaler set marshal the binary encoding of v function.

func (*UserTaskClientImpl) UpdateUser

func (c *UserTaskClientImpl) UpdateUser(ctx context.Context, in *UpdateUserPayload, opts ...asynq.Option) (*asynq.TaskInfo, error)

UpdateUser 异步更新用户

type UserTaskHandler

type UserTaskHandler interface {
	// CreateUser 异步创建用户
	CreateUser(context.Context, *CreateUserPayload) error
	// UpdateUser 异步更新用户
	UpdateUser(context.Context, *UpdateUserPayload) error
	// UnmarshalBinary parses the binary data and stores the result
	// in the value pointed to by v.
	UnmarshalBinary([]byte, any) error
}