Documentation
¶
Index ¶
- Variables
- func RegisterDataServer(s *grpc.Server, srv DataServer)
- type Capabilities
- type CapabilityRequest
- func (*CapabilityRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CapabilityRequest) GetCapability() string
- func (x *CapabilityRequest) GetId() int64
- func (*CapabilityRequest) ProtoMessage()
- func (x *CapabilityRequest) ProtoReflect() protoreflect.Message
- func (x *CapabilityRequest) Reset()
- func (x *CapabilityRequest) String() string
- type Count
- type DataClient
- type DataServer
- type GithubJSON
- func (*GithubJSON) Descriptor() ([]byte, []int)deprecated
- func (x *GithubJSON) GetAutoCreated() bool
- func (x *GithubJSON) GetJSON() []byte
- func (x *GithubJSON) GetUsername() string
- func (*GithubJSON) ProtoMessage()
- func (x *GithubJSON) ProtoReflect() protoreflect.Message
- func (x *GithubJSON) Reset()
- func (x *GithubJSON) String() string
- type ListSubscribedTasksRequest
- func (*ListSubscribedTasksRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListSubscribedTasksRequest) GetId() int64
- func (x *ListSubscribedTasksRequest) GetPage() int64
- func (x *ListSubscribedTasksRequest) GetPerPage() int64
- func (*ListSubscribedTasksRequest) ProtoMessage()
- func (x *ListSubscribedTasksRequest) ProtoReflect() protoreflect.Message
- func (x *ListSubscribedTasksRequest) Reset()
- func (x *ListSubscribedTasksRequest) String() string
- type Name
- type NameSearch
- type OAuthState
- type QueueList
- type QueueListRequest
- func (*QueueListRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueueListRequest) GetName() string
- func (x *QueueListRequest) GetPage() int64
- func (x *QueueListRequest) GetPerPage() int64
- func (*QueueListRequest) ProtoMessage()
- func (x *QueueListRequest) ProtoReflect() protoreflect.Message
- func (x *QueueListRequest) Reset()
- func (x *QueueListRequest) String() string
- type RefPair
- type RepoRef
- type RepoUserSelection
- func (*RepoUserSelection) Descriptor() ([]byte, []int)deprecated
- func (x *RepoUserSelection) GetRepoName() string
- func (x *RepoUserSelection) GetUsername() string
- func (*RepoUserSelection) ProtoMessage()
- func (x *RepoUserSelection) ProtoReflect() protoreflect.Message
- func (x *RepoUserSelection) Reset()
- func (x *RepoUserSelection) String() string
- type RepositoryFilterRequest
- func (*RepositoryFilterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RepositoryFilterRequest) GetRepository() string
- func (x *RepositoryFilterRequest) GetSha() string
- func (*RepositoryFilterRequest) ProtoMessage()
- func (x *RepositoryFilterRequest) ProtoReflect() protoreflect.Message
- func (x *RepositoryFilterRequest) Reset()
- func (x *RepositoryFilterRequest) String() string
- type RepositoryFilterRequestWithPagination
- func (*RepositoryFilterRequestWithPagination) Descriptor() ([]byte, []int)deprecated
- func (x *RepositoryFilterRequestWithPagination) GetPage() int64
- func (x *RepositoryFilterRequestWithPagination) GetPerPage() int64
- func (x *RepositoryFilterRequestWithPagination) GetRepository() string
- func (x *RepositoryFilterRequestWithPagination) GetSha() string
- func (*RepositoryFilterRequestWithPagination) ProtoMessage()
- func (x *RepositoryFilterRequestWithPagination) ProtoReflect() protoreflect.Message
- func (x *RepositoryFilterRequestWithPagination) Reset()
- func (x *RepositoryFilterRequestWithPagination) String() string
- type RunListRequest
- func (*RunListRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RunListRequest) GetPage() int64
- func (x *RunListRequest) GetPerPage() int64
- func (x *RunListRequest) GetRepository() string
- func (x *RunListRequest) GetSha() string
- func (*RunListRequest) ProtoMessage()
- func (x *RunListRequest) ProtoReflect() protoreflect.Message
- func (x *RunListRequest) Reset()
- func (x *RunListRequest) String() string
- type RunsForTaskRequest
- func (*RunsForTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RunsForTaskRequest) GetId() int64
- func (x *RunsForTaskRequest) GetPage() int64
- func (x *RunsForTaskRequest) GetPerPage() int64
- func (*RunsForTaskRequest) ProtoMessage()
- func (x *RunsForTaskRequest) ProtoReflect() protoreflect.Message
- func (x *RunsForTaskRequest) Reset()
- func (x *RunsForTaskRequest) String() string
- type Search
- type SubmissionQuery
- func (*SubmissionQuery) Descriptor() ([]byte, []int)deprecated
- func (x *SubmissionQuery) GetPage() int64
- func (x *SubmissionQuery) GetPerPage() int64
- func (x *SubmissionQuery) GetSubmission() *types.Submission
- func (*SubmissionQuery) ProtoMessage()
- func (x *SubmissionQuery) ProtoReflect() protoreflect.Message
- func (x *SubmissionQuery) Reset()
- func (x *SubmissionQuery) String() string
- type TaskListRequest
- func (*TaskListRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TaskListRequest) GetPage() int64
- func (x *TaskListRequest) GetPerPage() int64
- func (x *TaskListRequest) GetRepository() string
- func (x *TaskListRequest) GetSha() string
- func (*TaskListRequest) ProtoMessage()
- func (x *TaskListRequest) ProtoReflect() protoreflect.Message
- func (x *TaskListRequest) Reset()
- func (x *TaskListRequest) String() string
- type UnimplementedDataServer
- func (*UnimplementedDataServer) AddCapability(context.Context, *CapabilityRequest) (*emptypb.Empty, error)
- func (*UnimplementedDataServer) AddError(context.Context, *types.UserError) (*emptypb.Empty, error)
- func (*UnimplementedDataServer) AddSubscription(context.Context, *RepoUserSelection) (*emptypb.Empty, error)
- func (*UnimplementedDataServer) AllRepositories(context.Context, *NameSearch) (*types.RepositoryList, error)
- func (*UnimplementedDataServer) CancelRefByName(context.Context, *RepoRef) (*emptypb.Empty, error)
- func (*UnimplementedDataServer) CancelSubmission(context.Context, *types.IntID) (*emptypb.Empty, error)
- func (*UnimplementedDataServer) CancelTask(context.Context, *types.IntID) (*emptypb.Empty, error)
- func (*UnimplementedDataServer) CancelTasksByPR(context.Context, *types.CancelPRRequest) (*emptypb.Empty, error)
- func (*UnimplementedDataServer) CountRunsForTask(context.Context, *types.IntID) (*Count, error)
- func (*UnimplementedDataServer) CountSubmissions(context.Context, *RepositoryFilterRequest) (*Count, error)
- func (*UnimplementedDataServer) CountTasks(context.Context, *TaskListRequest) (*Count, error)
- func (*UnimplementedDataServer) DeleteError(context.Context, *types.UserError) (*emptypb.Empty, error)
- func (*UnimplementedDataServer) DeleteToken(context.Context, *Name) (*emptypb.Empty, error)
- func (*UnimplementedDataServer) DisableRepository(context.Context, *RepoUserSelection) (*emptypb.Empty, error)
- func (*UnimplementedDataServer) EnableRepository(context.Context, *RepoUserSelection) (*emptypb.Empty, error)
- func (*UnimplementedDataServer) GetCancel(context.Context, *types.IntID) (*types.Status, error)
- func (*UnimplementedDataServer) GetCapabilities(context.Context, *types.User) (*Capabilities, error)
- func (*UnimplementedDataServer) GetErrors(context.Context, *Name) (*types.UserErrors, error)
- func (*UnimplementedDataServer) GetRefByNameAndSHA(context.Context, *RefPair) (*types.Ref, error)
- func (*UnimplementedDataServer) GetRepository(context.Context, *Name) (*types.Repository, error)
- func (*UnimplementedDataServer) GetRun(context.Context, *types.IntID) (*types.Run, error)
- func (*UnimplementedDataServer) GetRunUI(context.Context, *types.IntID) (*types.Run, error)
- func (*UnimplementedDataServer) GetSubmission(context.Context, *types.IntID) (*types.Submission, error)
- func (*UnimplementedDataServer) GetSubmissionRuns(context.Context, *SubmissionQuery) (*types.RunList, error)
- func (*UnimplementedDataServer) GetSubmissionTasks(context.Context, *SubmissionQuery) (*types.TaskList, error)
- func (*UnimplementedDataServer) GetToken(context.Context, *Name) (*types.StringID, error)
- func (*UnimplementedDataServer) HasCapability(context.Context, *CapabilityRequest) (*types.Bool, error)
- func (*UnimplementedDataServer) ListSubmissions(context.Context, *RepositoryFilterRequestWithPagination) (*types.SubmissionList, error)
- func (*UnimplementedDataServer) ListSubscribedTasksForUser(context.Context, *ListSubscribedTasksRequest) (*types.TaskList, error)
- func (*UnimplementedDataServer) ListSubscriptions(context.Context, *NameSearch) (*types.RepositoryList, error)
- func (*UnimplementedDataServer) ListTasks(context.Context, *TaskListRequest) (*types.TaskList, error)
- func (*UnimplementedDataServer) ListUsers(context.Context, *emptypb.Empty) (*types.UserList, error)
- func (*UnimplementedDataServer) LoadSession(context.Context, *types.StringID) (*types.Session, error)
- func (*UnimplementedDataServer) OAuthRegisterState(context.Context, *OAuthState) (*emptypb.Empty, error)
- func (*UnimplementedDataServer) OAuthValidateState(context.Context, *OAuthState) (*OAuthState, error)
- func (*UnimplementedDataServer) OwnedRepositories(context.Context, *NameSearch) (*types.RepositoryList, error)
- func (*UnimplementedDataServer) PatchUser(context.Context, *types.User) (*emptypb.Empty, error)
- func (*UnimplementedDataServer) PrivateRepositories(context.Context, *NameSearch) (*types.RepositoryList, error)
- func (*UnimplementedDataServer) PublicRepositories(context.Context, *Search) (*types.RepositoryList, error)
- func (*UnimplementedDataServer) PutRef(context.Context, *types.Ref) (*types.Ref, error)
- func (*UnimplementedDataServer) PutSession(context.Context, *types.Session) (*emptypb.Empty, error)
- func (*UnimplementedDataServer) PutStatus(context.Context, *types.Status) (*emptypb.Empty, error)
- func (*UnimplementedDataServer) PutSubmission(context.Context, *types.Submission) (*types.Submission, error)
- func (*UnimplementedDataServer) PutTask(context.Context, *types.Task) (*types.Task, error)
- func (*UnimplementedDataServer) PutUser(context.Context, *types.User) (*types.User, error)
- func (*UnimplementedDataServer) QueueAdd(context.Context, *QueueList) (*QueueList, error)
- func (*UnimplementedDataServer) QueueCount(context.Context, *emptypb.Empty) (*Count, error)
- func (*UnimplementedDataServer) QueueCountForRepository(context.Context, *Name) (*Count, error)
- func (*UnimplementedDataServer) QueueListForRepository(context.Context, *QueueListRequest) (*QueueList, error)
- func (*UnimplementedDataServer) QueueNext(context.Context, *types.QueueRequest) (*types.QueueItem, error)
- func (*UnimplementedDataServer) RemoveCapability(context.Context, *CapabilityRequest) (*emptypb.Empty, error)
- func (*UnimplementedDataServer) RemoveSubscription(context.Context, *RepoUserSelection) (*emptypb.Empty, error)
- func (*UnimplementedDataServer) RunCount(context.Context, *RefPair) (*Count, error)
- func (*UnimplementedDataServer) RunList(context.Context, *RunListRequest) (*types.RunList, error)
- func (*UnimplementedDataServer) RunsForTask(context.Context, *RunsForTaskRequest) (*types.RunList, error)
- func (*UnimplementedDataServer) SaveRepositories(context.Context, *GithubJSON) (*emptypb.Empty, error)
- func (*UnimplementedDataServer) SetCancel(context.Context, *types.IntID) (*emptypb.Empty, error)
- func (*UnimplementedDataServer) UserByName(context.Context, *Name) (*types.User, error)
- func (*UnimplementedDataServer) ValidateToken(context.Context, *types.StringID) (*types.User, error)
Constants ¶
This section is empty.
Variables ¶
var File_grpc_services_data_server_proto protoreflect.FileDescriptor
Functions ¶
func RegisterDataServer ¶
func RegisterDataServer(s *grpc.Server, srv DataServer)
Types ¶
type Capabilities ¶
type Capabilities struct {
Capabilities []string `protobuf:"bytes,1,rep,name=capabilities,proto3" json:"capabilities,omitempty"` // list of capabilities
// contains filtered or unexported fields
}
func (*Capabilities) Descriptor
deprecated
func (*Capabilities) Descriptor() ([]byte, []int)
Deprecated: Use Capabilities.ProtoReflect.Descriptor instead.
func (*Capabilities) GetCapabilities ¶
func (x *Capabilities) GetCapabilities() []string
func (*Capabilities) ProtoMessage ¶
func (*Capabilities) ProtoMessage()
func (*Capabilities) ProtoReflect ¶ added in v0.3.0
func (x *Capabilities) ProtoReflect() protoreflect.Message
func (*Capabilities) Reset ¶
func (x *Capabilities) Reset()
func (*Capabilities) String ¶
func (x *Capabilities) String() string
type CapabilityRequest ¶
type CapabilityRequest struct {
Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // User ID
Capability string `protobuf:"bytes,2,opt,name=capability,proto3" json:"capability,omitempty"` // name of capability (See model/user.go)
// contains filtered or unexported fields
}
func (*CapabilityRequest) Descriptor
deprecated
func (*CapabilityRequest) Descriptor() ([]byte, []int)
Deprecated: Use CapabilityRequest.ProtoReflect.Descriptor instead.
func (*CapabilityRequest) GetCapability ¶
func (x *CapabilityRequest) GetCapability() string
func (*CapabilityRequest) GetId ¶
func (x *CapabilityRequest) GetId() int64
func (*CapabilityRequest) ProtoMessage ¶
func (*CapabilityRequest) ProtoMessage()
func (*CapabilityRequest) ProtoReflect ¶ added in v0.3.0
func (x *CapabilityRequest) ProtoReflect() protoreflect.Message
func (*CapabilityRequest) Reset ¶
func (x *CapabilityRequest) Reset()
func (*CapabilityRequest) String ¶
func (x *CapabilityRequest) String() string
type Count ¶
type Count struct {
Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
// contains filtered or unexported fields
}
func (*Count) Descriptor
deprecated
func (*Count) ProtoMessage ¶
func (*Count) ProtoMessage()
func (*Count) ProtoReflect ¶ added in v0.3.0
func (x *Count) ProtoReflect() protoreflect.Message
type DataClient ¶
type DataClient interface {
// Retrieve User Error
GetErrors(ctx context.Context, in *Name, opts ...grpc.CallOption) (*types.UserErrors, error)
// Add A User Error
AddError(ctx context.Context, in *types.UserError, opts ...grpc.CallOption) (*emptypb.Empty, error)
// Delete A User Error
DeleteError(ctx context.Context, in *types.UserError, opts ...grpc.CallOption) (*emptypb.Empty, error)
// Register state with the database.
OAuthRegisterState(ctx context.Context, in *OAuthState, opts ...grpc.CallOption) (*emptypb.Empty, error)
// Validate returned state within the database.
OAuthValidateState(ctx context.Context, in *OAuthState, opts ...grpc.CallOption) (*OAuthState, error)
// QueueCount is the count of the queue
QueueCount(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Count, error)
// QueueCountForRepository counts by repo
QueueCountForRepository(ctx context.Context, in *Name, opts ...grpc.CallOption) (*Count, error)
// QueueListForRepository produces a list for the repo of queue items.
QueueListForRepository(ctx context.Context, in *QueueListRequest, opts ...grpc.CallOption) (*QueueList, error)
// QueueAdd adds a new QueueList of items
QueueAdd(ctx context.Context, in *QueueList, opts ...grpc.CallOption) (*QueueList, error)
// QueueNext retrieves the next item in the queue.
QueueNext(ctx context.Context, in *types.QueueRequest, opts ...grpc.CallOption) (*types.QueueItem, error)
// PutStatus sets the status of the run in the DB.
PutStatus(ctx context.Context, in *types.Status, opts ...grpc.CallOption) (*emptypb.Empty, error)
// SetCancel cancels a run.
SetCancel(ctx context.Context, in *types.IntID, opts ...grpc.CallOption) (*emptypb.Empty, error)
// GetCancel retrieves the canceled state of the run.
GetCancel(ctx context.Context, in *types.IntID, opts ...grpc.CallOption) (*types.Status, error)
// Given a name and sha, look up the ref.
GetRefByNameAndSHA(ctx context.Context, in *RefPair, opts ...grpc.CallOption) (*types.Ref, error)
// PutRef saves a ref.
PutRef(ctx context.Context, in *types.Ref, opts ...grpc.CallOption) (*types.Ref, error)
// CancelRefByName cancels by branch or tag name.
CancelRefByName(ctx context.Context, in *RepoRef, opts ...grpc.CallOption) (*emptypb.Empty, error)
// CancelTask cancels the branch by task ID.
CancelTask(ctx context.Context, in *types.IntID, opts ...grpc.CallOption) (*emptypb.Empty, error)
// Enables repository for testing in CI
EnableRepository(ctx context.Context, in *RepoUserSelection, opts ...grpc.CallOption) (*emptypb.Empty, error)
// Disables repository for testing in CI
DisableRepository(ctx context.Context, in *RepoUserSelection, opts ...grpc.CallOption) (*emptypb.Empty, error)
// Given a JSON list of github responses; save all the repos.
SaveRepositories(ctx context.Context, in *GithubJSON, opts ...grpc.CallOption) (*emptypb.Empty, error)
// List all Private Repositories for the user.
PrivateRepositories(ctx context.Context, in *NameSearch, opts ...grpc.CallOption) (*types.RepositoryList, error)
// List all Owned Repositories for the user.
OwnedRepositories(ctx context.Context, in *NameSearch, opts ...grpc.CallOption) (*types.RepositoryList, error)
// List all repositories for the user.
AllRepositories(ctx context.Context, in *NameSearch, opts ...grpc.CallOption) (*types.RepositoryList, error)
// List all public repositories.
PublicRepositories(ctx context.Context, in *Search, opts ...grpc.CallOption) (*types.RepositoryList, error)
// Get a specific repository by name.
GetRepository(ctx context.Context, in *Name, opts ...grpc.CallOption) (*types.Repository, error)
// Count of runs for the given ref pair
RunCount(ctx context.Context, in *RefPair, opts ...grpc.CallOption) (*Count, error)
// List the runs
RunList(ctx context.Context, in *RunListRequest, opts ...grpc.CallOption) (*types.RunList, error)
// Get a specific Run
GetRun(ctx context.Context, in *types.IntID, opts ...grpc.CallOption) (*types.Run, error)
// Get a specific Run with security details omitted; for UI work.
GetRunUI(ctx context.Context, in *types.IntID, opts ...grpc.CallOption) (*types.Run, error)
// PutSession saves the session.
PutSession(ctx context.Context, in *types.Session, opts ...grpc.CallOption) (*emptypb.Empty, error)
// LoadSession loads the session.
LoadSession(ctx context.Context, in *types.StringID, opts ...grpc.CallOption) (*types.Session, error)
// removes the subscription from the user's account.
RemoveSubscription(ctx context.Context, in *RepoUserSelection, opts ...grpc.CallOption) (*emptypb.Empty, error)
// adds a subscription.
AddSubscription(ctx context.Context, in *RepoUserSelection, opts ...grpc.CallOption) (*emptypb.Empty, error)
// lists all the subscriptions for the user.
ListSubscriptions(ctx context.Context, in *NameSearch, opts ...grpc.CallOption) (*types.RepositoryList, error)
// Add a submission to the db.
PutSubmission(ctx context.Context, in *types.Submission, opts ...grpc.CallOption) (*types.Submission, error)
// Look up a submission by ID
GetSubmission(ctx context.Context, in *types.IntID, opts ...grpc.CallOption) (*types.Submission, error)
// Obtain the tasks for a submission
GetSubmissionTasks(ctx context.Context, in *SubmissionQuery, opts ...grpc.CallOption) (*types.TaskList, error)
// Obtain the runs for a submission
GetSubmissionRuns(ctx context.Context, in *SubmissionQuery, opts ...grpc.CallOption) (*types.RunList, error)
// List the submissions with pagination
ListSubmissions(ctx context.Context, in *RepositoryFilterRequestWithPagination, opts ...grpc.CallOption) (*types.SubmissionList, error)
// Count of all submissions optionally filtered by repository and sha
CountSubmissions(ctx context.Context, in *RepositoryFilterRequest, opts ...grpc.CallOption) (*Count, error)
// Cancel a submission by ID.
CancelSubmission(ctx context.Context, in *types.IntID, opts ...grpc.CallOption) (*emptypb.Empty, error)
// Add a task to the db.
PutTask(ctx context.Context, in *types.Task, opts ...grpc.CallOption) (*types.Task, error)
// List Tasks
ListTasks(ctx context.Context, in *TaskListRequest, opts ...grpc.CallOption) (*types.TaskList, error)
// List tasks only in the user's subscription list.
ListSubscribedTasksForUser(ctx context.Context, in *ListSubscribedTasksRequest, opts ...grpc.CallOption) (*types.TaskList, error)
// Count Tasks
CountTasks(ctx context.Context, in *TaskListRequest, opts ...grpc.CallOption) (*Count, error)
// cancel a task by pull request ID
CancelTasksByPR(ctx context.Context, in *types.CancelPRRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
// get all runs associated with the task.
RunsForTask(ctx context.Context, in *RunsForTaskRequest, opts ...grpc.CallOption) (*types.RunList, error)
// Count all associated runs with the task.
CountRunsForTask(ctx context.Context, in *types.IntID, opts ...grpc.CallOption) (*Count, error)
// Get a user by name
UserByName(ctx context.Context, in *Name, opts ...grpc.CallOption) (*types.User, error)
// Update a user -- currently only accepts token changes.
PatchUser(ctx context.Context, in *types.User, opts ...grpc.CallOption) (*emptypb.Empty, error)
// Create a user
PutUser(ctx context.Context, in *types.User, opts ...grpc.CallOption) (*types.User, error)
// List all users.
ListUsers(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*types.UserList, error)
// Get a auth token (not oauth)
GetToken(ctx context.Context, in *Name, opts ...grpc.CallOption) (*types.StringID, error)
// Delete the auth token
DeleteToken(ctx context.Context, in *Name, opts ...grpc.CallOption) (*emptypb.Empty, error)
// Validate the auth token -- returns the user if successful
ValidateToken(ctx context.Context, in *types.StringID, opts ...grpc.CallOption) (*types.User, error)
// Retrieves the capabilities for a user
GetCapabilities(ctx context.Context, in *types.User, opts ...grpc.CallOption) (*Capabilities, error)
// Returns true if the user has the capability
HasCapability(ctx context.Context, in *CapabilityRequest, opts ...grpc.CallOption) (*types.Bool, error)
// Adds the capability for the user
AddCapability(ctx context.Context, in *CapabilityRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
// Removes the capability from the user
RemoveCapability(ctx context.Context, in *CapabilityRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}
DataClient is the client API for Data service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewDataClient ¶
func NewDataClient(cc grpc.ClientConnInterface) DataClient
type DataServer ¶
type DataServer interface {
// Retrieve User Error
GetErrors(context.Context, *Name) (*types.UserErrors, error)
// Add A User Error
AddError(context.Context, *types.UserError) (*emptypb.Empty, error)
// Delete A User Error
DeleteError(context.Context, *types.UserError) (*emptypb.Empty, error)
// Register state with the database.
OAuthRegisterState(context.Context, *OAuthState) (*emptypb.Empty, error)
// Validate returned state within the database.
OAuthValidateState(context.Context, *OAuthState) (*OAuthState, error)
// QueueCount is the count of the queue
QueueCount(context.Context, *emptypb.Empty) (*Count, error)
// QueueCountForRepository counts by repo
QueueCountForRepository(context.Context, *Name) (*Count, error)
// QueueListForRepository produces a list for the repo of queue items.
QueueListForRepository(context.Context, *QueueListRequest) (*QueueList, error)
// QueueAdd adds a new QueueList of items
QueueAdd(context.Context, *QueueList) (*QueueList, error)
// QueueNext retrieves the next item in the queue.
QueueNext(context.Context, *types.QueueRequest) (*types.QueueItem, error)
// PutStatus sets the status of the run in the DB.
PutStatus(context.Context, *types.Status) (*emptypb.Empty, error)
// SetCancel cancels a run.
SetCancel(context.Context, *types.IntID) (*emptypb.Empty, error)
// GetCancel retrieves the canceled state of the run.
GetCancel(context.Context, *types.IntID) (*types.Status, error)
// Given a name and sha, look up the ref.
GetRefByNameAndSHA(context.Context, *RefPair) (*types.Ref, error)
// PutRef saves a ref.
PutRef(context.Context, *types.Ref) (*types.Ref, error)
// CancelRefByName cancels by branch or tag name.
CancelRefByName(context.Context, *RepoRef) (*emptypb.Empty, error)
// CancelTask cancels the branch by task ID.
CancelTask(context.Context, *types.IntID) (*emptypb.Empty, error)
// Enables repository for testing in CI
EnableRepository(context.Context, *RepoUserSelection) (*emptypb.Empty, error)
// Disables repository for testing in CI
DisableRepository(context.Context, *RepoUserSelection) (*emptypb.Empty, error)
// Given a JSON list of github responses; save all the repos.
SaveRepositories(context.Context, *GithubJSON) (*emptypb.Empty, error)
// List all Private Repositories for the user.
PrivateRepositories(context.Context, *NameSearch) (*types.RepositoryList, error)
// List all Owned Repositories for the user.
OwnedRepositories(context.Context, *NameSearch) (*types.RepositoryList, error)
// List all repositories for the user.
AllRepositories(context.Context, *NameSearch) (*types.RepositoryList, error)
// List all public repositories.
PublicRepositories(context.Context, *Search) (*types.RepositoryList, error)
// Get a specific repository by name.
GetRepository(context.Context, *Name) (*types.Repository, error)
// Count of runs for the given ref pair
RunCount(context.Context, *RefPair) (*Count, error)
// List the runs
RunList(context.Context, *RunListRequest) (*types.RunList, error)
// Get a specific Run
GetRun(context.Context, *types.IntID) (*types.Run, error)
// Get a specific Run with security details omitted; for UI work.
GetRunUI(context.Context, *types.IntID) (*types.Run, error)
// PutSession saves the session.
PutSession(context.Context, *types.Session) (*emptypb.Empty, error)
// LoadSession loads the session.
LoadSession(context.Context, *types.StringID) (*types.Session, error)
// removes the subscription from the user's account.
RemoveSubscription(context.Context, *RepoUserSelection) (*emptypb.Empty, error)
// adds a subscription.
AddSubscription(context.Context, *RepoUserSelection) (*emptypb.Empty, error)
// lists all the subscriptions for the user.
ListSubscriptions(context.Context, *NameSearch) (*types.RepositoryList, error)
// Add a submission to the db.
PutSubmission(context.Context, *types.Submission) (*types.Submission, error)
// Look up a submission by ID
GetSubmission(context.Context, *types.IntID) (*types.Submission, error)
// Obtain the tasks for a submission
GetSubmissionTasks(context.Context, *SubmissionQuery) (*types.TaskList, error)
// Obtain the runs for a submission
GetSubmissionRuns(context.Context, *SubmissionQuery) (*types.RunList, error)
// List the submissions with pagination
ListSubmissions(context.Context, *RepositoryFilterRequestWithPagination) (*types.SubmissionList, error)
// Count of all submissions optionally filtered by repository and sha
CountSubmissions(context.Context, *RepositoryFilterRequest) (*Count, error)
// Cancel a submission by ID.
CancelSubmission(context.Context, *types.IntID) (*emptypb.Empty, error)
// Add a task to the db.
PutTask(context.Context, *types.Task) (*types.Task, error)
// List Tasks
ListTasks(context.Context, *TaskListRequest) (*types.TaskList, error)
// List tasks only in the user's subscription list.
ListSubscribedTasksForUser(context.Context, *ListSubscribedTasksRequest) (*types.TaskList, error)
// Count Tasks
CountTasks(context.Context, *TaskListRequest) (*Count, error)
// cancel a task by pull request ID
CancelTasksByPR(context.Context, *types.CancelPRRequest) (*emptypb.Empty, error)
// get all runs associated with the task.
RunsForTask(context.Context, *RunsForTaskRequest) (*types.RunList, error)
// Count all associated runs with the task.
CountRunsForTask(context.Context, *types.IntID) (*Count, error)
// Get a user by name
UserByName(context.Context, *Name) (*types.User, error)
// Update a user -- currently only accepts token changes.
PatchUser(context.Context, *types.User) (*emptypb.Empty, error)
// Create a user
PutUser(context.Context, *types.User) (*types.User, error)
// List all users.
ListUsers(context.Context, *emptypb.Empty) (*types.UserList, error)
// Get a auth token (not oauth)
GetToken(context.Context, *Name) (*types.StringID, error)
// Delete the auth token
DeleteToken(context.Context, *Name) (*emptypb.Empty, error)
// Validate the auth token -- returns the user if successful
ValidateToken(context.Context, *types.StringID) (*types.User, error)
// Retrieves the capabilities for a user
GetCapabilities(context.Context, *types.User) (*Capabilities, error)
// Returns true if the user has the capability
HasCapability(context.Context, *CapabilityRequest) (*types.Bool, error)
// Adds the capability for the user
AddCapability(context.Context, *CapabilityRequest) (*emptypb.Empty, error)
// Removes the capability from the user
RemoveCapability(context.Context, *CapabilityRequest) (*emptypb.Empty, error)
}
DataServer is the server API for Data service.
type GithubJSON ¶
type GithubJSON struct {
JSON []byte `protobuf:"bytes,1,opt,name=JSON,proto3" json:"JSON,omitempty"`
Username string `protobuf:"bytes,2,opt,name=Username,proto3" json:"Username,omitempty"`
AutoCreated bool `protobuf:"varint,3,opt,name=AutoCreated,proto3" json:"AutoCreated,omitempty"`
// contains filtered or unexported fields
}
func (*GithubJSON) Descriptor
deprecated
func (*GithubJSON) Descriptor() ([]byte, []int)
Deprecated: Use GithubJSON.ProtoReflect.Descriptor instead.
func (*GithubJSON) GetAutoCreated ¶
func (x *GithubJSON) GetAutoCreated() bool
func (*GithubJSON) GetJSON ¶
func (x *GithubJSON) GetJSON() []byte
func (*GithubJSON) GetUsername ¶
func (x *GithubJSON) GetUsername() string
func (*GithubJSON) ProtoMessage ¶
func (*GithubJSON) ProtoMessage()
func (*GithubJSON) ProtoReflect ¶ added in v0.3.0
func (x *GithubJSON) ProtoReflect() protoreflect.Message
func (*GithubJSON) Reset ¶
func (x *GithubJSON) Reset()
func (*GithubJSON) String ¶
func (x *GithubJSON) String() string
type ListSubscribedTasksRequest ¶
type ListSubscribedTasksRequest struct {
Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // User ID
Page int64 `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"`
PerPage int64 `protobuf:"varint,3,opt,name=perPage,proto3" json:"perPage,omitempty"`
// contains filtered or unexported fields
}
func (*ListSubscribedTasksRequest) Descriptor
deprecated
func (*ListSubscribedTasksRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListSubscribedTasksRequest.ProtoReflect.Descriptor instead.
func (*ListSubscribedTasksRequest) GetId ¶
func (x *ListSubscribedTasksRequest) GetId() int64
func (*ListSubscribedTasksRequest) GetPage ¶
func (x *ListSubscribedTasksRequest) GetPage() int64
func (*ListSubscribedTasksRequest) GetPerPage ¶
func (x *ListSubscribedTasksRequest) GetPerPage() int64
func (*ListSubscribedTasksRequest) ProtoMessage ¶
func (*ListSubscribedTasksRequest) ProtoMessage()
func (*ListSubscribedTasksRequest) ProtoReflect ¶ added in v0.3.0
func (x *ListSubscribedTasksRequest) ProtoReflect() protoreflect.Message
func (*ListSubscribedTasksRequest) Reset ¶
func (x *ListSubscribedTasksRequest) Reset()
func (*ListSubscribedTasksRequest) String ¶
func (x *ListSubscribedTasksRequest) String() string
type Name ¶
type Name struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*Name) Descriptor
deprecated
func (*Name) ProtoMessage ¶
func (*Name) ProtoMessage()
func (*Name) ProtoReflect ¶ added in v0.3.0
func (x *Name) ProtoReflect() protoreflect.Message
type NameSearch ¶
type NameSearch struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Search string `protobuf:"bytes,2,opt,name=search,proto3" json:"search,omitempty"`
// contains filtered or unexported fields
}
func (*NameSearch) Descriptor
deprecated
func (*NameSearch) Descriptor() ([]byte, []int)
Deprecated: Use NameSearch.ProtoReflect.Descriptor instead.
func (*NameSearch) GetName ¶
func (x *NameSearch) GetName() string
func (*NameSearch) GetSearch ¶
func (x *NameSearch) GetSearch() string
func (*NameSearch) ProtoMessage ¶
func (*NameSearch) ProtoMessage()
func (*NameSearch) ProtoReflect ¶ added in v0.3.0
func (x *NameSearch) ProtoReflect() protoreflect.Message
func (*NameSearch) Reset ¶
func (x *NameSearch) Reset()
func (*NameSearch) String ¶
func (x *NameSearch) String() string
type OAuthState ¶
type OAuthState struct {
State string `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
Scopes []string `protobuf:"bytes,2,rep,name=scopes,proto3" json:"scopes,omitempty"`
// contains filtered or unexported fields
}
func (*OAuthState) Descriptor
deprecated
func (*OAuthState) Descriptor() ([]byte, []int)
Deprecated: Use OAuthState.ProtoReflect.Descriptor instead.
func (*OAuthState) GetScopes ¶
func (x *OAuthState) GetScopes() []string
func (*OAuthState) GetState ¶
func (x *OAuthState) GetState() string
func (*OAuthState) ProtoMessage ¶
func (*OAuthState) ProtoMessage()
func (*OAuthState) ProtoReflect ¶ added in v0.3.0
func (x *OAuthState) ProtoReflect() protoreflect.Message
func (*OAuthState) Reset ¶
func (x *OAuthState) Reset()
func (*OAuthState) String ¶
func (x *OAuthState) String() string
type QueueList ¶
type QueueList struct {
Items []*types.QueueItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
// contains filtered or unexported fields
}
func (*QueueList) Descriptor
deprecated
func (*QueueList) ProtoMessage ¶
func (*QueueList) ProtoMessage()
func (*QueueList) ProtoReflect ¶ added in v0.3.0
func (x *QueueList) ProtoReflect() protoreflect.Message
type QueueListRequest ¶
type QueueListRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Repository name in owner/repo format
Page int64 `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"`
PerPage int64 `protobuf:"varint,3,opt,name=perPage,proto3" json:"perPage,omitempty"`
// contains filtered or unexported fields
}
func (*QueueListRequest) Descriptor
deprecated
func (*QueueListRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueueListRequest.ProtoReflect.Descriptor instead.
func (*QueueListRequest) GetName ¶
func (x *QueueListRequest) GetName() string
func (*QueueListRequest) GetPage ¶
func (x *QueueListRequest) GetPage() int64
func (*QueueListRequest) GetPerPage ¶
func (x *QueueListRequest) GetPerPage() int64
func (*QueueListRequest) ProtoMessage ¶
func (*QueueListRequest) ProtoMessage()
func (*QueueListRequest) ProtoReflect ¶ added in v0.3.0
func (x *QueueListRequest) ProtoReflect() protoreflect.Message
func (*QueueListRequest) Reset ¶
func (x *QueueListRequest) Reset()
func (*QueueListRequest) String ¶
func (x *QueueListRequest) String() string
type RefPair ¶
type RefPair struct {
RepoName string `protobuf:"bytes,1,opt,name=repoName,proto3" json:"repoName,omitempty"` // these are in owner/repo format
Sha string `protobuf:"bytes,2,opt,name=sha,proto3" json:"sha,omitempty"`
// contains filtered or unexported fields
}
func (*RefPair) Descriptor
deprecated
func (*RefPair) GetRepoName ¶
func (*RefPair) ProtoMessage ¶
func (*RefPair) ProtoMessage()
func (*RefPair) ProtoReflect ¶ added in v0.3.0
func (x *RefPair) ProtoReflect() protoreflect.Message
type RepoRef ¶
type RepoRef struct {
Repository int64 `protobuf:"varint,1,opt,name=repository,proto3" json:"repository,omitempty"`
RefName string `protobuf:"bytes,2,opt,name=refName,proto3" json:"refName,omitempty"`
// contains filtered or unexported fields
}
func (*RepoRef) Descriptor
deprecated
func (*RepoRef) GetRefName ¶
func (*RepoRef) GetRepository ¶
func (*RepoRef) ProtoMessage ¶
func (*RepoRef) ProtoMessage()
func (*RepoRef) ProtoReflect ¶ added in v0.3.0
func (x *RepoRef) ProtoReflect() protoreflect.Message
type RepoUserSelection ¶
type RepoUserSelection struct {
Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
RepoName string `protobuf:"bytes,2,opt,name=repoName,proto3" json:"repoName,omitempty"` // these are in owner/repo format
// contains filtered or unexported fields
}
func (*RepoUserSelection) Descriptor
deprecated
func (*RepoUserSelection) Descriptor() ([]byte, []int)
Deprecated: Use RepoUserSelection.ProtoReflect.Descriptor instead.
func (*RepoUserSelection) GetRepoName ¶
func (x *RepoUserSelection) GetRepoName() string
func (*RepoUserSelection) GetUsername ¶
func (x *RepoUserSelection) GetUsername() string
func (*RepoUserSelection) ProtoMessage ¶
func (*RepoUserSelection) ProtoMessage()
func (*RepoUserSelection) ProtoReflect ¶ added in v0.3.0
func (x *RepoUserSelection) ProtoReflect() protoreflect.Message
func (*RepoUserSelection) Reset ¶
func (x *RepoUserSelection) Reset()
func (*RepoUserSelection) String ¶
func (x *RepoUserSelection) String() string
type RepositoryFilterRequest ¶
type RepositoryFilterRequest struct {
Repository string `protobuf:"bytes,1,opt,name=repository,proto3" json:"repository,omitempty"` // Parent or Fork
Sha string `protobuf:"bytes,2,opt,name=sha,proto3" json:"sha,omitempty"`
// contains filtered or unexported fields
}
func (*RepositoryFilterRequest) Descriptor
deprecated
func (*RepositoryFilterRequest) Descriptor() ([]byte, []int)
Deprecated: Use RepositoryFilterRequest.ProtoReflect.Descriptor instead.
func (*RepositoryFilterRequest) GetRepository ¶
func (x *RepositoryFilterRequest) GetRepository() string
func (*RepositoryFilterRequest) GetSha ¶
func (x *RepositoryFilterRequest) GetSha() string
func (*RepositoryFilterRequest) ProtoMessage ¶
func (*RepositoryFilterRequest) ProtoMessage()
func (*RepositoryFilterRequest) ProtoReflect ¶ added in v0.3.0
func (x *RepositoryFilterRequest) ProtoReflect() protoreflect.Message
func (*RepositoryFilterRequest) Reset ¶
func (x *RepositoryFilterRequest) Reset()
func (*RepositoryFilterRequest) String ¶
func (x *RepositoryFilterRequest) String() string
type RepositoryFilterRequestWithPagination ¶
type RepositoryFilterRequestWithPagination struct {
Repository string `protobuf:"bytes,1,opt,name=repository,proto3" json:"repository,omitempty"` // Parent or Fork
Sha string `protobuf:"bytes,2,opt,name=sha,proto3" json:"sha,omitempty"`
Page int64 `protobuf:"varint,3,opt,name=page,proto3" json:"page,omitempty"`
PerPage int64 `protobuf:"varint,4,opt,name=perPage,proto3" json:"perPage,omitempty"`
// contains filtered or unexported fields
}
func (*RepositoryFilterRequestWithPagination) Descriptor
deprecated
func (*RepositoryFilterRequestWithPagination) Descriptor() ([]byte, []int)
Deprecated: Use RepositoryFilterRequestWithPagination.ProtoReflect.Descriptor instead.
func (*RepositoryFilterRequestWithPagination) GetPage ¶
func (x *RepositoryFilterRequestWithPagination) GetPage() int64
func (*RepositoryFilterRequestWithPagination) GetPerPage ¶
func (x *RepositoryFilterRequestWithPagination) GetPerPage() int64
func (*RepositoryFilterRequestWithPagination) GetRepository ¶
func (x *RepositoryFilterRequestWithPagination) GetRepository() string
func (*RepositoryFilterRequestWithPagination) GetSha ¶
func (x *RepositoryFilterRequestWithPagination) GetSha() string
func (*RepositoryFilterRequestWithPagination) ProtoMessage ¶
func (*RepositoryFilterRequestWithPagination) ProtoMessage()
func (*RepositoryFilterRequestWithPagination) ProtoReflect ¶ added in v0.3.0
func (x *RepositoryFilterRequestWithPagination) ProtoReflect() protoreflect.Message
func (*RepositoryFilterRequestWithPagination) Reset ¶
func (x *RepositoryFilterRequestWithPagination) Reset()
func (*RepositoryFilterRequestWithPagination) String ¶
func (x *RepositoryFilterRequestWithPagination) String() string
type RunListRequest ¶
type RunListRequest struct {
Repository string `protobuf:"bytes,1,opt,name=repository,proto3" json:"repository,omitempty"` // Parent or Fork
Sha string `protobuf:"bytes,2,opt,name=sha,proto3" json:"sha,omitempty"`
Page int64 `protobuf:"varint,3,opt,name=page,proto3" json:"page,omitempty"`
PerPage int64 `protobuf:"varint,4,opt,name=perPage,proto3" json:"perPage,omitempty"`
// contains filtered or unexported fields
}
func (*RunListRequest) Descriptor
deprecated
func (*RunListRequest) Descriptor() ([]byte, []int)
Deprecated: Use RunListRequest.ProtoReflect.Descriptor instead.
func (*RunListRequest) GetPage ¶
func (x *RunListRequest) GetPage() int64
func (*RunListRequest) GetPerPage ¶
func (x *RunListRequest) GetPerPage() int64
func (*RunListRequest) GetRepository ¶
func (x *RunListRequest) GetRepository() string
func (*RunListRequest) GetSha ¶
func (x *RunListRequest) GetSha() string
func (*RunListRequest) ProtoMessage ¶
func (*RunListRequest) ProtoMessage()
func (*RunListRequest) ProtoReflect ¶ added in v0.3.0
func (x *RunListRequest) ProtoReflect() protoreflect.Message
func (*RunListRequest) Reset ¶
func (x *RunListRequest) Reset()
func (*RunListRequest) String ¶
func (x *RunListRequest) String() string
type RunsForTaskRequest ¶
type RunsForTaskRequest struct {
Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // Task ID
Page int64 `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"`
PerPage int64 `protobuf:"varint,3,opt,name=perPage,proto3" json:"perPage,omitempty"`
// contains filtered or unexported fields
}
func (*RunsForTaskRequest) Descriptor
deprecated
func (*RunsForTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use RunsForTaskRequest.ProtoReflect.Descriptor instead.
func (*RunsForTaskRequest) GetId ¶
func (x *RunsForTaskRequest) GetId() int64
func (*RunsForTaskRequest) GetPage ¶
func (x *RunsForTaskRequest) GetPage() int64
func (*RunsForTaskRequest) GetPerPage ¶
func (x *RunsForTaskRequest) GetPerPage() int64
func (*RunsForTaskRequest) ProtoMessage ¶
func (*RunsForTaskRequest) ProtoMessage()
func (*RunsForTaskRequest) ProtoReflect ¶ added in v0.3.0
func (x *RunsForTaskRequest) ProtoReflect() protoreflect.Message
func (*RunsForTaskRequest) Reset ¶
func (x *RunsForTaskRequest) Reset()
func (*RunsForTaskRequest) String ¶
func (x *RunsForTaskRequest) String() string
type Search ¶
type Search struct {
Search string `protobuf:"bytes,1,opt,name=search,proto3" json:"search,omitempty"`
// contains filtered or unexported fields
}
func (*Search) Descriptor
deprecated
func (*Search) ProtoMessage ¶
func (*Search) ProtoMessage()
func (*Search) ProtoReflect ¶ added in v0.3.0
func (x *Search) ProtoReflect() protoreflect.Message
type SubmissionQuery ¶
type SubmissionQuery struct {
Submission *types.Submission `protobuf:"bytes,1,opt,name=submission,proto3" json:"submission,omitempty"` // the submission
Page int64 `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"` // what page to fetch
PerPage int64 `protobuf:"varint,3,opt,name=perPage,proto3" json:"perPage,omitempty"` // how many per-page
// contains filtered or unexported fields
}
func (*SubmissionQuery) Descriptor
deprecated
func (*SubmissionQuery) Descriptor() ([]byte, []int)
Deprecated: Use SubmissionQuery.ProtoReflect.Descriptor instead.
func (*SubmissionQuery) GetPage ¶
func (x *SubmissionQuery) GetPage() int64
func (*SubmissionQuery) GetPerPage ¶
func (x *SubmissionQuery) GetPerPage() int64
func (*SubmissionQuery) GetSubmission ¶
func (x *SubmissionQuery) GetSubmission() *types.Submission
func (*SubmissionQuery) ProtoMessage ¶
func (*SubmissionQuery) ProtoMessage()
func (*SubmissionQuery) ProtoReflect ¶ added in v0.3.0
func (x *SubmissionQuery) ProtoReflect() protoreflect.Message
func (*SubmissionQuery) Reset ¶
func (x *SubmissionQuery) Reset()
func (*SubmissionQuery) String ¶
func (x *SubmissionQuery) String() string
type TaskListRequest ¶
type TaskListRequest struct {
Repository string `protobuf:"bytes,1,opt,name=repository,proto3" json:"repository,omitempty"` // Parent or Fork
Sha string `protobuf:"bytes,2,opt,name=sha,proto3" json:"sha,omitempty"`
Page int64 `protobuf:"varint,3,opt,name=page,proto3" json:"page,omitempty"`
PerPage int64 `protobuf:"varint,4,opt,name=perPage,proto3" json:"perPage,omitempty"`
// contains filtered or unexported fields
}
func (*TaskListRequest) Descriptor
deprecated
func (*TaskListRequest) Descriptor() ([]byte, []int)
Deprecated: Use TaskListRequest.ProtoReflect.Descriptor instead.
func (*TaskListRequest) GetPage ¶
func (x *TaskListRequest) GetPage() int64
func (*TaskListRequest) GetPerPage ¶
func (x *TaskListRequest) GetPerPage() int64
func (*TaskListRequest) GetRepository ¶
func (x *TaskListRequest) GetRepository() string
func (*TaskListRequest) GetSha ¶
func (x *TaskListRequest) GetSha() string
func (*TaskListRequest) ProtoMessage ¶
func (*TaskListRequest) ProtoMessage()
func (*TaskListRequest) ProtoReflect ¶ added in v0.3.0
func (x *TaskListRequest) ProtoReflect() protoreflect.Message
func (*TaskListRequest) Reset ¶
func (x *TaskListRequest) Reset()
func (*TaskListRequest) String ¶
func (x *TaskListRequest) String() string
type UnimplementedDataServer ¶
type UnimplementedDataServer struct {
}
UnimplementedDataServer can be embedded to have forward compatible implementations.
func (*UnimplementedDataServer) AddCapability ¶
func (*UnimplementedDataServer) AddCapability(context.Context, *CapabilityRequest) (*emptypb.Empty, error)
func (*UnimplementedDataServer) AddSubscription ¶
func (*UnimplementedDataServer) AddSubscription(context.Context, *RepoUserSelection) (*emptypb.Empty, error)
func (*UnimplementedDataServer) AllRepositories ¶
func (*UnimplementedDataServer) AllRepositories(context.Context, *NameSearch) (*types.RepositoryList, error)
func (*UnimplementedDataServer) CancelRefByName ¶
func (*UnimplementedDataServer) CancelSubmission ¶
func (*UnimplementedDataServer) CancelTask ¶
func (*UnimplementedDataServer) CancelTasksByPR ¶
func (*UnimplementedDataServer) CancelTasksByPR(context.Context, *types.CancelPRRequest) (*emptypb.Empty, error)
func (*UnimplementedDataServer) CountRunsForTask ¶
func (*UnimplementedDataServer) CountSubmissions ¶
func (*UnimplementedDataServer) CountSubmissions(context.Context, *RepositoryFilterRequest) (*Count, error)
func (*UnimplementedDataServer) CountTasks ¶
func (*UnimplementedDataServer) CountTasks(context.Context, *TaskListRequest) (*Count, error)
func (*UnimplementedDataServer) DeleteError ¶
func (*UnimplementedDataServer) DeleteToken ¶
func (*UnimplementedDataServer) DisableRepository ¶
func (*UnimplementedDataServer) DisableRepository(context.Context, *RepoUserSelection) (*emptypb.Empty, error)
func (*UnimplementedDataServer) EnableRepository ¶
func (*UnimplementedDataServer) EnableRepository(context.Context, *RepoUserSelection) (*emptypb.Empty, error)
func (*UnimplementedDataServer) GetCapabilities ¶
func (*UnimplementedDataServer) GetCapabilities(context.Context, *types.User) (*Capabilities, error)
func (*UnimplementedDataServer) GetErrors ¶
func (*UnimplementedDataServer) GetErrors(context.Context, *Name) (*types.UserErrors, error)
func (*UnimplementedDataServer) GetRefByNameAndSHA ¶
func (*UnimplementedDataServer) GetRepository ¶
func (*UnimplementedDataServer) GetRepository(context.Context, *Name) (*types.Repository, error)
func (*UnimplementedDataServer) GetSubmission ¶
func (*UnimplementedDataServer) GetSubmission(context.Context, *types.IntID) (*types.Submission, error)
func (*UnimplementedDataServer) GetSubmissionRuns ¶
func (*UnimplementedDataServer) GetSubmissionRuns(context.Context, *SubmissionQuery) (*types.RunList, error)
func (*UnimplementedDataServer) GetSubmissionTasks ¶
func (*UnimplementedDataServer) GetSubmissionTasks(context.Context, *SubmissionQuery) (*types.TaskList, error)
func (*UnimplementedDataServer) HasCapability ¶
func (*UnimplementedDataServer) HasCapability(context.Context, *CapabilityRequest) (*types.Bool, error)
func (*UnimplementedDataServer) ListSubmissions ¶
func (*UnimplementedDataServer) ListSubmissions(context.Context, *RepositoryFilterRequestWithPagination) (*types.SubmissionList, error)
func (*UnimplementedDataServer) ListSubscribedTasksForUser ¶
func (*UnimplementedDataServer) ListSubscribedTasksForUser(context.Context, *ListSubscribedTasksRequest) (*types.TaskList, error)
func (*UnimplementedDataServer) ListSubscriptions ¶
func (*UnimplementedDataServer) ListSubscriptions(context.Context, *NameSearch) (*types.RepositoryList, error)
func (*UnimplementedDataServer) ListTasks ¶
func (*UnimplementedDataServer) ListTasks(context.Context, *TaskListRequest) (*types.TaskList, error)
func (*UnimplementedDataServer) LoadSession ¶
func (*UnimplementedDataServer) OAuthRegisterState ¶
func (*UnimplementedDataServer) OAuthRegisterState(context.Context, *OAuthState) (*emptypb.Empty, error)
func (*UnimplementedDataServer) OAuthValidateState ¶
func (*UnimplementedDataServer) OAuthValidateState(context.Context, *OAuthState) (*OAuthState, error)
func (*UnimplementedDataServer) OwnedRepositories ¶
func (*UnimplementedDataServer) OwnedRepositories(context.Context, *NameSearch) (*types.RepositoryList, error)
func (*UnimplementedDataServer) PrivateRepositories ¶
func (*UnimplementedDataServer) PrivateRepositories(context.Context, *NameSearch) (*types.RepositoryList, error)
func (*UnimplementedDataServer) PublicRepositories ¶
func (*UnimplementedDataServer) PublicRepositories(context.Context, *Search) (*types.RepositoryList, error)
func (*UnimplementedDataServer) PutSession ¶
func (*UnimplementedDataServer) PutSubmission ¶
func (*UnimplementedDataServer) PutSubmission(context.Context, *types.Submission) (*types.Submission, error)
func (*UnimplementedDataServer) QueueCount ¶
func (*UnimplementedDataServer) QueueCountForRepository ¶
func (*UnimplementedDataServer) QueueListForRepository ¶
func (*UnimplementedDataServer) QueueListForRepository(context.Context, *QueueListRequest) (*QueueList, error)
func (*UnimplementedDataServer) QueueNext ¶
func (*UnimplementedDataServer) QueueNext(context.Context, *types.QueueRequest) (*types.QueueItem, error)
func (*UnimplementedDataServer) RemoveCapability ¶
func (*UnimplementedDataServer) RemoveCapability(context.Context, *CapabilityRequest) (*emptypb.Empty, error)
func (*UnimplementedDataServer) RemoveSubscription ¶
func (*UnimplementedDataServer) RemoveSubscription(context.Context, *RepoUserSelection) (*emptypb.Empty, error)
func (*UnimplementedDataServer) RunList ¶
func (*UnimplementedDataServer) RunList(context.Context, *RunListRequest) (*types.RunList, error)
func (*UnimplementedDataServer) RunsForTask ¶
func (*UnimplementedDataServer) RunsForTask(context.Context, *RunsForTaskRequest) (*types.RunList, error)
func (*UnimplementedDataServer) SaveRepositories ¶
func (*UnimplementedDataServer) SaveRepositories(context.Context, *GithubJSON) (*emptypb.Empty, error)