Documentation ¶
Index ¶
- func RegisterDataServer(s *grpc.Server, srv DataServer)
- type Capabilities
- func (*Capabilities) Descriptor() ([]byte, []int)
- func (m *Capabilities) GetCapabilities() []string
- func (*Capabilities) ProtoMessage()
- func (m *Capabilities) Reset()
- func (m *Capabilities) String() string
- func (m *Capabilities) XXX_DiscardUnknown()
- func (m *Capabilities) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Capabilities) XXX_Merge(src proto.Message)
- func (m *Capabilities) XXX_Size() int
- func (m *Capabilities) XXX_Unmarshal(b []byte) error
- type CapabilityRequest
- func (*CapabilityRequest) Descriptor() ([]byte, []int)
- func (m *CapabilityRequest) GetCapability() string
- func (m *CapabilityRequest) GetId() int64
- func (*CapabilityRequest) ProtoMessage()
- func (m *CapabilityRequest) Reset()
- func (m *CapabilityRequest) String() string
- func (m *CapabilityRequest) XXX_DiscardUnknown()
- func (m *CapabilityRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CapabilityRequest) XXX_Merge(src proto.Message)
- func (m *CapabilityRequest) XXX_Size() int
- func (m *CapabilityRequest) XXX_Unmarshal(b []byte) error
- type Count
- func (*Count) Descriptor() ([]byte, []int)
- func (m *Count) GetCount() int64
- func (*Count) ProtoMessage()
- func (m *Count) Reset()
- func (m *Count) String() string
- func (m *Count) XXX_DiscardUnknown()
- func (m *Count) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Count) XXX_Merge(src proto.Message)
- func (m *Count) XXX_Size() int
- func (m *Count) XXX_Unmarshal(b []byte) error
- type DataClient
- type DataServer
- type GithubJSON
- func (*GithubJSON) Descriptor() ([]byte, []int)
- func (m *GithubJSON) GetAutoCreated() bool
- func (m *GithubJSON) GetJSON() []byte
- func (m *GithubJSON) GetUsername() string
- func (*GithubJSON) ProtoMessage()
- func (m *GithubJSON) Reset()
- func (m *GithubJSON) String() string
- func (m *GithubJSON) XXX_DiscardUnknown()
- func (m *GithubJSON) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GithubJSON) XXX_Merge(src proto.Message)
- func (m *GithubJSON) XXX_Size() int
- func (m *GithubJSON) XXX_Unmarshal(b []byte) error
- type ListSubscribedTasksRequest
- func (*ListSubscribedTasksRequest) Descriptor() ([]byte, []int)
- func (m *ListSubscribedTasksRequest) GetId() int64
- func (m *ListSubscribedTasksRequest) GetPage() int64
- func (m *ListSubscribedTasksRequest) GetPerPage() int64
- func (*ListSubscribedTasksRequest) ProtoMessage()
- func (m *ListSubscribedTasksRequest) Reset()
- func (m *ListSubscribedTasksRequest) String() string
- func (m *ListSubscribedTasksRequest) XXX_DiscardUnknown()
- func (m *ListSubscribedTasksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListSubscribedTasksRequest) XXX_Merge(src proto.Message)
- func (m *ListSubscribedTasksRequest) XXX_Size() int
- func (m *ListSubscribedTasksRequest) XXX_Unmarshal(b []byte) error
- type Name
- func (*Name) Descriptor() ([]byte, []int)
- func (m *Name) GetName() string
- func (*Name) ProtoMessage()
- func (m *Name) Reset()
- func (m *Name) String() string
- func (m *Name) XXX_DiscardUnknown()
- func (m *Name) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Name) XXX_Merge(src proto.Message)
- func (m *Name) XXX_Size() int
- func (m *Name) XXX_Unmarshal(b []byte) error
- type NameSearch
- func (*NameSearch) Descriptor() ([]byte, []int)
- func (m *NameSearch) GetName() string
- func (m *NameSearch) GetSearch() string
- func (*NameSearch) ProtoMessage()
- func (m *NameSearch) Reset()
- func (m *NameSearch) String() string
- func (m *NameSearch) XXX_DiscardUnknown()
- func (m *NameSearch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NameSearch) XXX_Merge(src proto.Message)
- func (m *NameSearch) XXX_Size() int
- func (m *NameSearch) XXX_Unmarshal(b []byte) error
- type OAuthState
- func (*OAuthState) Descriptor() ([]byte, []int)
- func (m *OAuthState) GetScopes() []string
- func (m *OAuthState) GetState() string
- func (*OAuthState) ProtoMessage()
- func (m *OAuthState) Reset()
- func (m *OAuthState) String() string
- func (m *OAuthState) XXX_DiscardUnknown()
- func (m *OAuthState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OAuthState) XXX_Merge(src proto.Message)
- func (m *OAuthState) XXX_Size() int
- func (m *OAuthState) XXX_Unmarshal(b []byte) error
- type QueueList
- func (*QueueList) Descriptor() ([]byte, []int)
- func (m *QueueList) GetItems() []*types.QueueItem
- func (*QueueList) ProtoMessage()
- func (m *QueueList) Reset()
- func (m *QueueList) String() string
- func (m *QueueList) XXX_DiscardUnknown()
- func (m *QueueList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueueList) XXX_Merge(src proto.Message)
- func (m *QueueList) XXX_Size() int
- func (m *QueueList) XXX_Unmarshal(b []byte) error
- type QueueListRequest
- func (*QueueListRequest) Descriptor() ([]byte, []int)
- func (m *QueueListRequest) GetName() string
- func (m *QueueListRequest) GetPage() int64
- func (m *QueueListRequest) GetPerPage() int64
- func (*QueueListRequest) ProtoMessage()
- func (m *QueueListRequest) Reset()
- func (m *QueueListRequest) String() string
- func (m *QueueListRequest) XXX_DiscardUnknown()
- func (m *QueueListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueueListRequest) XXX_Merge(src proto.Message)
- func (m *QueueListRequest) XXX_Size() int
- func (m *QueueListRequest) XXX_Unmarshal(b []byte) error
- type RefPair
- func (*RefPair) Descriptor() ([]byte, []int)
- func (m *RefPair) GetRepoName() string
- func (m *RefPair) GetSha() string
- func (*RefPair) ProtoMessage()
- func (m *RefPair) Reset()
- func (m *RefPair) String() string
- func (m *RefPair) XXX_DiscardUnknown()
- func (m *RefPair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RefPair) XXX_Merge(src proto.Message)
- func (m *RefPair) XXX_Size() int
- func (m *RefPair) XXX_Unmarshal(b []byte) error
- type RepoRef
- func (*RepoRef) Descriptor() ([]byte, []int)
- func (m *RepoRef) GetRefName() string
- func (m *RepoRef) GetRepository() int64
- func (*RepoRef) ProtoMessage()
- func (m *RepoRef) Reset()
- func (m *RepoRef) String() string
- func (m *RepoRef) XXX_DiscardUnknown()
- func (m *RepoRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RepoRef) XXX_Merge(src proto.Message)
- func (m *RepoRef) XXX_Size() int
- func (m *RepoRef) XXX_Unmarshal(b []byte) error
- type RepoUserSelection
- func (*RepoUserSelection) Descriptor() ([]byte, []int)
- func (m *RepoUserSelection) GetRepoName() string
- func (m *RepoUserSelection) GetUsername() string
- func (*RepoUserSelection) ProtoMessage()
- func (m *RepoUserSelection) Reset()
- func (m *RepoUserSelection) String() string
- func (m *RepoUserSelection) XXX_DiscardUnknown()
- func (m *RepoUserSelection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RepoUserSelection) XXX_Merge(src proto.Message)
- func (m *RepoUserSelection) XXX_Size() int
- func (m *RepoUserSelection) XXX_Unmarshal(b []byte) error
- type RepositoryFilterRequest
- func (*RepositoryFilterRequest) Descriptor() ([]byte, []int)
- func (m *RepositoryFilterRequest) GetRepository() string
- func (m *RepositoryFilterRequest) GetSha() string
- func (*RepositoryFilterRequest) ProtoMessage()
- func (m *RepositoryFilterRequest) Reset()
- func (m *RepositoryFilterRequest) String() string
- func (m *RepositoryFilterRequest) XXX_DiscardUnknown()
- func (m *RepositoryFilterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RepositoryFilterRequest) XXX_Merge(src proto.Message)
- func (m *RepositoryFilterRequest) XXX_Size() int
- func (m *RepositoryFilterRequest) XXX_Unmarshal(b []byte) error
- type RepositoryFilterRequestWithPagination
- func (*RepositoryFilterRequestWithPagination) Descriptor() ([]byte, []int)
- func (m *RepositoryFilterRequestWithPagination) GetPage() int64
- func (m *RepositoryFilterRequestWithPagination) GetPerPage() int64
- func (m *RepositoryFilterRequestWithPagination) GetRepository() string
- func (m *RepositoryFilterRequestWithPagination) GetSha() string
- func (*RepositoryFilterRequestWithPagination) ProtoMessage()
- func (m *RepositoryFilterRequestWithPagination) Reset()
- func (m *RepositoryFilterRequestWithPagination) String() string
- func (m *RepositoryFilterRequestWithPagination) XXX_DiscardUnknown()
- func (m *RepositoryFilterRequestWithPagination) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RepositoryFilterRequestWithPagination) XXX_Merge(src proto.Message)
- func (m *RepositoryFilterRequestWithPagination) XXX_Size() int
- func (m *RepositoryFilterRequestWithPagination) XXX_Unmarshal(b []byte) error
- type RunListRequest
- func (*RunListRequest) Descriptor() ([]byte, []int)
- func (m *RunListRequest) GetPage() int64
- func (m *RunListRequest) GetPerPage() int64
- func (m *RunListRequest) GetRepository() string
- func (m *RunListRequest) GetSha() string
- func (*RunListRequest) ProtoMessage()
- func (m *RunListRequest) Reset()
- func (m *RunListRequest) String() string
- func (m *RunListRequest) XXX_DiscardUnknown()
- func (m *RunListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RunListRequest) XXX_Merge(src proto.Message)
- func (m *RunListRequest) XXX_Size() int
- func (m *RunListRequest) XXX_Unmarshal(b []byte) error
- type RunsForTaskRequest
- func (*RunsForTaskRequest) Descriptor() ([]byte, []int)
- func (m *RunsForTaskRequest) GetId() int64
- func (m *RunsForTaskRequest) GetPage() int64
- func (m *RunsForTaskRequest) GetPerPage() int64
- func (*RunsForTaskRequest) ProtoMessage()
- func (m *RunsForTaskRequest) Reset()
- func (m *RunsForTaskRequest) String() string
- func (m *RunsForTaskRequest) XXX_DiscardUnknown()
- func (m *RunsForTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RunsForTaskRequest) XXX_Merge(src proto.Message)
- func (m *RunsForTaskRequest) XXX_Size() int
- func (m *RunsForTaskRequest) XXX_Unmarshal(b []byte) error
- type Search
- func (*Search) Descriptor() ([]byte, []int)
- func (m *Search) GetSearch() string
- func (*Search) ProtoMessage()
- func (m *Search) Reset()
- func (m *Search) String() string
- func (m *Search) XXX_DiscardUnknown()
- func (m *Search) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Search) XXX_Merge(src proto.Message)
- func (m *Search) XXX_Size() int
- func (m *Search) XXX_Unmarshal(b []byte) error
- type SubmissionQuery
- func (*SubmissionQuery) Descriptor() ([]byte, []int)
- func (m *SubmissionQuery) GetPage() int64
- func (m *SubmissionQuery) GetPerPage() int64
- func (m *SubmissionQuery) GetSubmission() *types.Submission
- func (*SubmissionQuery) ProtoMessage()
- func (m *SubmissionQuery) Reset()
- func (m *SubmissionQuery) String() string
- func (m *SubmissionQuery) XXX_DiscardUnknown()
- func (m *SubmissionQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SubmissionQuery) XXX_Merge(src proto.Message)
- func (m *SubmissionQuery) XXX_Size() int
- func (m *SubmissionQuery) XXX_Unmarshal(b []byte) error
- type TaskListRequest
- func (*TaskListRequest) Descriptor() ([]byte, []int)
- func (m *TaskListRequest) GetPage() int64
- func (m *TaskListRequest) GetPerPage() int64
- func (m *TaskListRequest) GetRepository() string
- func (m *TaskListRequest) GetSha() string
- func (*TaskListRequest) ProtoMessage()
- func (m *TaskListRequest) Reset()
- func (m *TaskListRequest) String() string
- func (m *TaskListRequest) XXX_DiscardUnknown()
- func (m *TaskListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TaskListRequest) XXX_Merge(src proto.Message)
- func (m *TaskListRequest) XXX_Size() int
- func (m *TaskListRequest) XXX_Unmarshal(b []byte) error
- type UnimplementedDataServer
- func (*UnimplementedDataServer) AddCapability(ctx context.Context, req *CapabilityRequest) (*empty.Empty, error)
- func (*UnimplementedDataServer) AddError(ctx context.Context, req *types.UserError) (*empty.Empty, error)
- func (*UnimplementedDataServer) AddSubscription(ctx context.Context, req *RepoUserSelection) (*empty.Empty, error)
- func (*UnimplementedDataServer) AllRepositories(ctx context.Context, req *NameSearch) (*types.RepositoryList, error)
- func (*UnimplementedDataServer) CancelRefByName(ctx context.Context, req *RepoRef) (*empty.Empty, error)
- func (*UnimplementedDataServer) CancelSubmission(ctx context.Context, req *types.IntID) (*empty.Empty, error)
- func (*UnimplementedDataServer) CancelTask(ctx context.Context, req *types.IntID) (*empty.Empty, error)
- func (*UnimplementedDataServer) CancelTasksByPR(ctx context.Context, req *types.CancelPRRequest) (*empty.Empty, error)
- func (*UnimplementedDataServer) CountRunsForTask(ctx context.Context, req *types.IntID) (*Count, error)
- func (*UnimplementedDataServer) CountSubmissions(ctx context.Context, req *RepositoryFilterRequest) (*Count, error)
- func (*UnimplementedDataServer) CountTasks(ctx context.Context, req *TaskListRequest) (*Count, error)
- func (*UnimplementedDataServer) DeleteError(ctx context.Context, req *types.UserError) (*empty.Empty, error)
- func (*UnimplementedDataServer) DeleteToken(ctx context.Context, req *Name) (*empty.Empty, error)
- func (*UnimplementedDataServer) DisableRepository(ctx context.Context, req *RepoUserSelection) (*empty.Empty, error)
- func (*UnimplementedDataServer) EnableRepository(ctx context.Context, req *RepoUserSelection) (*empty.Empty, error)
- func (*UnimplementedDataServer) GetCancel(ctx context.Context, req *types.IntID) (*types.Status, error)
- func (*UnimplementedDataServer) GetCapabilities(ctx context.Context, req *types.User) (*Capabilities, error)
- func (*UnimplementedDataServer) GetErrors(ctx context.Context, req *Name) (*types.UserErrors, error)
- func (*UnimplementedDataServer) GetRefByNameAndSHA(ctx context.Context, req *RefPair) (*types.Ref, error)
- func (*UnimplementedDataServer) GetRepository(ctx context.Context, req *Name) (*types.Repository, error)
- func (*UnimplementedDataServer) GetRun(ctx context.Context, req *types.IntID) (*types.Run, error)
- func (*UnimplementedDataServer) GetRunUI(ctx context.Context, req *types.IntID) (*types.Run, error)
- func (*UnimplementedDataServer) GetSubmission(ctx context.Context, req *types.IntID) (*types.Submission, error)
- func (*UnimplementedDataServer) GetSubmissionRuns(ctx context.Context, req *SubmissionQuery) (*types.RunList, error)
- func (*UnimplementedDataServer) GetSubmissionTasks(ctx context.Context, req *SubmissionQuery) (*types.TaskList, error)
- func (*UnimplementedDataServer) GetToken(ctx context.Context, req *Name) (*types.StringID, error)
- func (*UnimplementedDataServer) HasCapability(ctx context.Context, req *CapabilityRequest) (*types.Bool, error)
- func (*UnimplementedDataServer) ListSubmissions(ctx context.Context, req *RepositoryFilterRequestWithPagination) (*types.SubmissionList, error)
- func (*UnimplementedDataServer) ListSubscribedTasksForUser(ctx context.Context, req *ListSubscribedTasksRequest) (*types.TaskList, error)
- func (*UnimplementedDataServer) ListSubscriptions(ctx context.Context, req *NameSearch) (*types.RepositoryList, error)
- func (*UnimplementedDataServer) ListTasks(ctx context.Context, req *TaskListRequest) (*types.TaskList, error)
- func (*UnimplementedDataServer) ListUsers(ctx context.Context, req *empty.Empty) (*types.UserList, error)
- func (*UnimplementedDataServer) LoadSession(ctx context.Context, req *types.StringID) (*types.Session, error)
- func (*UnimplementedDataServer) OAuthRegisterState(ctx context.Context, req *OAuthState) (*empty.Empty, error)
- func (*UnimplementedDataServer) OAuthValidateState(ctx context.Context, req *OAuthState) (*OAuthState, error)
- func (*UnimplementedDataServer) OwnedRepositories(ctx context.Context, req *NameSearch) (*types.RepositoryList, error)
- func (*UnimplementedDataServer) PatchUser(ctx context.Context, req *types.User) (*empty.Empty, error)
- func (*UnimplementedDataServer) PrivateRepositories(ctx context.Context, req *NameSearch) (*types.RepositoryList, error)
- func (*UnimplementedDataServer) PublicRepositories(ctx context.Context, req *Search) (*types.RepositoryList, error)
- func (*UnimplementedDataServer) PutRef(ctx context.Context, req *types.Ref) (*types.Ref, error)
- func (*UnimplementedDataServer) PutSession(ctx context.Context, req *types.Session) (*empty.Empty, error)
- func (*UnimplementedDataServer) PutStatus(ctx context.Context, req *types.Status) (*empty.Empty, error)
- func (*UnimplementedDataServer) PutSubmission(ctx context.Context, req *types.Submission) (*types.Submission, error)
- func (*UnimplementedDataServer) PutTask(ctx context.Context, req *types.Task) (*types.Task, error)
- func (*UnimplementedDataServer) PutUser(ctx context.Context, req *types.User) (*types.User, error)
- func (*UnimplementedDataServer) QueueAdd(ctx context.Context, req *QueueList) (*QueueList, error)
- func (*UnimplementedDataServer) QueueCount(ctx context.Context, req *empty.Empty) (*Count, error)
- func (*UnimplementedDataServer) QueueCountForRepository(ctx context.Context, req *Name) (*Count, error)
- func (*UnimplementedDataServer) QueueListForRepository(ctx context.Context, req *QueueListRequest) (*QueueList, error)
- func (*UnimplementedDataServer) QueueNext(ctx context.Context, req *types.QueueRequest) (*types.QueueItem, error)
- func (*UnimplementedDataServer) RemoveCapability(ctx context.Context, req *CapabilityRequest) (*empty.Empty, error)
- func (*UnimplementedDataServer) RemoveSubscription(ctx context.Context, req *RepoUserSelection) (*empty.Empty, error)
- func (*UnimplementedDataServer) RunCount(ctx context.Context, req *RefPair) (*Count, error)
- func (*UnimplementedDataServer) RunList(ctx context.Context, req *RunListRequest) (*types.RunList, error)
- func (*UnimplementedDataServer) RunsForTask(ctx context.Context, req *RunsForTaskRequest) (*types.RunList, error)
- func (*UnimplementedDataServer) SaveRepositories(ctx context.Context, req *GithubJSON) (*empty.Empty, error)
- func (*UnimplementedDataServer) SetCancel(ctx context.Context, req *types.IntID) (*empty.Empty, error)
- func (*UnimplementedDataServer) UserByName(ctx context.Context, req *Name) (*types.User, error)
- func (*UnimplementedDataServer) ValidateToken(ctx context.Context, req *types.StringID) (*types.User, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Capabilities) Descriptor ¶
func (*Capabilities) Descriptor() ([]byte, []int)
func (*Capabilities) GetCapabilities ¶
func (m *Capabilities) GetCapabilities() []string
func (*Capabilities) ProtoMessage ¶
func (*Capabilities) ProtoMessage()
func (*Capabilities) Reset ¶
func (m *Capabilities) Reset()
func (*Capabilities) String ¶
func (m *Capabilities) String() string
func (*Capabilities) XXX_DiscardUnknown ¶
func (m *Capabilities) XXX_DiscardUnknown()
func (*Capabilities) XXX_Marshal ¶
func (m *Capabilities) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Capabilities) XXX_Merge ¶
func (m *Capabilities) XXX_Merge(src proto.Message)
func (*Capabilities) XXX_Size ¶
func (m *Capabilities) XXX_Size() int
func (*Capabilities) XXX_Unmarshal ¶
func (m *Capabilities) XXX_Unmarshal(b []byte) error
type CapabilityRequest ¶
type CapabilityRequest struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Capability string `protobuf:"bytes,2,opt,name=capability,proto3" json:"capability,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CapabilityRequest) Descriptor ¶
func (*CapabilityRequest) Descriptor() ([]byte, []int)
func (*CapabilityRequest) GetCapability ¶
func (m *CapabilityRequest) GetCapability() string
func (*CapabilityRequest) GetId ¶
func (m *CapabilityRequest) GetId() int64
func (*CapabilityRequest) ProtoMessage ¶
func (*CapabilityRequest) ProtoMessage()
func (*CapabilityRequest) Reset ¶
func (m *CapabilityRequest) Reset()
func (*CapabilityRequest) String ¶
func (m *CapabilityRequest) String() string
func (*CapabilityRequest) XXX_DiscardUnknown ¶
func (m *CapabilityRequest) XXX_DiscardUnknown()
func (*CapabilityRequest) XXX_Marshal ¶
func (m *CapabilityRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CapabilityRequest) XXX_Merge ¶
func (m *CapabilityRequest) XXX_Merge(src proto.Message)
func (*CapabilityRequest) XXX_Size ¶
func (m *CapabilityRequest) XXX_Size() int
func (*CapabilityRequest) XXX_Unmarshal ¶
func (m *CapabilityRequest) XXX_Unmarshal(b []byte) error
type Count ¶
type Count struct { Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Count) Descriptor ¶
func (*Count) ProtoMessage ¶
func (*Count) ProtoMessage()
func (*Count) XXX_DiscardUnknown ¶
func (m *Count) XXX_DiscardUnknown()
func (*Count) XXX_Marshal ¶
func (*Count) XXX_Unmarshal ¶
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) (*empty.Empty, error) // Delete A User Error DeleteError(ctx context.Context, in *types.UserError, opts ...grpc.CallOption) (*empty.Empty, error) // Register state with the database. OAuthRegisterState(ctx context.Context, in *OAuthState, opts ...grpc.CallOption) (*empty.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 *empty.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) (*empty.Empty, error) // SetCancel cancels a run. SetCancel(ctx context.Context, in *types.IntID, opts ...grpc.CallOption) (*empty.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) (*empty.Empty, error) // CancelTask cancels the branch by task ID. CancelTask(ctx context.Context, in *types.IntID, opts ...grpc.CallOption) (*empty.Empty, error) // Enables repository for testing in CI EnableRepository(ctx context.Context, in *RepoUserSelection, opts ...grpc.CallOption) (*empty.Empty, error) // Disables repository for testing in CI DisableRepository(ctx context.Context, in *RepoUserSelection, opts ...grpc.CallOption) (*empty.Empty, error) // Given a JSON list of github responses; save all the repos. SaveRepositories(ctx context.Context, in *GithubJSON, opts ...grpc.CallOption) (*empty.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) (*empty.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) (*empty.Empty, error) // adds a subscription. AddSubscription(ctx context.Context, in *RepoUserSelection, opts ...grpc.CallOption) (*empty.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) (*empty.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) (*empty.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) (*empty.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 *empty.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) (*empty.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) (*empty.Empty, error) // Removes the capability from the user RemoveCapability(ctx context.Context, in *CapabilityRequest, opts ...grpc.CallOption) (*empty.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.ClientConn) 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) (*empty.Empty, error) // Delete A User Error DeleteError(context.Context, *types.UserError) (*empty.Empty, error) // Register state with the database. OAuthRegisterState(context.Context, *OAuthState) (*empty.Empty, error) // Validate returned state within the database. OAuthValidateState(context.Context, *OAuthState) (*OAuthState, error) // QueueCount is the count of the queue QueueCount(context.Context, *empty.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) (*empty.Empty, error) // SetCancel cancels a run. SetCancel(context.Context, *types.IntID) (*empty.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) (*empty.Empty, error) // CancelTask cancels the branch by task ID. CancelTask(context.Context, *types.IntID) (*empty.Empty, error) // Enables repository for testing in CI EnableRepository(context.Context, *RepoUserSelection) (*empty.Empty, error) // Disables repository for testing in CI DisableRepository(context.Context, *RepoUserSelection) (*empty.Empty, error) // Given a JSON list of github responses; save all the repos. SaveRepositories(context.Context, *GithubJSON) (*empty.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) (*empty.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) (*empty.Empty, error) // adds a subscription. AddSubscription(context.Context, *RepoUserSelection) (*empty.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) (*empty.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) (*empty.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) (*empty.Empty, error) // Create a user PutUser(context.Context, *types.User) (*types.User, error) // List all users. ListUsers(context.Context, *empty.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) (*empty.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) (*empty.Empty, error) // Removes the capability from the user RemoveCapability(context.Context, *CapabilityRequest) (*empty.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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GithubJSON) Descriptor ¶
func (*GithubJSON) Descriptor() ([]byte, []int)
func (*GithubJSON) GetAutoCreated ¶
func (m *GithubJSON) GetAutoCreated() bool
func (*GithubJSON) GetJSON ¶
func (m *GithubJSON) GetJSON() []byte
func (*GithubJSON) GetUsername ¶
func (m *GithubJSON) GetUsername() string
func (*GithubJSON) ProtoMessage ¶
func (*GithubJSON) ProtoMessage()
func (*GithubJSON) Reset ¶
func (m *GithubJSON) Reset()
func (*GithubJSON) String ¶
func (m *GithubJSON) String() string
func (*GithubJSON) XXX_DiscardUnknown ¶
func (m *GithubJSON) XXX_DiscardUnknown()
func (*GithubJSON) XXX_Marshal ¶
func (m *GithubJSON) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GithubJSON) XXX_Merge ¶
func (m *GithubJSON) XXX_Merge(src proto.Message)
func (*GithubJSON) XXX_Size ¶
func (m *GithubJSON) XXX_Size() int
func (*GithubJSON) XXX_Unmarshal ¶
func (m *GithubJSON) XXX_Unmarshal(b []byte) error
type ListSubscribedTasksRequest ¶
type ListSubscribedTasksRequest struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Page int64 `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"` PerPage int64 `protobuf:"varint,3,opt,name=perPage,proto3" json:"perPage,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListSubscribedTasksRequest) Descriptor ¶
func (*ListSubscribedTasksRequest) Descriptor() ([]byte, []int)
func (*ListSubscribedTasksRequest) GetId ¶
func (m *ListSubscribedTasksRequest) GetId() int64
func (*ListSubscribedTasksRequest) GetPage ¶
func (m *ListSubscribedTasksRequest) GetPage() int64
func (*ListSubscribedTasksRequest) GetPerPage ¶
func (m *ListSubscribedTasksRequest) GetPerPage() int64
func (*ListSubscribedTasksRequest) ProtoMessage ¶
func (*ListSubscribedTasksRequest) ProtoMessage()
func (*ListSubscribedTasksRequest) Reset ¶
func (m *ListSubscribedTasksRequest) Reset()
func (*ListSubscribedTasksRequest) String ¶
func (m *ListSubscribedTasksRequest) String() string
func (*ListSubscribedTasksRequest) XXX_DiscardUnknown ¶
func (m *ListSubscribedTasksRequest) XXX_DiscardUnknown()
func (*ListSubscribedTasksRequest) XXX_Marshal ¶
func (m *ListSubscribedTasksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListSubscribedTasksRequest) XXX_Merge ¶
func (m *ListSubscribedTasksRequest) XXX_Merge(src proto.Message)
func (*ListSubscribedTasksRequest) XXX_Size ¶
func (m *ListSubscribedTasksRequest) XXX_Size() int
func (*ListSubscribedTasksRequest) XXX_Unmarshal ¶
func (m *ListSubscribedTasksRequest) XXX_Unmarshal(b []byte) error
type Name ¶
type Name struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Name) Descriptor ¶
func (*Name) ProtoMessage ¶
func (*Name) ProtoMessage()
func (*Name) XXX_DiscardUnknown ¶
func (m *Name) XXX_DiscardUnknown()
func (*Name) XXX_Unmarshal ¶
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NameSearch) Descriptor ¶
func (*NameSearch) Descriptor() ([]byte, []int)
func (*NameSearch) GetName ¶
func (m *NameSearch) GetName() string
func (*NameSearch) GetSearch ¶
func (m *NameSearch) GetSearch() string
func (*NameSearch) ProtoMessage ¶
func (*NameSearch) ProtoMessage()
func (*NameSearch) Reset ¶
func (m *NameSearch) Reset()
func (*NameSearch) String ¶
func (m *NameSearch) String() string
func (*NameSearch) XXX_DiscardUnknown ¶
func (m *NameSearch) XXX_DiscardUnknown()
func (*NameSearch) XXX_Marshal ¶
func (m *NameSearch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NameSearch) XXX_Merge ¶
func (m *NameSearch) XXX_Merge(src proto.Message)
func (*NameSearch) XXX_Size ¶
func (m *NameSearch) XXX_Size() int
func (*NameSearch) XXX_Unmarshal ¶
func (m *NameSearch) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*OAuthState) Descriptor ¶
func (*OAuthState) Descriptor() ([]byte, []int)
func (*OAuthState) GetScopes ¶
func (m *OAuthState) GetScopes() []string
func (*OAuthState) GetState ¶
func (m *OAuthState) GetState() string
func (*OAuthState) ProtoMessage ¶
func (*OAuthState) ProtoMessage()
func (*OAuthState) Reset ¶
func (m *OAuthState) Reset()
func (*OAuthState) String ¶
func (m *OAuthState) String() string
func (*OAuthState) XXX_DiscardUnknown ¶
func (m *OAuthState) XXX_DiscardUnknown()
func (*OAuthState) XXX_Marshal ¶
func (m *OAuthState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OAuthState) XXX_Merge ¶
func (m *OAuthState) XXX_Merge(src proto.Message)
func (*OAuthState) XXX_Size ¶
func (m *OAuthState) XXX_Size() int
func (*OAuthState) XXX_Unmarshal ¶
func (m *OAuthState) XXX_Unmarshal(b []byte) error
type QueueList ¶
type QueueList struct { Items []*types.QueueItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*QueueList) Descriptor ¶
func (*QueueList) ProtoMessage ¶
func (*QueueList) ProtoMessage()
func (*QueueList) XXX_DiscardUnknown ¶
func (m *QueueList) XXX_DiscardUnknown()
func (*QueueList) XXX_Marshal ¶
func (*QueueList) XXX_Unmarshal ¶
type QueueListRequest ¶
type QueueListRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Page int64 `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"` PerPage int64 `protobuf:"varint,3,opt,name=perPage,proto3" json:"perPage,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*QueueListRequest) Descriptor ¶
func (*QueueListRequest) Descriptor() ([]byte, []int)
func (*QueueListRequest) GetName ¶
func (m *QueueListRequest) GetName() string
func (*QueueListRequest) GetPage ¶
func (m *QueueListRequest) GetPage() int64
func (*QueueListRequest) GetPerPage ¶
func (m *QueueListRequest) GetPerPage() int64
func (*QueueListRequest) ProtoMessage ¶
func (*QueueListRequest) ProtoMessage()
func (*QueueListRequest) Reset ¶
func (m *QueueListRequest) Reset()
func (*QueueListRequest) String ¶
func (m *QueueListRequest) String() string
func (*QueueListRequest) XXX_DiscardUnknown ¶
func (m *QueueListRequest) XXX_DiscardUnknown()
func (*QueueListRequest) XXX_Marshal ¶
func (m *QueueListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueueListRequest) XXX_Merge ¶
func (m *QueueListRequest) XXX_Merge(src proto.Message)
func (*QueueListRequest) XXX_Size ¶
func (m *QueueListRequest) XXX_Size() int
func (*QueueListRequest) XXX_Unmarshal ¶
func (m *QueueListRequest) XXX_Unmarshal(b []byte) error
type RefPair ¶
type RefPair struct { RepoName string `protobuf:"bytes,1,opt,name=repoName,proto3" json:"repoName,omitempty"` Sha string `protobuf:"bytes,2,opt,name=sha,proto3" json:"sha,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RefPair) Descriptor ¶
func (*RefPair) GetRepoName ¶
func (*RefPair) ProtoMessage ¶
func (*RefPair) ProtoMessage()
func (*RefPair) XXX_DiscardUnknown ¶
func (m *RefPair) XXX_DiscardUnknown()
func (*RefPair) XXX_Marshal ¶
func (*RefPair) XXX_Unmarshal ¶
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RepoRef) Descriptor ¶
func (*RepoRef) GetRefName ¶
func (*RepoRef) GetRepository ¶
func (*RepoRef) ProtoMessage ¶
func (*RepoRef) ProtoMessage()
func (*RepoRef) XXX_DiscardUnknown ¶
func (m *RepoRef) XXX_DiscardUnknown()
func (*RepoRef) XXX_Marshal ¶
func (*RepoRef) XXX_Unmarshal ¶
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RepoUserSelection) Descriptor ¶
func (*RepoUserSelection) Descriptor() ([]byte, []int)
func (*RepoUserSelection) GetRepoName ¶
func (m *RepoUserSelection) GetRepoName() string
func (*RepoUserSelection) GetUsername ¶
func (m *RepoUserSelection) GetUsername() string
func (*RepoUserSelection) ProtoMessage ¶
func (*RepoUserSelection) ProtoMessage()
func (*RepoUserSelection) Reset ¶
func (m *RepoUserSelection) Reset()
func (*RepoUserSelection) String ¶
func (m *RepoUserSelection) String() string
func (*RepoUserSelection) XXX_DiscardUnknown ¶
func (m *RepoUserSelection) XXX_DiscardUnknown()
func (*RepoUserSelection) XXX_Marshal ¶
func (m *RepoUserSelection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RepoUserSelection) XXX_Merge ¶
func (m *RepoUserSelection) XXX_Merge(src proto.Message)
func (*RepoUserSelection) XXX_Size ¶
func (m *RepoUserSelection) XXX_Size() int
func (*RepoUserSelection) XXX_Unmarshal ¶
func (m *RepoUserSelection) XXX_Unmarshal(b []byte) error
type RepositoryFilterRequest ¶
type RepositoryFilterRequest struct { Repository string `protobuf:"bytes,1,opt,name=repository,proto3" json:"repository,omitempty"` Sha string `protobuf:"bytes,2,opt,name=sha,proto3" json:"sha,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RepositoryFilterRequest) Descriptor ¶
func (*RepositoryFilterRequest) Descriptor() ([]byte, []int)
func (*RepositoryFilterRequest) GetRepository ¶
func (m *RepositoryFilterRequest) GetRepository() string
func (*RepositoryFilterRequest) GetSha ¶
func (m *RepositoryFilterRequest) GetSha() string
func (*RepositoryFilterRequest) ProtoMessage ¶
func (*RepositoryFilterRequest) ProtoMessage()
func (*RepositoryFilterRequest) Reset ¶
func (m *RepositoryFilterRequest) Reset()
func (*RepositoryFilterRequest) String ¶
func (m *RepositoryFilterRequest) String() string
func (*RepositoryFilterRequest) XXX_DiscardUnknown ¶
func (m *RepositoryFilterRequest) XXX_DiscardUnknown()
func (*RepositoryFilterRequest) XXX_Marshal ¶
func (m *RepositoryFilterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RepositoryFilterRequest) XXX_Merge ¶
func (m *RepositoryFilterRequest) XXX_Merge(src proto.Message)
func (*RepositoryFilterRequest) XXX_Size ¶
func (m *RepositoryFilterRequest) XXX_Size() int
func (*RepositoryFilterRequest) XXX_Unmarshal ¶
func (m *RepositoryFilterRequest) XXX_Unmarshal(b []byte) error
type RepositoryFilterRequestWithPagination ¶
type RepositoryFilterRequestWithPagination struct { Repository string `protobuf:"bytes,1,opt,name=repository,proto3" json:"repository,omitempty"` 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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RepositoryFilterRequestWithPagination) Descriptor ¶
func (*RepositoryFilterRequestWithPagination) Descriptor() ([]byte, []int)
func (*RepositoryFilterRequestWithPagination) GetPage ¶
func (m *RepositoryFilterRequestWithPagination) GetPage() int64
func (*RepositoryFilterRequestWithPagination) GetPerPage ¶
func (m *RepositoryFilterRequestWithPagination) GetPerPage() int64
func (*RepositoryFilterRequestWithPagination) GetRepository ¶
func (m *RepositoryFilterRequestWithPagination) GetRepository() string
func (*RepositoryFilterRequestWithPagination) GetSha ¶
func (m *RepositoryFilterRequestWithPagination) GetSha() string
func (*RepositoryFilterRequestWithPagination) ProtoMessage ¶
func (*RepositoryFilterRequestWithPagination) ProtoMessage()
func (*RepositoryFilterRequestWithPagination) Reset ¶
func (m *RepositoryFilterRequestWithPagination) Reset()
func (*RepositoryFilterRequestWithPagination) String ¶
func (m *RepositoryFilterRequestWithPagination) String() string
func (*RepositoryFilterRequestWithPagination) XXX_DiscardUnknown ¶
func (m *RepositoryFilterRequestWithPagination) XXX_DiscardUnknown()
func (*RepositoryFilterRequestWithPagination) XXX_Marshal ¶
func (m *RepositoryFilterRequestWithPagination) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RepositoryFilterRequestWithPagination) XXX_Merge ¶
func (m *RepositoryFilterRequestWithPagination) XXX_Merge(src proto.Message)
func (*RepositoryFilterRequestWithPagination) XXX_Size ¶
func (m *RepositoryFilterRequestWithPagination) XXX_Size() int
func (*RepositoryFilterRequestWithPagination) XXX_Unmarshal ¶
func (m *RepositoryFilterRequestWithPagination) XXX_Unmarshal(b []byte) error
type RunListRequest ¶
type RunListRequest struct { Repository string `protobuf:"bytes,1,opt,name=repository,proto3" json:"repository,omitempty"` 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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RunListRequest) Descriptor ¶
func (*RunListRequest) Descriptor() ([]byte, []int)
func (*RunListRequest) GetPage ¶
func (m *RunListRequest) GetPage() int64
func (*RunListRequest) GetPerPage ¶
func (m *RunListRequest) GetPerPage() int64
func (*RunListRequest) GetRepository ¶
func (m *RunListRequest) GetRepository() string
func (*RunListRequest) GetSha ¶
func (m *RunListRequest) GetSha() string
func (*RunListRequest) ProtoMessage ¶
func (*RunListRequest) ProtoMessage()
func (*RunListRequest) Reset ¶
func (m *RunListRequest) Reset()
func (*RunListRequest) String ¶
func (m *RunListRequest) String() string
func (*RunListRequest) XXX_DiscardUnknown ¶
func (m *RunListRequest) XXX_DiscardUnknown()
func (*RunListRequest) XXX_Marshal ¶
func (m *RunListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RunListRequest) XXX_Merge ¶
func (m *RunListRequest) XXX_Merge(src proto.Message)
func (*RunListRequest) XXX_Size ¶
func (m *RunListRequest) XXX_Size() int
func (*RunListRequest) XXX_Unmarshal ¶
func (m *RunListRequest) XXX_Unmarshal(b []byte) error
type RunsForTaskRequest ¶
type RunsForTaskRequest struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Page int64 `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"` PerPage int64 `protobuf:"varint,3,opt,name=perPage,proto3" json:"perPage,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RunsForTaskRequest) Descriptor ¶
func (*RunsForTaskRequest) Descriptor() ([]byte, []int)
func (*RunsForTaskRequest) GetId ¶
func (m *RunsForTaskRequest) GetId() int64
func (*RunsForTaskRequest) GetPage ¶
func (m *RunsForTaskRequest) GetPage() int64
func (*RunsForTaskRequest) GetPerPage ¶
func (m *RunsForTaskRequest) GetPerPage() int64
func (*RunsForTaskRequest) ProtoMessage ¶
func (*RunsForTaskRequest) ProtoMessage()
func (*RunsForTaskRequest) Reset ¶
func (m *RunsForTaskRequest) Reset()
func (*RunsForTaskRequest) String ¶
func (m *RunsForTaskRequest) String() string
func (*RunsForTaskRequest) XXX_DiscardUnknown ¶
func (m *RunsForTaskRequest) XXX_DiscardUnknown()
func (*RunsForTaskRequest) XXX_Marshal ¶
func (m *RunsForTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RunsForTaskRequest) XXX_Merge ¶
func (m *RunsForTaskRequest) XXX_Merge(src proto.Message)
func (*RunsForTaskRequest) XXX_Size ¶
func (m *RunsForTaskRequest) XXX_Size() int
func (*RunsForTaskRequest) XXX_Unmarshal ¶
func (m *RunsForTaskRequest) XXX_Unmarshal(b []byte) error
type Search ¶
type Search struct { Search string `protobuf:"bytes,1,opt,name=search,proto3" json:"search,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Search) Descriptor ¶
func (*Search) ProtoMessage ¶
func (*Search) ProtoMessage()
func (*Search) XXX_DiscardUnknown ¶
func (m *Search) XXX_DiscardUnknown()
func (*Search) XXX_Marshal ¶
func (*Search) XXX_Unmarshal ¶
type SubmissionQuery ¶
type SubmissionQuery struct { Submission *types.Submission `protobuf:"bytes,1,opt,name=submission,proto3" json:"submission,omitempty"` Page int64 `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"` PerPage int64 `protobuf:"varint,3,opt,name=perPage,proto3" json:"perPage,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SubmissionQuery) Descriptor ¶
func (*SubmissionQuery) Descriptor() ([]byte, []int)
func (*SubmissionQuery) GetPage ¶
func (m *SubmissionQuery) GetPage() int64
func (*SubmissionQuery) GetPerPage ¶
func (m *SubmissionQuery) GetPerPage() int64
func (*SubmissionQuery) GetSubmission ¶
func (m *SubmissionQuery) GetSubmission() *types.Submission
func (*SubmissionQuery) ProtoMessage ¶
func (*SubmissionQuery) ProtoMessage()
func (*SubmissionQuery) Reset ¶
func (m *SubmissionQuery) Reset()
func (*SubmissionQuery) String ¶
func (m *SubmissionQuery) String() string
func (*SubmissionQuery) XXX_DiscardUnknown ¶
func (m *SubmissionQuery) XXX_DiscardUnknown()
func (*SubmissionQuery) XXX_Marshal ¶
func (m *SubmissionQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SubmissionQuery) XXX_Merge ¶
func (m *SubmissionQuery) XXX_Merge(src proto.Message)
func (*SubmissionQuery) XXX_Size ¶
func (m *SubmissionQuery) XXX_Size() int
func (*SubmissionQuery) XXX_Unmarshal ¶
func (m *SubmissionQuery) XXX_Unmarshal(b []byte) error
type TaskListRequest ¶
type TaskListRequest struct { Repository string `protobuf:"bytes,1,opt,name=repository,proto3" json:"repository,omitempty"` 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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TaskListRequest) Descriptor ¶
func (*TaskListRequest) Descriptor() ([]byte, []int)
func (*TaskListRequest) GetPage ¶
func (m *TaskListRequest) GetPage() int64
func (*TaskListRequest) GetPerPage ¶
func (m *TaskListRequest) GetPerPage() int64
func (*TaskListRequest) GetRepository ¶
func (m *TaskListRequest) GetRepository() string
func (*TaskListRequest) GetSha ¶
func (m *TaskListRequest) GetSha() string
func (*TaskListRequest) ProtoMessage ¶
func (*TaskListRequest) ProtoMessage()
func (*TaskListRequest) Reset ¶
func (m *TaskListRequest) Reset()
func (*TaskListRequest) String ¶
func (m *TaskListRequest) String() string
func (*TaskListRequest) XXX_DiscardUnknown ¶
func (m *TaskListRequest) XXX_DiscardUnknown()
func (*TaskListRequest) XXX_Marshal ¶
func (m *TaskListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TaskListRequest) XXX_Merge ¶
func (m *TaskListRequest) XXX_Merge(src proto.Message)
func (*TaskListRequest) XXX_Size ¶
func (m *TaskListRequest) XXX_Size() int
func (*TaskListRequest) XXX_Unmarshal ¶
func (m *TaskListRequest) XXX_Unmarshal(b []byte) error
type UnimplementedDataServer ¶
type UnimplementedDataServer struct { }
UnimplementedDataServer can be embedded to have forward compatible implementations.
func (*UnimplementedDataServer) AddCapability ¶
func (*UnimplementedDataServer) AddCapability(ctx context.Context, req *CapabilityRequest) (*empty.Empty, error)
func (*UnimplementedDataServer) AddSubscription ¶
func (*UnimplementedDataServer) AddSubscription(ctx context.Context, req *RepoUserSelection) (*empty.Empty, error)
func (*UnimplementedDataServer) AllRepositories ¶
func (*UnimplementedDataServer) AllRepositories(ctx context.Context, req *NameSearch) (*types.RepositoryList, error)
func (*UnimplementedDataServer) CancelRefByName ¶
func (*UnimplementedDataServer) CancelSubmission ¶
func (*UnimplementedDataServer) CancelTask ¶
func (*UnimplementedDataServer) CancelTasksByPR ¶
func (*UnimplementedDataServer) CancelTasksByPR(ctx context.Context, req *types.CancelPRRequest) (*empty.Empty, error)
func (*UnimplementedDataServer) CountRunsForTask ¶
func (*UnimplementedDataServer) CountSubmissions ¶
func (*UnimplementedDataServer) CountSubmissions(ctx context.Context, req *RepositoryFilterRequest) (*Count, error)
func (*UnimplementedDataServer) CountTasks ¶
func (*UnimplementedDataServer) CountTasks(ctx context.Context, req *TaskListRequest) (*Count, error)
func (*UnimplementedDataServer) DeleteError ¶
func (*UnimplementedDataServer) DeleteToken ¶
func (*UnimplementedDataServer) DisableRepository ¶
func (*UnimplementedDataServer) DisableRepository(ctx context.Context, req *RepoUserSelection) (*empty.Empty, error)
func (*UnimplementedDataServer) EnableRepository ¶
func (*UnimplementedDataServer) EnableRepository(ctx context.Context, req *RepoUserSelection) (*empty.Empty, error)
func (*UnimplementedDataServer) GetCapabilities ¶
func (*UnimplementedDataServer) GetCapabilities(ctx context.Context, req *types.User) (*Capabilities, error)
func (*UnimplementedDataServer) GetErrors ¶
func (*UnimplementedDataServer) GetErrors(ctx context.Context, req *Name) (*types.UserErrors, error)
func (*UnimplementedDataServer) GetRefByNameAndSHA ¶
func (*UnimplementedDataServer) GetRepository ¶
func (*UnimplementedDataServer) GetRepository(ctx context.Context, req *Name) (*types.Repository, error)
func (*UnimplementedDataServer) GetSubmission ¶
func (*UnimplementedDataServer) GetSubmission(ctx context.Context, req *types.IntID) (*types.Submission, error)
func (*UnimplementedDataServer) GetSubmissionRuns ¶
func (*UnimplementedDataServer) GetSubmissionRuns(ctx context.Context, req *SubmissionQuery) (*types.RunList, error)
func (*UnimplementedDataServer) GetSubmissionTasks ¶
func (*UnimplementedDataServer) GetSubmissionTasks(ctx context.Context, req *SubmissionQuery) (*types.TaskList, error)
func (*UnimplementedDataServer) HasCapability ¶
func (*UnimplementedDataServer) HasCapability(ctx context.Context, req *CapabilityRequest) (*types.Bool, error)
func (*UnimplementedDataServer) ListSubmissions ¶
func (*UnimplementedDataServer) ListSubmissions(ctx context.Context, req *RepositoryFilterRequestWithPagination) (*types.SubmissionList, error)
func (*UnimplementedDataServer) ListSubscribedTasksForUser ¶
func (*UnimplementedDataServer) ListSubscribedTasksForUser(ctx context.Context, req *ListSubscribedTasksRequest) (*types.TaskList, error)
func (*UnimplementedDataServer) ListSubscriptions ¶
func (*UnimplementedDataServer) ListSubscriptions(ctx context.Context, req *NameSearch) (*types.RepositoryList, error)
func (*UnimplementedDataServer) ListTasks ¶
func (*UnimplementedDataServer) ListTasks(ctx context.Context, req *TaskListRequest) (*types.TaskList, error)
func (*UnimplementedDataServer) LoadSession ¶
func (*UnimplementedDataServer) OAuthRegisterState ¶
func (*UnimplementedDataServer) OAuthRegisterState(ctx context.Context, req *OAuthState) (*empty.Empty, error)
func (*UnimplementedDataServer) OAuthValidateState ¶
func (*UnimplementedDataServer) OAuthValidateState(ctx context.Context, req *OAuthState) (*OAuthState, error)
func (*UnimplementedDataServer) OwnedRepositories ¶
func (*UnimplementedDataServer) OwnedRepositories(ctx context.Context, req *NameSearch) (*types.RepositoryList, error)
func (*UnimplementedDataServer) PrivateRepositories ¶
func (*UnimplementedDataServer) PrivateRepositories(ctx context.Context, req *NameSearch) (*types.RepositoryList, error)
func (*UnimplementedDataServer) PublicRepositories ¶
func (*UnimplementedDataServer) PublicRepositories(ctx context.Context, req *Search) (*types.RepositoryList, error)
func (*UnimplementedDataServer) PutSession ¶
func (*UnimplementedDataServer) PutSubmission ¶
func (*UnimplementedDataServer) PutSubmission(ctx context.Context, req *types.Submission) (*types.Submission, error)
func (*UnimplementedDataServer) QueueCount ¶
func (*UnimplementedDataServer) QueueCountForRepository ¶
func (*UnimplementedDataServer) QueueListForRepository ¶
func (*UnimplementedDataServer) QueueListForRepository(ctx context.Context, req *QueueListRequest) (*QueueList, error)
func (*UnimplementedDataServer) QueueNext ¶
func (*UnimplementedDataServer) QueueNext(ctx context.Context, req *types.QueueRequest) (*types.QueueItem, error)
func (*UnimplementedDataServer) RemoveCapability ¶
func (*UnimplementedDataServer) RemoveCapability(ctx context.Context, req *CapabilityRequest) (*empty.Empty, error)
func (*UnimplementedDataServer) RemoveSubscription ¶
func (*UnimplementedDataServer) RemoveSubscription(ctx context.Context, req *RepoUserSelection) (*empty.Empty, error)
func (*UnimplementedDataServer) RunList ¶
func (*UnimplementedDataServer) RunList(ctx context.Context, req *RunListRequest) (*types.RunList, error)
func (*UnimplementedDataServer) RunsForTask ¶
func (*UnimplementedDataServer) RunsForTask(ctx context.Context, req *RunsForTaskRequest) (*types.RunList, error)
func (*UnimplementedDataServer) SaveRepositories ¶
func (*UnimplementedDataServer) SaveRepositories(ctx context.Context, req *GithubJSON) (*empty.Empty, error)
func (*UnimplementedDataServer) UserByName ¶
func (*UnimplementedDataServer) ValidateToken ¶
Click to show internal directories.
Click to hide internal directories.