masstasker

type BulkSetRequest struct {

	// select which tasks we want to "update"
	Ref []*TaskRef `protobuf:"bytes,1,rep,name=ref,proto3" json:"ref,omitempty"`
	// and copy non-zero fields in the prototype into each matching object
	Prototype *Task `protobuf:"bytes,2,opt,name=prototype,proto3" json:"prototype,omitempty"`
	// contains filtered or unexported fields
}

type BulkSetResponse struct {
	NumUpdated uint64 `protobuf:"varint,1,opt,name=num_updated,json=numUpdated,proto3" json:"num_updated,omitempty"`
	// contains filtered or unexported fields
}

type DebugRequest struct {
	Group string `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	Limit uint64 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

type DebugResponse struct {
	Tasks    []*Task `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	NumTasks uint64  `protobuf:"varint,2,opt,name=num_tasks,json=numTasks,proto3" json:"num_tasks,omitempty"`
	// contains filtered or unexported fields
}

type LabelSelector struct {
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

type MassTaskerClient interface {
	Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error)
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
	BulkSet(ctx context.Context, in *BulkSetRequest, opts ...grpc.CallOption) (*BulkSetResponse, error)
	Debug(ctx context.Context, in *DebugRequest, opts ...grpc.CallOption) (*DebugResponse, error)
}

type MassTaskerServer interface {
	Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
	Query(context.Context, *QueryRequest) (*QueryResponse, error)
	BulkSet(context.Context, *BulkSetRequest) (*BulkSetResponse, error)
	Debug(context.Context, *DebugRequest) (*DebugResponse, error)
	// contains filtered or unexported methods
}

type QueryRequest struct {
	Group  string                 `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	Now    *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=now,proto3" json:"now,omitempty"`
	OwnFor *durationpb.Duration   `protobuf:"bytes,3,opt,name=own_for,json=ownFor,proto3" json:"own_for,omitempty"`
	Wait   bool                   `protobuf:"varint,5,opt,name=wait,proto3" json:"wait,omitempty"`
	// contains filtered or unexported fields
}

type QueryResponse struct {
	Task *Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

type Task struct {
	Id        uint64                 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Group     string                 `protobuf:"bytes,2,opt,name=group,proto3" json:"group,omitempty"`
	Data      *anypb.Any             `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Labels    map[string]string      `` /* 153-byte string literal not displayed */
	NotBefore *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=not_before,json=notBefore,proto3" json:"not_before,omitempty"`
	// optional error annotation, useful when moving tasks to an error queue.
	// If you need a more structured error please encode it in the payload.
	Error string `protobuf:"bytes,6,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type TaskRef struct {

	// Types that are assignable to Sel:
	//
	//	*TaskRef_Id
	//	*TaskRef_Selector
	//	*TaskRef_Group
	Sel isTaskRef_Sel `protobuf_oneof:"sel"`
	// contains filtered or unexported fields
}

type TaskRef_Group struct {
	Group string `protobuf:"bytes,3,opt,name=group,proto3,oneof"`
}

type TaskRef_Id struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3,oneof"`
}

type TaskRef_Selector struct {
	Selector *LabelSelector `protobuf:"bytes,2,opt,name=selector,proto3,oneof"`
}

type Test struct {
	Foo string `protobuf:"bytes,1,opt,name=foo,proto3" json:"foo,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedMassTaskerServer struct {
}

type UnsafeMassTaskerServer interface {
	// contains filtered or unexported methods
}

type UpdateRequest struct {
	Created    []*Task    `protobuf:"bytes,1,rep,name=created,proto3" json:"created,omitempty"`
	Deleted    []*TaskRef `protobuf:"bytes,2,rep,name=deleted,proto3" json:"deleted,omitempty"`
	Predicates []uint64   `protobuf:"varint,3,rep,packed,name=predicates,proto3" json:"predicates,omitempty"`
	// contains filtered or unexported fields
}

type UpdateResponse struct {
	CreatedIds []uint64 `protobuf:"varint,1,rep,packed,name=created_ids,json=createdIds,proto3" json:"created_ids,omitempty"`
	// contains filtered or unexported fields
}