Documentation ¶
Index ¶
- func RegisterBokchoyServer(s *grpc.Server, srv BokchoyServer)
- type BokchoyClient
- type BokchoyServer
- type PublishTaskRequest
- func (*PublishTaskRequest) Descriptor() ([]byte, []int)
- func (m *PublishTaskRequest) GetCountdown() *time.Duration
- func (m *PublishTaskRequest) GetMaxRetries() *wrappers.Int64Value
- func (m *PublishTaskRequest) GetPayload() *wrappers.BytesValue
- func (m *PublishTaskRequest) GetQueue() string
- func (m *PublishTaskRequest) GetRetryIntervals() []*time.Duration
- func (m *PublishTaskRequest) GetTTL() *time.Duration
- func (m *PublishTaskRequest) GetTimeout() *time.Duration
- func (*PublishTaskRequest) ProtoMessage()
- func (m *PublishTaskRequest) Reset()
- func (m *PublishTaskRequest) String() string
- func (m *PublishTaskRequest) XXX_DiscardUnknown()
- func (m *PublishTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PublishTaskRequest) XXX_Merge(src proto.Message)
- func (m *PublishTaskRequest) XXX_Size() int
- func (m *PublishTaskRequest) XXX_Unmarshal(b []byte) error
- type Task
- func (*Task) Descriptor() ([]byte, []int)
- func (m *Task) GetETA() *time.Time
- func (m *Task) GetID() string
- func (m *Task) GetMaxRetries() int64
- func (m *Task) GetName() string
- func (m *Task) GetPayload() *wrappers.BytesValue
- func (m *Task) GetProcessedAt() *time.Time
- func (m *Task) GetPublishedAt() *time.Time
- func (m *Task) GetRetryIntervals() []*time.Duration
- func (m *Task) GetStartedAt() *time.Time
- func (m *Task) GetStatus() int64
- func (m *Task) GetTTL() *time.Duration
- func (m *Task) GetTimeout() *time.Duration
- func (*Task) ProtoMessage()
- func (m *Task) Reset()
- func (m *Task) String() string
- func (m *Task) XXX_DiscardUnknown()
- func (m *Task) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Task) XXX_Merge(src proto.Message)
- func (m *Task) XXX_Size() int
- func (m *Task) XXX_Unmarshal(b []byte) error
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) GetMaxRetries ¶
func (*Task) GetPayload ¶
func (m *Task) GetPayload() *wrappers.BytesValue
func (*Task) GetProcessedAt ¶
func (*Task) GetPublishedAt ¶
func (*Task) GetRetryIntervals ¶
func (*Task) GetStartedAt ¶
func (*Task) GetTimeout ¶
func (*Task) ProtoMessage ¶
func (*Task) ProtoMessage()
func (*Task) XXX_DiscardUnknown ¶
func (m *Task) XXX_DiscardUnknown()
func (*Task) XXX_Unmarshal ¶
Click to show internal directories.
Click to hide internal directories.