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)