gitiles

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)

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) Name

func (m TaskManager) Name() string

Name 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.