protocol

type FinishRequest struct {
	Id            string                  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ResultHeaders map[string]*HeaderValue `` /* 188-byte string literal not displayed */
	Result        []byte                  `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

type GetRequest struct {
	QueueName string `protobuf:"bytes,1,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
	// contains filtered or unexported fields
}

type HeaderValue struct {
	Value []string `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type NackRequest struct {
	Id    string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type RenewRequest struct {
	Id         string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	LeaseUntil *timestamp.Timestamp `protobuf:"bytes,2,opt,name=lease_until,json=leaseUntil,proto3" json:"lease_until,omitempty"`
	// contains filtered or unexported fields
}

type TaskManagerClient interface {
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*Work, error)
	Renew(ctx context.Context, in *RenewRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	Finish(ctx context.Context, in *FinishRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	Nack(ctx context.Context, in *NackRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

type TaskManagerServer interface {
	Get(context.Context, *GetRequest) (*Work, error)
	Renew(context.Context, *RenewRequest) (*empty.Empty, error)
	Finish(context.Context, *FinishRequest) (*empty.Empty, error)
	Nack(context.Context, *NackRequest) (*empty.Empty, error)
}

type UnimplementedTaskManagerServer struct {
}

type Work struct {

	// Generated ID representing the Work. An opaque value.
	Id          string                  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Headers     map[string]*HeaderValue `` /* 155-byte string literal not displayed */
	Payload     []byte                  `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	EnqueuedAt  *timestamp.Timestamp    `protobuf:"bytes,4,opt,name=enqueued_at,json=enqueuedAt,proto3" json:"enqueued_at,omitempty"`
	LeasedUntil *timestamp.Timestamp    `protobuf:"bytes,5,opt,name=leased_until,json=leasedUntil,proto3" json:"leased_until,omitempty"`
	// contains filtered or unexported fields
}