queue

Documentation

Index

• Variables
• func RegisterQueueServer(s *grpc.Server, srv QueueServer)
• type QueueClient
  • func NewQueueClient(cc grpc.ClientConnInterface) QueueClient
• type QueueServer
• type Submission
  • func (*Submission) Descriptor() ([]byte, []int)
  • func (x *Submission) GetAll() bool
  • func (x *Submission) GetBasesha() string
  • func (x *Submission) GetFork() string
  • func (x *Submission) GetHeadsha() string
  • func (x *Submission) GetManual() bool
  • func (x *Submission) GetParent() string
  • func (x *Submission) GetSubmittedBy() string
  • func (x *Submission) GetTicketID() int64
  • func (*Submission) ProtoMessage()
  • func (x *Submission) ProtoReflect() protoreflect.Message
  • func (x *Submission) Reset()
  • func (x *Submission) String() string
• type UnimplementedQueueServer
  • func (*UnimplementedQueueServer) GetCancel(context.Context, *types.IntID) (*types.Status, error)
  • func (*UnimplementedQueueServer) NextQueueItem(context.Context, *types.QueueRequest) (*types.QueueItem, error)
  • func (*UnimplementedQueueServer) PutStatus(context.Context, *types.Status) (*emptypb.Empty, error)
  • func (*UnimplementedQueueServer) SetCancel(context.Context, *types.IntID) (*emptypb.Empty, error)
  • func (*UnimplementedQueueServer) Submit(context.Context, *Submission) (*emptypb.Empty, error)

Variables

var File_grpc_services_queue_server_proto protoreflect.FileDescriptor

Functions

func RegisterQueueServer

func RegisterQueueServer(s *grpc.Server, srv QueueServer)

Types

type QueueClient

type QueueClient interface {
	PutStatus(ctx context.Context, in *types.Status, opts ...grpc.CallOption) (*emptypb.Empty, error)
	NextQueueItem(ctx context.Context, in *types.QueueRequest, opts ...grpc.CallOption) (*types.QueueItem, error)
	Submit(ctx context.Context, in *Submission, opts ...grpc.CallOption) (*emptypb.Empty, error)
	SetCancel(ctx context.Context, in *types.IntID, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetCancel(ctx context.Context, in *types.IntID, opts ...grpc.CallOption) (*types.Status, error)
}

QueueClient is the client API for Queue service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQueueClient

func NewQueueClient(cc grpc.ClientConnInterface) QueueClient

type QueueServer

type QueueServer interface {
	PutStatus(context.Context, *types.Status) (*emptypb.Empty, error)
	NextQueueItem(context.Context, *types.QueueRequest) (*types.QueueItem, error)
	Submit(context.Context, *Submission) (*emptypb.Empty, error)
	SetCancel(context.Context, *types.IntID) (*emptypb.Empty, error)
	GetCancel(context.Context, *types.IntID) (*types.Status, error)
}

QueueServer is the server API for Queue service.

type Submission

type Submission struct {
	Parent      string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`                              // Parent repository
	Fork        string `protobuf:"bytes,2,opt,name=fork,proto3" json:"fork,omitempty"`                                  // Fork repository
	Headsha     string `protobuf:"bytes,3,opt,name=headsha,proto3" json:"headsha,omitempty"`                            // HEAD SHA -- usually the head of the fork
	Basesha     string `protobuf:"bytes,4,opt,name=basesha,proto3" json:"basesha,omitempty"`                            // Base SHA -- usually the head of the parent
	SubmittedBy string `protobuf:"bytes,5,opt,name=submitted_by,json=submittedBy,proto3" json:"submitted_by,omitempty"` // Who submitted this?
	TicketID    int64  `protobuf:"varint,6,opt,name=ticketID,proto3" json:"ticketID,omitempty"`                         // PullRequest ID if available -- not set during manual submissions
	All         bool   `protobuf:"varint,7,opt,name=all,proto3" json:"all,omitempty"`                                   // Test all instead of using diff selection; this is a flag in the UI and can also be triggered by tinycli. It is not used in github hooks except for pushes to master.
	Manual      bool   `protobuf:"varint,8,opt,name=manual,proto3" json:"manual,omitempty"`                             // Flag set if this was a manual submission. Typically managed by the uisvc.
	// contains filtered or unexported fields
}

Submission controls the submission of branches and pull requests. Some (noted) properties are not externally modifiable, so they will result in a noop if set.

func (*Submission) Descriptor

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

Deprecated: Use Submission.ProtoReflect.Descriptor instead.

func (*Submission) GetAll

func (x *Submission) GetAll() bool

func (*Submission) GetBasesha

func (x *Submission) GetBasesha() string

func (*Submission) GetFork

func (x *Submission) GetFork() string

func (*Submission) GetHeadsha

func (x *Submission) GetHeadsha() string

func (*Submission) GetManual

func (x *Submission) GetManual() bool

func (*Submission) GetParent

func (x *Submission) GetParent() string

func (*Submission) GetSubmittedBy

func (x *Submission) GetSubmittedBy() string

func (*Submission) GetTicketID

func (x *Submission) GetTicketID() int64

func (*Submission) ProtoMessage

func (*Submission) ProtoMessage()

func (*Submission) ProtoReflect

func (x *Submission) ProtoReflect() protoreflect.Message

func (*Submission) Reset

func (x *Submission) Reset()

func (*Submission) String

func (x *Submission) String() string

type UnimplementedQueueServer

type UnimplementedQueueServer struct {
}

UnimplementedQueueServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueueServer) GetCancel

func (*UnimplementedQueueServer) GetCancel(context.Context, *types.IntID) (*types.Status, error)

func (*UnimplementedQueueServer) NextQueueItem

func (*UnimplementedQueueServer) NextQueueItem(context.Context, *types.QueueRequest) (*types.QueueItem, error)

func (*UnimplementedQueueServer) PutStatus

func (*UnimplementedQueueServer) PutStatus(context.Context, *types.Status) (*emptypb.Empty, error)

func (*UnimplementedQueueServer) SetCancel

func (*UnimplementedQueueServer) SetCancel(context.Context, *types.IntID) (*emptypb.Empty, error)

func (*UnimplementedQueueServer) Submit

func (*UnimplementedQueueServer) Submit(context.Context, *Submission) (*emptypb.Empty, error)