commitqueue

package

v0.0.0-...-a9abf63 Latest Latest Go to latest Published: Jul 17, 2020 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/colindbrown/evergreen

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func ClearAllCommitQueues() (int, error)
func InsertQueue(q *CommitQueue) error
func NewCommitQueueDequeueLogger(name string, l send.LevelInfo) (send.Sender, error)
func NewDequeueItemMessage(p level.Priority, dequeueMsg DequeueItem) message.Composer
func NewGithubMergePRMessage(p level.Priority, mergeMsg GithubMergePR) message.Composer
func NewGithubPRLogger(ctx context.Context, name string, token string, statusSender send.Sender) (send.Sender, error)
func NewMockGithubPRLogger(name string, errLogger *mockErrorLogger) (send.Sender, error)
func RemoveCommitQueueItemForVersion(projectId, patchType, version string, user string) (bool, error)
func SetupEnv(env evergreen.Environment) error
func TriggersCommitQueue(commentAction string, comment string) bool
type CommitQueue
- func FindOneId(id string) (*CommitQueue, error)
- func (q *CommitQueue) Enqueue(item CommitQueueItem) (int, error)
- func (q *CommitQueue) EnqueueAtFront(item CommitQueueItem) (int, error)
- func (q *CommitQueue) FindItem(issue string) int
- func (q *CommitQueue) MarshalBSON() ([]byte, error)
- func (q *CommitQueue) Next() (CommitQueueItem, bool)
- func (q *CommitQueue) Remove(issue string) (bool, error)
- func (cq *CommitQueue) RemoveItemAndPreventMerge(issue, patchType string, versionExists bool, user string) (bool, error)
- func (q *CommitQueue) SetProcessing(status bool) error
- func (q *CommitQueue) UnmarshalBSON(in []byte) error
- func (q *CommitQueue) UpdateVersion(item CommitQueueItem) error
type CommitQueueItem
- func (i *CommitQueueItem) MarshalBSON() ([]byte, error)
- func (i *CommitQueueItem) UnmarshalBSON(in []byte) error
type DequeueItem
type GithubMergePR
- func (m *GithubMergePR) MarshalBSON() ([]byte, error)
- func (m *GithubMergePR) UnmarshalBSON(in []byte) error
- func (p *GithubMergePR) Valid() error
type Module
- func (m *Module) MarshalBSON() ([]byte, error)
- func (m *Module) UnmarshalBSON(in []byte) error

Constants ¶

View Source

const (
	PRPatchType  = "PR"
	CLIPatchType = "CLI"
)

View Source

const Collection = "commit_queue"

View Source

const Context = "evergreen/commitqueue"

Variables ¶

View Source

var (
	// bson fields for the CommitQueue struct
	IdKey                    = bsonutil.MustHaveTag(CommitQueue{}, "ProjectID")
	QueueKey                 = bsonutil.MustHaveTag(CommitQueue{}, "Queue")
	ProcessingKey            = bsonutil.MustHaveTag(CommitQueue{}, "Processing")
	ProcessingUpdatedTimeKey = bsonutil.MustHaveTag(CommitQueue{}, "ProcessingUpdatedTime")
	IssueKey                 = bsonutil.MustHaveTag(CommitQueueItem{}, "Issue")
	VersionKey               = bsonutil.MustHaveTag(CommitQueueItem{}, "Version")
	EnqueueTimeKey           = bsonutil.MustHaveTag(CommitQueueItem{}, "EnqueueTime")
)

Functions ¶

func ClearAllCommitQueues ¶

func ClearAllCommitQueues() (int, error)

func InsertQueue ¶

func InsertQueue(q *CommitQueue) error

func NewCommitQueueDequeueLogger ¶

func NewCommitQueueDequeueLogger(name string, l send.LevelInfo) (send.Sender, error)

NewCommitQueueDequeueLogger constructs a Sender that dequeues an item from a commit queue

func NewDequeueItemMessage ¶

func NewDequeueItemMessage(p level.Priority, dequeueMsg DequeueItem) message.Composer

NewDequeueItemMessage returns a composer for DequeueItem messages

func NewGithubMergePRMessage ¶

func NewGithubMergePRMessage(p level.Priority, mergeMsg GithubMergePR) message.Composer

NewGithubMergePRMessage returns a composer for GithubMergePR messages

