Documentation
¶
Index ¶
- type Repository
- type TaskManager
- func (m TaskManager) AbortTask(c context.Context, ctl task.Controller) error
- func (m TaskManager) ExamineNotification(c context.Context, msg *pubsub.PubsubMessage) string
- func (m TaskManager) GetDebugState(c context.Context, ctl task.ControllerReadOnly) (*internal.DebugManagerState, error)
- func (m TaskManager) HandleNotification(c context.Context, ctl task.Controller, msg *pubsub.PubsubMessage) error
- func (m TaskManager) HandleTimer(c context.Context, ctl task.Controller, name string, payload []byte) error
- func (m TaskManager) LaunchTask(c context.Context, ctl task.Controller) error
- func (m TaskManager) Name() string
- func (m TaskManager) ProtoMessageType() proto.Message
- func (m TaskManager) Traits() task.Traits
- func (m TaskManager) ValidateProtoMessage(c *validation.Context, msg proto.Message, realmID string)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Repository ¶
type Repository struct {
// ID is uniquely derived from jobID and repository URL, see repositoryID().
ID string `gae:"$id"`
// CompressedState stores gzip-compressed proto-serialized list of watched
// refs with hashes of their tips.
CompressedState []byte `gae:",noindex"`
// contains filtered or unexported fields
}
Repository is used to store the repository status.
type TaskManager ¶
type TaskManager struct {
// contains filtered or unexported fields
}
TaskManager implements task.Manager interface for tasks defined with GitilesTask proto message.
func (TaskManager) AbortTask ¶
func (m TaskManager) AbortTask(c context.Context, ctl task.Controller) error
AbortTask is part of Manager interface.
func (TaskManager) ExamineNotification ¶
func (m TaskManager) ExamineNotification(c context.Context, msg *pubsub.PubsubMessage) string
ExamineNotification is part of Manager interface.
func (TaskManager) GetDebugState ¶
func (m TaskManager) GetDebugState(c context.Context, ctl task.ControllerReadOnly) (*internal.DebugManagerState, error)
GetDebugState is part of Manager interface.
func (TaskManager) HandleNotification ¶
func (m TaskManager) HandleNotification(c context.Context, ctl task.Controller, msg *pubsub.PubsubMessage) error
HandleNotification is part of Manager interface.
func (TaskManager) HandleTimer ¶
func (m TaskManager) HandleTimer(c context.Context, ctl task.Controller, name string, payload []byte) error
HandleTimer is part of Manager interface.
func (TaskManager) LaunchTask ¶
func (m TaskManager) LaunchTask(c context.Context, ctl task.Controller) error
LaunchTask is part of Manager interface.
func (TaskManager) ProtoMessageType ¶
func (m TaskManager) ProtoMessageType() proto.Message
ProtoMessageType is part of Manager interface.
func (TaskManager) Traits ¶
func (m TaskManager) Traits() task.Traits
Traits is part of Manager interface.
func (TaskManager) ValidateProtoMessage ¶
func (m TaskManager) ValidateProtoMessage(c *validation.Context, msg proto.Message, realmID string)
ValidateProtoMessage is part of Manager interface.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.