example

Mar 15, 2022

Changes in this version

type BookSvcTask

+ func (j *BookSvcTask) CreateBook(in *CreateBookPayload, opts ...asynq.Option) (*asynq.Task, error)

+ func (j *BookSvcTask) UpdateBook(in *UpdateBookPayload, opts ...asynq.Option) (*asynq.Task, error)

type BookTaskClient

+ CreateBook func(ctx context.Context, req *CreateBookPayload, opts ...asynq.Option) (info *asynq.TaskInfo, err error)

+ UpdateBook func(ctx context.Context, req *UpdateBookPayload, opts ...asynq.Option) (info *asynq.TaskInfo, err error)

type BookTaskClientImpl

+ func (c *BookTaskClientImpl) CreateBook(ctx context.Context, in *CreateBookPayload, opts ...asynq.Option) (*asynq.TaskInfo, error)

+ func (c *BookTaskClientImpl) UpdateBook(ctx context.Context, in *UpdateBookPayload, opts ...asynq.Option) (*asynq.TaskInfo, error)

type BookTaskServer

+ CreateBook func(context.Context, *CreateBookPayload) error

+ UpdateBook func(context.Context, *UpdateBookPayload) error

Mar 14, 2022

Changes in this version

+ const BookQueueName

+ const UserQueueName

+ func RegisterBookTaskServer(s *asynqx.Server, srv BookTaskServer)

+ type BookSvcTask struct

+ var BookTask BookSvcTask

+ func (j *BookSvcTask) CreateUser(in *CreateBookPayload, opts ...asynq.Option) (*asynq.Task, error)

+ func (j *BookSvcTask) UpdateUser(in *UpdateBookPayload, opts ...asynq.Option) (*asynq.Task, error)

+ type BookTaskClient interface

+ CreateUser func(ctx context.Context, req *CreateBookPayload, opts ...asynq.Option) (info *asynq.TaskInfo, err error)

+ UpdateUser func(ctx context.Context, req *UpdateBookPayload, opts ...asynq.Option) (info *asynq.TaskInfo, err error)

+ func NewBookTaskClient(client *asynq.Client) BookTaskClient

+ type BookTaskClientImpl struct

+ func (c *BookTaskClientImpl) CreateUser(ctx context.Context, in *CreateBookPayload, opts ...asynq.Option) (*asynq.TaskInfo, error)

+ func (c *BookTaskClientImpl) UpdateUser(ctx context.Context, in *UpdateBookPayload, opts ...asynq.Option) (*asynq.TaskInfo, error)

+ type BookTaskServer interface

+ CreateUser func(context.Context, *CreateBookPayload) error

+ UpdateUser func(context.Context, *UpdateBookPayload) error

+ type CreateBookPayload struct

+ Name string

+ func (*CreateBookPayload) Descriptor() ([]byte, []int)

+ func (*CreateBookPayload) ProtoMessage()

+ func (x *CreateBookPayload) GetName() string

+ func (x *CreateBookPayload) ProtoReflect() protoreflect.Message

+ func (x *CreateBookPayload) Reset()

+ func (x *CreateBookPayload) String() string

+ type UpdateBookPayload struct

+ Name string

+ func (*UpdateBookPayload) Descriptor() ([]byte, []int)

+ func (*UpdateBookPayload) ProtoMessage()

+ func (x *UpdateBookPayload) GetName() string

+ func (x *UpdateBookPayload) ProtoReflect() protoreflect.Message

+ func (x *UpdateBookPayload) Reset()

+ func (x *UpdateBookPayload) String() string

Mar 11, 2022

Changes in this version

+ const QueueName

Mar 10, 2022

Changes in this version

+ var File_example_example_proto protoreflect.FileDescriptor

+ func IsRateLimitError(err error) bool

+ func RegisterUserTaskServer(s *asynqx.Server, srv UserTaskServer)

+ func TestServer(t *testing.T)

+ type CreateUserPayload struct

+ Name string

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

+ func (*CreateUserPayload) ProtoMessage()

+ func (x *CreateUserPayload) GetName() string

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

+ func (x *CreateUserPayload) Reset()

+ func (x *CreateUserPayload) String() string

+ type RateLimitError struct

+ RetryIn time.Duration

+ func (e *RateLimitError) Error() string

+ type UpdateUserPayload struct

+ Name string

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

+ func (*UpdateUserPayload) ProtoMessage()

+ func (x *UpdateUserPayload) GetName() string

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

+ func (x *UpdateUserPayload) Reset()

+ func (x *UpdateUserPayload) String() string

+ type UserSvcTask struct

+ var UserTask UserSvcTask

+ func (j *UserSvcTask) CreateUser(in *CreateUserPayload, opts ...asynq.Option) (*asynq.Task, error)

+ func (j *UserSvcTask) UpdateUser(in *UpdateUserPayload, opts ...asynq.Option) (*asynq.Task, error)

+ type UserTaskClient interface

+ CreateUser func(ctx context.Context, req *CreateUserPayload, opts ...asynq.Option) (info *asynq.TaskInfo, err error)

+ UpdateUser func(ctx context.Context, req *UpdateUserPayload, opts ...asynq.Option) (info *asynq.TaskInfo, err error)

+ func NewUserTaskClient(client *asynq.Client) UserTaskClient

+ type UserTaskClientImpl struct

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

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

+ type UserTaskServer interface

+ CreateUser func(context.Context, *CreateUserPayload) error

+ UpdateUser func(context.Context, *UpdateUserPayload) error