commitqueue

package

v0.0.0-...-366f0b0 Latest Latest Go to latest Published: Jul 2, 2019 License: Apache-2.0 Imports: 18 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/chasinglogic/evergreen

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 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) FindItem(issue string) int
- func (q *CommitQueue) MarshalBSON() ([]byte, error)
- func (q *CommitQueue) Next() *CommitQueueItem
- func (q *CommitQueue) Remove(issue string) (bool, error)
- func (q *CommitQueue) SetProcessing(status bool) error
- func (q *CommitQueue) UnmarshalBSON(in []byte) 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")
	IssueKey      = bsonutil.MustHaveTag(CommitQueueItem{}, "Issue")
)

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 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"`
	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) 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

func (*CommitQueue) Remove ¶

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

func (*CommitQueue) SetProcessing ¶

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

func (*CommitQueue) UnmarshalBSON ¶

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

type CommitQueueItem ¶

type CommitQueueItem struct {
	Issue   string   `bson:"issue"`
	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