Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterBokchoyServer

func RegisterBokchoyServer(s *grpc.Server, srv BokchoyServer)

Types

type BokchoyClient

type BokchoyClient interface {
	PublishTask(ctx context.Context, in *PublishTaskRequest, opts ...grpc.CallOption) (*Task, error)
}

    BokchoyClient is the client API for Bokchoy service.

    For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

    func NewBokchoyClient

    func NewBokchoyClient(cc *grpc.ClientConn) BokchoyClient

    type BokchoyServer

    type BokchoyServer interface {
    	PublishTask(context.Context, *PublishTaskRequest) (*Task, error)
    }

      BokchoyServer is the server API for Bokchoy service.

      type PublishTaskRequest

      type PublishTaskRequest struct {
      	Queue                string               `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
      	Payload              *wrappers.BytesValue `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
      	Countdown            *time.Duration       `protobuf:"bytes,3,opt,name=countdown,proto3,stdduration" json:"countdown,omitempty"`
      	Timeout              *time.Duration       `protobuf:"bytes,4,opt,name=timeout,proto3,stdduration" json:"timeout,omitempty"`
      	TTL                  *time.Duration       `protobuf:"bytes,5,opt,name=ttl,proto3,stdduration" json:"ttl,omitempty"`
      	MaxRetries           *wrappers.Int64Value `protobuf:"bytes,6,opt,name=max_retries,json=maxRetries,proto3" json:"max_retries,omitempty"`
      	RetryIntervals       []*time.Duration     `protobuf:"bytes,7,rep,name=retry_intervals,json=retryIntervals,proto3,stdduration" json:"retry_intervals,omitempty"`
      	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
      	XXX_unrecognized     []byte               `json:"-"`
      	XXX_sizecache        int32                `json:"-"`
      }

      func (*PublishTaskRequest) Descriptor

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

      func (*PublishTaskRequest) GetCountdown

      func (m *PublishTaskRequest) GetCountdown() *time.Duration

      func (*PublishTaskRequest) GetMaxRetries

      func (m *PublishTaskRequest) GetMaxRetries() *wrappers.Int64Value

      func (*PublishTaskRequest) GetPayload

      func (m *PublishTaskRequest) GetPayload() *wrappers.BytesValue

      func (*PublishTaskRequest) GetQueue

      func (m *PublishTaskRequest) GetQueue() string

      func (*PublishTaskRequest) GetRetryIntervals

      func (m *PublishTaskRequest) GetRetryIntervals() []*time.Duration

      func (*PublishTaskRequest) GetTTL

      func (m *PublishTaskRequest) GetTTL() *time.Duration

      func (*PublishTaskRequest) GetTimeout

      func (m *PublishTaskRequest) GetTimeout() *time.Duration

      func (*PublishTaskRequest) ProtoMessage

      func (*PublishTaskRequest) ProtoMessage()

      func (*PublishTaskRequest) Reset

      func (m *PublishTaskRequest) Reset()

      func (*PublishTaskRequest) String

      func (m *PublishTaskRequest) String() string

      func (*PublishTaskRequest) XXX_DiscardUnknown

      func (m *PublishTaskRequest) XXX_DiscardUnknown()

      func (*PublishTaskRequest) XXX_Marshal

      func (m *PublishTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

      func (*PublishTaskRequest) XXX_Merge

      func (m *PublishTaskRequest) XXX_Merge(src proto.Message)

      func (*PublishTaskRequest) XXX_Size

      func (m *PublishTaskRequest) XXX_Size() int

      func (*PublishTaskRequest) XXX_Unmarshal

      func (m *PublishTaskRequest) XXX_Unmarshal(b []byte) error

      type Task

      type Task struct {
      	ID                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
      	Name                 string               `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
      	Payload              *wrappers.BytesValue `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
      	Status               int64                `protobuf:"varint,4,opt,name=status,proto3" json:"status,omitempty"`
      	MaxRetries           int64                `protobuf:"varint,5,opt,name=max_retries,json=maxRetries,proto3" json:"max_retries,omitempty"`
      	Timeout              *time.Duration       `protobuf:"bytes,6,opt,name=timeout,proto3,stdduration" json:"timeout,omitempty"`
      	TTL                  *time.Duration       `protobuf:"bytes,7,opt,name=ttl,proto3,stdduration" json:"ttl,omitempty"`
      	RetryIntervals       []*time.Duration     `protobuf:"bytes,8,rep,name=retry_intervals,json=retryIntervals,proto3,stdduration" json:"retry_intervals,omitempty"`
      	PublishedAt          *time.Time           `protobuf:"bytes,9,opt,name=published_at,json=publishedAt,proto3,stdtime" json:"published_at,omitempty"`
      	StartedAt            *time.Time           `protobuf:"bytes,10,opt,name=started_at,json=startedAt,proto3,stdtime" json:"started_at,omitempty"`
      	ProcessedAt          *time.Time           `protobuf:"bytes,11,opt,name=processed_at,json=processedAt,proto3,stdtime" json:"processed_at,omitempty"`
      	ETA                  *time.Time           `protobuf:"bytes,12,opt,name=eta,proto3,stdtime" json:"eta,omitempty"`
      	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
      	XXX_unrecognized     []byte               `json:"-"`
      	XXX_sizecache        int32                `json:"-"`
      }

      func (*Task) Descriptor

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

      func (*Task) GetETA

      func (m *Task) GetETA() *time.Time

      func (*Task) GetID

      func (m *Task) GetID() string

      func (*Task) GetMaxRetries

      func (m *Task) GetMaxRetries() int64

      func (*Task) GetName

      func (m *Task) GetName() string

      func (*Task) GetPayload

      func (m *Task) GetPayload() *wrappers.BytesValue

      func (*Task) GetProcessedAt

      func (m *Task) GetProcessedAt() *time.Time

      func (*Task) GetPublishedAt

      func (m *Task) GetPublishedAt() *time.Time

      func (*Task) GetRetryIntervals

      func (m *Task) GetRetryIntervals() []*time.Duration

      func (*Task) GetStartedAt

      func (m *Task) GetStartedAt() *time.Time

      func (*Task) GetStatus

      func (m *Task) GetStatus() int64

      func (*Task) GetTTL

      func (m *Task) GetTTL() *time.Duration

      func (*Task) GetTimeout

      func (m *Task) GetTimeout() *time.Duration

      func (*Task) ProtoMessage

      func (*Task) ProtoMessage()

      func (*Task) Reset

      func (m *Task) Reset()

      func (*Task) String

      func (m *Task) String() string

      func (*Task) XXX_DiscardUnknown

      func (m *Task) XXX_DiscardUnknown()

      func (*Task) XXX_Marshal

      func (m *Task) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

      func (*Task) XXX_Merge

      func (m *Task) XXX_Merge(src proto.Message)

      func (*Task) XXX_Size

      func (m *Task) XXX_Size() int

      func (*Task) XXX_Unmarshal

      func (m *Task) XXX_Unmarshal(b []byte) error

      Source Files