func NewGithubPRLogger ¶

func NewGithubPRLogger(ctx context.Context, name string, token string, statusSender send.Sender) (send.Sender, error)

NewGithubPRLogger creates a new Sender implementation that merges a pull request Specify an OAuth token for GitHub authentication

func NewMockGithubPRLogger ¶

func NewMockGithubPRLogger(name string, errLogger *mockErrorLogger) (send.Sender, error)

Mock implementation

func RemoveCommitQueueItemForVersion ¶

func RemoveCommitQueueItemForVersion(projectId, patchType, version string, user string) (bool, error)

func SetupEnv ¶

func SetupEnv(env evergreen.Environment) error

func TriggersCommitQueue ¶

func TriggersCommitQueue(commentAction string, comment string) bool

Types ¶

type CommitQueue ¶

type CommitQueue struct {
	ProjectID             string            `bson:"_id"`
	Processing            bool              `bson:"processing"`
	ProcessingUpdatedTime time.Time         `bson:"processing_updated_time"`
	Queue                 []CommitQueueItem `bson:"queue,omitempty"`
}

func FindOneId ¶

func FindOneId(id string) (*CommitQueue, error)

func (*CommitQueue) Enqueue ¶

func (q *CommitQueue) Enqueue(item CommitQueueItem) (int, error)

func (*CommitQueue) EnqueueAtFront ¶

func (q *CommitQueue) EnqueueAtFront(item CommitQueueItem) (int, error)

func (*CommitQueue) FindItem ¶

func (q *CommitQueue) FindItem(issue string) int

func (*CommitQueue) MarshalBSON ¶

func (q *CommitQueue) MarshalBSON() ([]byte, error)

func (*CommitQueue) Next ¶

func (q *CommitQueue) Next() (CommitQueueItem, bool)

func (*CommitQueue) Remove ¶

func (q *CommitQueue) Remove(issue string) (bool, error)

func (*CommitQueue) RemoveItemAndPreventMerge ¶

func (cq *CommitQueue) RemoveItemAndPreventMerge(issue, patchType string, versionExists bool, user string) (bool, error)

func (*CommitQueue) SetProcessing ¶

func (q *CommitQueue) SetProcessing(status bool) error

func (*CommitQueue) UnmarshalBSON ¶

func (q *CommitQueue) UnmarshalBSON(in []byte) error

func (*CommitQueue) UpdateVersion ¶

func (q *CommitQueue) UpdateVersion(item CommitQueueItem) error

type CommitQueueItem ¶

type CommitQueueItem struct {
	Issue       string    `bson:"issue"`
	Version     string    `bson:"version,omitempty"`
	EnqueueTime time.Time `bson:"enqueue_time"`
	Modules     []Module  `bson:"modules"`
}

func (*CommitQueueItem) MarshalBSON ¶

func (i *CommitQueueItem) MarshalBSON() ([]byte, error)

func (*CommitQueueItem) UnmarshalBSON ¶

func (i *CommitQueueItem) UnmarshalBSON(in []byte) error

type DequeueItem ¶

type DequeueItem struct {
	ProjectID string
	Item      string
	Status    string
}

type GithubMergePR ¶

type GithubMergePR struct {
	Status      string         `bson:"status"`
	PatchID     string         `bson:"patch_id"`
	URL         string         `bson:"url"`
	ProjectID   string         `bson:"project_id"`
	MergeMethod string         `bson:"merge_method"`
	Item        string         `bson:"item"`
	PRs         []event.PRInfo `bson:"prs"`
}

func (*GithubMergePR) MarshalBSON ¶

func (m *GithubMergePR) MarshalBSON() ([]byte, error)

func (*GithubMergePR) UnmarshalBSON ¶

func (m *GithubMergePR) UnmarshalBSON(in []byte) error

func (*GithubMergePR) Valid ¶

func (p *GithubMergePR) Valid() error

Valid returns nil if the message is well formed

type Module ¶

type Module struct {
	Module string `bson:"module" json:"module"`
	Issue  string `bson:"issue" json:"issue"`
}

func (*Module) MarshalBSON ¶

func (m *Module) MarshalBSON() ([]byte, error)

func (*Module) UnmarshalBSON ¶

func (m *Module) UnmarshalBSON(in []byte) error

Source Files ¶

View all Source files

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