Versions in this module Expand all Collapse all v0 v0.2.1 Sep 21, 2020 v0.2.0 Dec 2, 2019 Changes in this version + func TaskToProto(task *bokchoy.Task) *proto.Task + type Client struct + func NewClient(addr string, options ClientOptions) *Client + func (c *Client) PublishTask(ctx context.Context, queueName string, payload []byte) (*proto.Task, error) + type ClientOptions struct + MaxRetries uint + PerRetryTimeout time.Duration + RetryCodes []codes.Code + type Handler struct + func (h Handler) PublishTask(ctx context.Context, req *proto.PublishTaskRequest) (*proto.Task, error) + type Server struct + func NewServer(bok *bokchoy.Bokchoy, port int) *Server + func (s *Server) Start(ctx context.Context) error + func (s *Server) Stop(ctx context.Context) + func (s *Server) String() string