Documentation
¶
Index ¶
- func RegisterQueueServer(s *grpc.Server, srv QueueServer)
- type QueueClient
- type QueueServer
- type Submission
- func (*Submission) Descriptor() ([]byte, []int)
- func (m *Submission) GetAll() bool
- func (m *Submission) GetBasesha() string
- func (m *Submission) GetFork() string
- func (m *Submission) GetHeadsha() string
- func (m *Submission) GetManual() bool
- func (m *Submission) GetParent() string
- func (m *Submission) GetSubmittedBy() string
- func (m *Submission) GetTicketID() int64
- func (*Submission) ProtoMessage()
- func (m *Submission) Reset()
- func (m *Submission) String() string
- func (m *Submission) XXX_DiscardUnknown()
- func (m *Submission) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Submission) XXX_Merge(src proto.Message)
- func (m *Submission) XXX_Size() int
- func (m *Submission) XXX_Unmarshal(b []byte) error
- type UnimplementedQueueServer
- func (*UnimplementedQueueServer) GetCancel(ctx context.Context, req *types.IntID) (*types.Status, error)
- func (*UnimplementedQueueServer) NextQueueItem(ctx context.Context, req *types.QueueRequest) (*types.QueueItem, error)
- func (*UnimplementedQueueServer) PutStatus(ctx context.Context, req *types.Status) (*empty.Empty, error)
- func (*UnimplementedQueueServer) SetCancel(ctx context.Context, req *types.IntID) (*empty.Empty, error)
- func (*UnimplementedQueueServer) Submit(ctx context.Context, req *Submission) (*empty.Empty, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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) (*empty.Empty, error)
NextQueueItem(ctx context.Context, in *types.QueueRequest, opts ...grpc.CallOption) (*types.QueueItem, error)
Submit(ctx context.Context, in *Submission, opts ...grpc.CallOption) (*empty.Empty, error)
SetCancel(ctx context.Context, in *types.IntID, opts ...grpc.CallOption) (*empty.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.ClientConn) QueueClient
type QueueServer ¶
type QueueServer interface {
PutStatus(context.Context, *types.Status) (*empty.Empty, error)
NextQueueItem(context.Context, *types.QueueRequest) (*types.QueueItem, error)
Submit(context.Context, *Submission) (*empty.Empty, error)
SetCancel(context.Context, *types.IntID) (*empty.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"`
Fork string `protobuf:"bytes,2,opt,name=fork,proto3" json:"fork,omitempty"`
Headsha string `protobuf:"bytes,3,opt,name=headsha,proto3" json:"headsha,omitempty"`
Basesha string `protobuf:"bytes,4,opt,name=basesha,proto3" json:"basesha,omitempty"`
SubmittedBy string `protobuf:"bytes,5,opt,name=submitted_by,json=submittedBy,proto3" json:"submitted_by,omitempty"`
TicketID int64 `protobuf:"varint,6,opt,name=ticketID,proto3" json:"ticketID,omitempty"`
All bool `protobuf:"varint,7,opt,name=all,proto3" json:"all,omitempty"`
Manual bool `protobuf:"varint,8,opt,name=manual,proto3" json:"manual,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
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)
func (*Submission) GetAll ¶
func (m *Submission) GetAll() bool
func (*Submission) GetBasesha ¶
func (m *Submission) GetBasesha() string
func (*Submission) GetFork ¶
func (m *Submission) GetFork() string
func (*Submission) GetHeadsha ¶
func (m *Submission) GetHeadsha() string
func (*Submission) GetManual ¶
func (m *Submission) GetManual() bool
func (*Submission) GetParent ¶
func (m *Submission) GetParent() string
func (*Submission) GetSubmittedBy ¶
func (m *Submission) GetSubmittedBy() string
func (*Submission) GetTicketID ¶
func (m *Submission) GetTicketID() int64
func (*Submission) ProtoMessage ¶
func (*Submission) ProtoMessage()
func (*Submission) Reset ¶
func (m *Submission) Reset()
func (*Submission) String ¶
func (m *Submission) String() string
func (*Submission) XXX_DiscardUnknown ¶
func (m *Submission) XXX_DiscardUnknown()
func (*Submission) XXX_Marshal ¶
func (m *Submission) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Submission) XXX_Merge ¶
func (m *Submission) XXX_Merge(src proto.Message)
func (*Submission) XXX_Size ¶
func (m *Submission) XXX_Size() int
func (*Submission) XXX_Unmarshal ¶
func (m *Submission) XXX_Unmarshal(b []byte) error
type UnimplementedQueueServer ¶
type UnimplementedQueueServer struct {
}
UnimplementedQueueServer can be embedded to have forward compatible implementations.
func (*UnimplementedQueueServer) NextQueueItem ¶
func (*UnimplementedQueueServer) NextQueueItem(ctx context.Context, req *types.QueueRequest) (*types.QueueItem, error)
func (*UnimplementedQueueServer) Submit ¶
func (*UnimplementedQueueServer) Submit(ctx context.Context, req *Submission) (*empty.Empty, error)
Click to show internal directories.
Click to hide internal directories.