cloudtasks

package

v1.151.0 Latest Latest Go to latest Published: May 12, 2026 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation ¶

Index ¶

func AppEngineRouting_FromProto(mapCtx *direct.MapContext, in *pb.AppEngineRouting) *krm.AppEngineRouting
func AppEngineRouting_ToProto(mapCtx *direct.MapContext, in *krm.AppEngineRouting) *pb.AppEngineRouting
func NewQueueModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)
func RateLimits_FromProto(mapCtx *direct.MapContext, in *pb.RateLimits) *krm.RateLimits
func RateLimits_ToProto(mapCtx *direct.MapContext, in *krm.RateLimits) *pb.RateLimits
func RetryConfig_FromProto(mapCtx *direct.MapContext, in *pb.RetryConfig) *krm.RetryConfig
func RetryConfig_ToProto(mapCtx *direct.MapContext, in *krm.RetryConfig) *pb.RetryConfig
func StackdriverLoggingConfig_FromProto(mapCtx *direct.MapContext, in *pb.StackdriverLoggingConfig) *krm.StackdriverLoggingConfig
func StackdriverLoggingConfig_ToProto(mapCtx *direct.MapContext, in *krm.StackdriverLoggingConfig) *pb.StackdriverLoggingConfig
func TasksQueueObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Queue) *krm.TasksQueueObservedState
func TasksQueueObservedState_ToProto(mapCtx *direct.MapContext, in *krm.TasksQueueObservedState) *pb.Queue
func TasksQueueSpec_FromProto(mapCtx *direct.MapContext, in *pb.Queue) *krm.TasksQueueSpec
func TasksQueueSpec_ToProto(mapCtx *direct.MapContext, in *krm.TasksQueueSpec) *pb.Queue
type QueueAdapter

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AppEngineRouting_FromProto ¶

func AppEngineRouting_FromProto(mapCtx *direct.MapContext, in *pb.AppEngineRouting) *krm.AppEngineRouting

func AppEngineRouting_ToProto ¶

func AppEngineRouting_ToProto(mapCtx *direct.MapContext, in *krm.AppEngineRouting) *pb.AppEngineRouting

func NewQueueModel ¶

func NewQueueModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)

func RateLimits_FromProto ¶

func RateLimits_FromProto(mapCtx *direct.MapContext, in *pb.RateLimits) *krm.RateLimits

func RateLimits_ToProto ¶

func RateLimits_ToProto(mapCtx *direct.MapContext, in *krm.RateLimits) *pb.RateLimits

func RetryConfig_FromProto ¶

func RetryConfig_FromProto(mapCtx *direct.MapContext, in *pb.RetryConfig) *krm.RetryConfig

func RetryConfig_ToProto ¶

func RetryConfig_ToProto(mapCtx *direct.MapContext, in *krm.RetryConfig) *pb.RetryConfig

func StackdriverLoggingConfig_FromProto ¶

func StackdriverLoggingConfig_FromProto(mapCtx *direct.MapContext, in *pb.StackdriverLoggingConfig) *krm.StackdriverLoggingConfig

func StackdriverLoggingConfig_ToProto ¶

func StackdriverLoggingConfig_ToProto(mapCtx *direct.MapContext, in *krm.StackdriverLoggingConfig) *pb.StackdriverLoggingConfig

func TasksQueueObservedState_FromProto ¶

func TasksQueueObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Queue) *krm.TasksQueueObservedState

func TasksQueueObservedState_ToProto ¶

func TasksQueueObservedState_ToProto(mapCtx *direct.MapContext, in *krm.TasksQueueObservedState) *pb.Queue

func TasksQueueSpec_FromProto ¶

func TasksQueueSpec_FromProto(mapCtx *direct.MapContext, in *pb.Queue) *krm.TasksQueueSpec

func TasksQueueSpec_ToProto ¶

func TasksQueueSpec_ToProto(mapCtx *direct.MapContext, in *krm.TasksQueueSpec) *pb.Queue

Types ¶

type QueueAdapter ¶

type QueueAdapter struct {
	// contains filtered or unexported fields
}

func (*QueueAdapter) Create ¶

func (a *QueueAdapter) Create(ctx context.Context, createOp *directbase.CreateOperation) error

Create creates the resource in GCP based on `spec` and update the Config Connector object `status` based on the GCP response.

func (*QueueAdapter) Delete ¶

func (a *QueueAdapter) Delete(ctx context.Context, deleteOp *directbase.DeleteOperation) (bool, error)

Delete the resource from GCP service when the corresponding Config Connector resource is deleted.

func (*QueueAdapter) Export ¶

func (a *QueueAdapter) Export(ctx context.Context) (*unstructured.Unstructured, error)

Export maps the GCP object to a Config Connector resource `spec`.

func (*QueueAdapter) Find ¶

func (a *QueueAdapter) Find(ctx context.Context) (bool, error)

Find retrieves the GCP resource. Return true means the object is found. This triggers Adapter `Update` call. Return false means the object is not found. This triggers Adapter `Create` call. Return a non-nil error requeues the requests.

func (*QueueAdapter) Update ¶

func (a *QueueAdapter) Update(ctx context.Context, updateOp *directbase.UpdateOperation) error

Update updates the resource in GCP based on `spec` and update the Config Connector object `status` based on the GCP response.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL