tasks

Documentation

Overview

Package tasks contains task queue tasks definitions.

Index

• type CleanupUpload
  • func (*CleanupUpload) Descriptor() ([]byte, []int)
  • func (m *CleanupUpload) GetPathToCleanup() string
  • func (m *CleanupUpload) GetUploadOperationId() int64
  • func (m *CleanupUpload) GetUploadUrl() string
  • func (*CleanupUpload) ProtoMessage()
  • func (m *CleanupUpload) Reset()
  • func (m *CleanupUpload) String() string
  • func (m *CleanupUpload) XXX_DiscardUnknown()
  • func (m *CleanupUpload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *CleanupUpload) XXX_Merge(src proto.Message)
  • func (m *CleanupUpload) XXX_Size() int
  • func (m *CleanupUpload) XXX_Unmarshal(b []byte) error
• type VerifyUpload
  • func (*VerifyUpload) Descriptor() ([]byte, []int)
  • func (m *VerifyUpload) GetUploadOperationId() int64
  • func (*VerifyUpload) ProtoMessage()
  • func (m *VerifyUpload) Reset()
  • func (m *VerifyUpload) String() string
  • func (m *VerifyUpload) XXX_DiscardUnknown()
  • func (m *VerifyUpload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *VerifyUpload) XXX_Merge(src proto.Message)
  • func (m *VerifyUpload) XXX_Size() int
  • func (m *VerifyUpload) XXX_Unmarshal(b []byte) error

Types

type CleanupUpload

type CleanupUpload struct {
	UploadOperationId    int64    `protobuf:"varint,1,opt,name=upload_operation_id,json=uploadOperationId,proto3" json:"upload_operation_id,omitempty"`
	UploadUrl            string   `protobuf:"bytes,2,opt,name=upload_url,json=uploadUrl,proto3" json:"upload_url,omitempty"`
	PathToCleanup        string   `protobuf:"bytes,3,opt,name=path_to_cleanup,json=pathToCleanup,proto3" json:"path_to_cleanup,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CleanupUpload task cleans up garbage after canceled upload.

func (*CleanupUpload) Descriptor

func (*CleanupUpload) Descriptor() ([]byte, []int)

func (*CleanupUpload) GetPathToCleanup

func (m *CleanupUpload) GetPathToCleanup() string

func (*CleanupUpload) GetUploadOperationId

func (m *CleanupUpload) GetUploadOperationId() int64

func (*CleanupUpload) GetUploadUrl

func (m *CleanupUpload) GetUploadUrl() string

func (*CleanupUpload) ProtoMessage

func (*CleanupUpload) ProtoMessage()

func (*CleanupUpload) Reset

func (m *CleanupUpload) Reset()

func (*CleanupUpload) String

func (m *CleanupUpload) String() string

func (*CleanupUpload) XXX_DiscardUnknown

func (m *CleanupUpload) XXX_DiscardUnknown()

func (*CleanupUpload) XXX_Marshal

func (m *CleanupUpload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CleanupUpload) XXX_Merge

func (m *CleanupUpload) XXX_Merge(src proto.Message)

func (*CleanupUpload) XXX_Size

func (m *CleanupUpload) XXX_Size() int

func (*CleanupUpload) XXX_Unmarshal

func (m *CleanupUpload) XXX_Unmarshal(b []byte) error

type VerifyUpload

type VerifyUpload struct {
	UploadOperationId    int64    `protobuf:"varint,1,opt,name=upload_operation_id,json=uploadOperationId,proto3" json:"upload_operation_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

VerifyUpload task verifies data uploaded by a user and closes the upload session based on the result.

func (*VerifyUpload) Descriptor

func (*VerifyUpload) Descriptor() ([]byte, []int)

func (*VerifyUpload) GetUploadOperationId

func (m *VerifyUpload) GetUploadOperationId() int64

func (*VerifyUpload) ProtoMessage

func (*VerifyUpload) ProtoMessage()

func (*VerifyUpload) Reset

func (m *VerifyUpload) Reset()

func (*VerifyUpload) String

func (m *VerifyUpload) String() string

func (*VerifyUpload) XXX_DiscardUnknown

func (m *VerifyUpload) XXX_DiscardUnknown()

func (*VerifyUpload) XXX_Marshal

func (m *VerifyUpload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VerifyUpload) XXX_Merge

func (m *VerifyUpload) XXX_Merge(src proto.Message)

func (*VerifyUpload) XXX_Size

func (m *VerifyUpload) XXX_Size() int

func (*VerifyUpload) XXX_Unmarshal

func (m *VerifyUpload) XXX_Unmarshal(b []byte) error