Versions in this module Expand all Collapse all v0 v0.2.9 Jan 13, 2022 v0.2.8 Sep 15, 2021 v0.2.7 Nov 29, 2020 v0.2.6 Aug 7, 2020 v0.2.5 Jun 15, 2020 v0.2.4 Jun 9, 2020 Changes in this version + func RegisterWorkerServer(s *grpc.Server, srv WorkerServer) + type Argument struct + Description string + Key string + Type string + Value string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Argument) Descriptor() ([]byte, []int) + func (*Argument) ProtoMessage() + func (m *Argument) GetDescription() string + func (m *Argument) GetKey() string + func (m *Argument) GetType() string + func (m *Argument) GetValue() string + func (m *Argument) Reset() + func (m *Argument) String() string + func (m *Argument) XXX_DiscardUnknown() + func (m *Argument) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Argument) XXX_Merge(src proto.Message) + func (m *Argument) XXX_Size() int + func (m *Argument) XXX_Unmarshal(b []byte) error + type FileChunk struct + Chunk []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FileChunk) Descriptor() ([]byte, []int) + func (*FileChunk) ProtoMessage() + func (m *FileChunk) GetChunk() []byte + func (m *FileChunk) Reset() + func (m *FileChunk) String() string + func (m *FileChunk) XXX_DiscardUnknown() + func (m *FileChunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FileChunk) XXX_Merge(src proto.Message) + func (m *FileChunk) XXX_Size() int + func (m *FileChunk) XXX_Unmarshal(b []byte) error + type GitRepo struct + Branches []string + Localdest string + Password string + PrivateKey *PrivateKey + SelectedBranch string + Url string + Username string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GitRepo) Descriptor() ([]byte, []int) + func (*GitRepo) ProtoMessage() + func (m *GitRepo) GetBranches() []string + func (m *GitRepo) GetLocaldest() string + func (m *GitRepo) GetPassword() string + func (m *GitRepo) GetPrivateKey() *PrivateKey + func (m *GitRepo) GetSelectedBranch() string + func (m *GitRepo) GetUrl() string + func (m *GitRepo) GetUsername() string + func (m *GitRepo) Reset() + func (m *GitRepo) String() string + func (m *GitRepo) XXX_DiscardUnknown() + func (m *GitRepo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GitRepo) XXX_Merge(src proto.Message) + func (m *GitRepo) XXX_Size() int + func (m *GitRepo) XXX_Unmarshal(b []byte) error + type Job struct + Args []*Argument + DependsOn []*Job + Description string + Status string + Title string + UniqueId uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Job) Descriptor() ([]byte, []int) + func (*Job) ProtoMessage() + func (m *Job) GetArgs() []*Argument + func (m *Job) GetDependsOn() []*Job + func (m *Job) GetDescription() string + func (m *Job) GetStatus() string + func (m *Job) GetTitle() string + func (m *Job) GetUniqueId() uint32 + func (m *Job) Reset() + func (m *Job) String() string + func (m *Job) XXX_DiscardUnknown() + func (m *Job) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Job) XXX_Merge(src proto.Message) + func (m *Job) XXX_Size() int + func (m *Job) XXX_Unmarshal(b []byte) error + type LogChunk struct + Chunk []byte + PipelineId int64 + RunId int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LogChunk) Descriptor() ([]byte, []int) + func (*LogChunk) ProtoMessage() + func (m *LogChunk) GetChunk() []byte + func (m *LogChunk) GetPipelineId() int64 + func (m *LogChunk) GetRunId() int64 + func (m *LogChunk) Reset() + func (m *LogChunk) String() string + func (m *LogChunk) XXX_DiscardUnknown() + func (m *LogChunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LogChunk) XXX_Merge(src proto.Message) + func (m *LogChunk) XXX_Size() int + func (m *LogChunk) XXX_Unmarshal(b []byte) error + type PipelineID struct + Id int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PipelineID) Descriptor() ([]byte, []int) + func (*PipelineID) ProtoMessage() + func (m *PipelineID) GetId() int64 + func (m *PipelineID) Reset() + func (m *PipelineID) String() string + func (m *PipelineID) XXX_DiscardUnknown() + func (m *PipelineID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PipelineID) XXX_Merge(src proto.Message) + func (m *PipelineID) XXX_Size() int + func (m *PipelineID) XXX_Unmarshal(b []byte) error + type PipelineRun struct + Docker bool + FinishDate int64 + Id int64 + Jobs []*Job + PipelineId int64 + PipelineName string + PipelineType string + ScheduleDate int64 + ShaSum []byte + StartDate int64 + Status string + UniqueId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PipelineRun) Descriptor() ([]byte, []int) + func (*PipelineRun) ProtoMessage() + func (m *PipelineRun) GetDocker() bool + func (m *PipelineRun) GetFinishDate() int64 + func (m *PipelineRun) GetId() int64 + func (m *PipelineRun) GetJobs() []*Job + func (m *PipelineRun) GetPipelineId() int64 + func (m *PipelineRun) GetPipelineName() string + func (m *PipelineRun) GetPipelineType() string + func (m *PipelineRun) GetScheduleDate() int64 + func (m *PipelineRun) GetShaSum() []byte + func (m *PipelineRun) GetStartDate() int64 + func (m *PipelineRun) GetStatus() string + func (m *PipelineRun) GetUniqueId() string + func (m *PipelineRun) Reset() + func (m *PipelineRun) String() string + func (m *PipelineRun) XXX_DiscardUnknown() + func (m *PipelineRun) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PipelineRun) XXX_Merge(src proto.Message) + func (m *PipelineRun) XXX_Size() int + func (m *PipelineRun) XXX_Unmarshal(b []byte) error + type PrivateKey struct + Key string + Password string + Username string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PrivateKey) Descriptor() ([]byte, []int) + func (*PrivateKey) ProtoMessage() + func (m *PrivateKey) GetKey() string + func (m *PrivateKey) GetPassword() string + func (m *PrivateKey) GetUsername() string + func (m *PrivateKey) Reset() + func (m *PrivateKey) String() string + func (m *PrivateKey) XXX_DiscardUnknown() + func (m *PrivateKey) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PrivateKey) XXX_Merge(src proto.Message) + func (m *PrivateKey) XXX_Size() int + func (m *PrivateKey) XXX_Unmarshal(b []byte) error + type WorkerClient interface + Deregister func(ctx context.Context, in *WorkerInstance, opts ...grpc.CallOption) (*empty.Empty, error) + GetGitRepo func(ctx context.Context, in *PipelineID, opts ...grpc.CallOption) (*GitRepo, error) + GetWork func(ctx context.Context, in *WorkerInstance, opts ...grpc.CallOption) (Worker_GetWorkClient, error) + StreamBinary func(ctx context.Context, in *PipelineRun, opts ...grpc.CallOption) (Worker_StreamBinaryClient, error) + StreamLogs func(ctx context.Context, opts ...grpc.CallOption) (Worker_StreamLogsClient, error) + UpdateWork func(ctx context.Context, in *PipelineRun, opts ...grpc.CallOption) (*empty.Empty, error) + func NewWorkerClient(cc *grpc.ClientConn) WorkerClient + type WorkerInstance struct + Tags []string + UniqueId string + WorkerSlots int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WorkerInstance) Descriptor() ([]byte, []int) + func (*WorkerInstance) ProtoMessage() + func (m *WorkerInstance) GetTags() []string + func (m *WorkerInstance) GetUniqueId() string + func (m *WorkerInstance) GetWorkerSlots() int32 + func (m *WorkerInstance) Reset() + func (m *WorkerInstance) String() string + func (m *WorkerInstance) XXX_DiscardUnknown() + func (m *WorkerInstance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WorkerInstance) XXX_Merge(src proto.Message) + func (m *WorkerInstance) XXX_Size() int + func (m *WorkerInstance) XXX_Unmarshal(b []byte) error + type WorkerServer interface + Deregister func(context.Context, *WorkerInstance) (*empty.Empty, error) + GetGitRepo func(context.Context, *PipelineID) (*GitRepo, error) + GetWork func(*WorkerInstance, Worker_GetWorkServer) error + StreamBinary func(*PipelineRun, Worker_StreamBinaryServer) error + StreamLogs func(Worker_StreamLogsServer) error + UpdateWork func(context.Context, *PipelineRun) (*empty.Empty, error) + type Worker_GetWorkClient interface + Recv func() (*PipelineRun, error) + type Worker_GetWorkServer interface + Send func(*PipelineRun) error + type Worker_StreamBinaryClient interface + Recv func() (*FileChunk, error) + type Worker_StreamBinaryServer interface + Send func(*FileChunk) error + type Worker_StreamLogsClient interface + CloseAndRecv func() (*empty.Empty, error) + Send func(*LogChunk) error + type Worker_StreamLogsServer interface + Recv func() (*LogChunk, error) + SendAndClose func(*empty.Empty) error
Go to main page