proto

Documentation

Index

• func RegisterBokchoyServer(s *grpc.Server, srv BokchoyServer)
• type BokchoyClient
  • func NewBokchoyClient(cc *grpc.ClientConn) 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

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