Versions in this module Expand all Collapse all v0 v0.6.0 Nov 8, 2019 v0.5.0 Jun 15, 2018 Changes in this version + var BuildEventError_ErrorType_name = map[int32]string + var BuildEventError_ErrorType_value = map[string]int32 + var BuildEvent_EventType_name = map[int32]string + var BuildEvent_EventType_value = map[string]int32 + var BuildStatusResponse_BuildState_name = map[int32]string + var BuildStatusResponse_BuildState_value = map[string]int32 + var ErrCanceled = errors.New("build canceled") + func RegisterFuranExecutorServer(s *grpc.Server, srv FuranExecutorServer) + type BuildCancelRequest struct + BuildId string + func (*BuildCancelRequest) Descriptor() ([]byte, []int) + func (*BuildCancelRequest) ProtoMessage() + func (m *BuildCancelRequest) GetBuildId() string + func (m *BuildCancelRequest) Reset() + func (m *BuildCancelRequest) String() string + type BuildCancelResponse struct + BuildId string + func (*BuildCancelResponse) Descriptor() ([]byte, []int) + func (*BuildCancelResponse) ProtoMessage() + func (m *BuildCancelResponse) GetBuildId() string + func (m *BuildCancelResponse) Reset() + func (m *BuildCancelResponse) String() string + type BuildDefinition struct + Args map[string]string + DockerfilePath string + GithubRepo string + Ref string + TagWithCommitSha bool + Tags []string + func (*BuildDefinition) Descriptor() ([]byte, []int) + func (*BuildDefinition) ProtoMessage() + func (m *BuildDefinition) GetArgs() map[string]string + func (m *BuildDefinition) GetDockerfilePath() string + func (m *BuildDefinition) GetGithubRepo() string + func (m *BuildDefinition) GetRef() string + func (m *BuildDefinition) GetTagWithCommitSha() bool + func (m *BuildDefinition) GetTags() []string + func (m *BuildDefinition) Reset() + func (m *BuildDefinition) String() string + type BuildEvent struct + BuildFinished bool + BuildId string + EventError *BuildEventError + EventType BuildEvent_EventType + Message string + func (*BuildEvent) Descriptor() ([]byte, []int) + func (*BuildEvent) ProtoMessage() + func (m *BuildEvent) GetBuildFinished() bool + func (m *BuildEvent) GetBuildId() string + func (m *BuildEvent) GetEventError() *BuildEventError + func (m *BuildEvent) GetEventType() BuildEvent_EventType + func (m *BuildEvent) GetMessage() string + func (m *BuildEvent) Reset() + func (m *BuildEvent) String() string + type BuildEventError struct + ErrorType BuildEventError_ErrorType + IsError bool + func (*BuildEventError) Descriptor() ([]byte, []int) + func (*BuildEventError) ProtoMessage() + func (m *BuildEventError) GetErrorType() BuildEventError_ErrorType + func (m *BuildEventError) GetIsError() bool + func (m *BuildEventError) Reset() + func (m *BuildEventError) String() string + type BuildEventError_ErrorType int32 + const BuildEventError_FATAL + const BuildEventError_NO_ERROR + const BuildEventError_TEMPORARY + func (BuildEventError_ErrorType) EnumDescriptor() ([]byte, []int) + func (x BuildEventError_ErrorType) String() string + type BuildEvent_EventType int32 + const BuildEvent_DOCKER_BUILD_STREAM + const BuildEvent_DOCKER_PUSH_STREAM + const BuildEvent_LOG + func (BuildEvent_EventType) EnumDescriptor() ([]byte, []int) + func (x BuildEvent_EventType) String() string + type BuildRequest struct + Build *BuildDefinition + Push *PushDefinition + SkipIfExists bool + func (*BuildRequest) Descriptor() ([]byte, []int) + func (*BuildRequest) ProtoMessage() + func (m *BuildRequest) GetBuild() *BuildDefinition + func (m *BuildRequest) GetPush() *PushDefinition + func (m *BuildRequest) GetSkipIfExists() bool + func (m *BuildRequest) Reset() + func (m *BuildRequest) String() string + type BuildRequestResponse struct + BuildId string + func (*BuildRequestResponse) Descriptor() ([]byte, []int) + func (*BuildRequestResponse) ProtoMessage() + func (m *BuildRequestResponse) GetBuildId() string + func (m *BuildRequestResponse) Reset() + func (m *BuildRequestResponse) String() string + type BuildStatusRequest struct + BuildId string + func (*BuildStatusRequest) Descriptor() ([]byte, []int) + func (*BuildStatusRequest) ProtoMessage() + func (m *BuildStatusRequest) GetBuildId() string + func (m *BuildStatusRequest) Reset() + func (m *BuildStatusRequest) String() string + type BuildStatusResponse struct + BuildId string + BuildRequest *BuildRequest + Cancelled bool + Completed string + Duration float64 + Failed bool + Finished bool + Started string + State BuildStatusResponse_BuildState + func (*BuildStatusResponse) Descriptor() ([]byte, []int) + func (*BuildStatusResponse) ProtoMessage() + func (m *BuildStatusResponse) GetBuildId() string + func (m *BuildStatusResponse) GetBuildRequest() *BuildRequest + func (m *BuildStatusResponse) GetCancelled() bool + func (m *BuildStatusResponse) GetCompleted() string + func (m *BuildStatusResponse) GetDuration() float64 + func (m *BuildStatusResponse) GetFailed() bool + func (m *BuildStatusResponse) GetFinished() bool + func (m *BuildStatusResponse) GetStarted() string + func (m *BuildStatusResponse) GetState() BuildStatusResponse_BuildState + func (m *BuildStatusResponse) Reset() + func (m *BuildStatusResponse) String() string + type BuildStatusResponse_BuildState int32 + const BuildStatusResponse_BUILDING + const BuildStatusResponse_BUILD_FAILURE + const BuildStatusResponse_NOT_NECESSARY + const BuildStatusResponse_PUSHING + const BuildStatusResponse_PUSH_FAILURE + const BuildStatusResponse_STARTED + const BuildStatusResponse_SUCCESS + func (BuildStatusResponse_BuildState) EnumDescriptor() ([]byte, []int) + func (x BuildStatusResponse_BuildState) String() string + type DiscoveryOptions struct + ConsulAddr string + NodeList []string + SelectionStrategy NodeSelectionStrategy + ServiceName string + UseConsul bool + type FakeClientBuilderFunc func() (*BuildEvent, error) + type FakeFuranClient struct + func NewFakeFuranClient(bf FakeClientBuilderFunc) (*FakeFuranClient, error) + func (ffc *FakeFuranClient) Build(ctx context.Context, out chan *BuildEvent, req *BuildRequest) (string, error) + type FuranClient struct + func NewFuranClient(opts *DiscoveryOptions, logger *log.Logger) (*FuranClient, error) + func (fc FuranClient) Build(ctx context.Context, out chan *BuildEvent, req *BuildRequest) (string, error) + type FuranExecutorClient interface + CancelBuild func(ctx context.Context, in *BuildCancelRequest, opts ...grpc.CallOption) (*BuildCancelResponse, error) + GetBuildStatus func(ctx context.Context, in *BuildStatusRequest, opts ...grpc.CallOption) (*BuildStatusResponse, error) + MonitorBuild func(ctx context.Context, in *BuildStatusRequest, opts ...grpc.CallOption) (FuranExecutor_MonitorBuildClient, error) + StartBuild func(ctx context.Context, in *BuildRequest, opts ...grpc.CallOption) (*BuildRequestResponse, error) + func NewFuranExecutorClient(cc *grpc.ClientConn) FuranExecutorClient + type FuranExecutorServer interface + CancelBuild func(context.Context, *BuildCancelRequest) (*BuildCancelResponse, error) + GetBuildStatus func(context.Context, *BuildStatusRequest) (*BuildStatusResponse, error) + MonitorBuild func(*BuildStatusRequest, FuranExecutor_MonitorBuildServer) error + StartBuild func(context.Context, *BuildRequest) (*BuildRequestResponse, error) + type FuranExecutor_MonitorBuildClient interface + Recv func() (*BuildEvent, error) + type FuranExecutor_MonitorBuildServer interface + Send func(*BuildEvent) error + type ImageBuildPusher interface + Build func(context.Context, chan *BuildEvent, *BuildRequest) (string, error) + type NodeSelectionStrategy int + const NetworkProximity + const RandomNodeSelection + func (i NodeSelectionStrategy) String() string + type PushDefinition struct + Registry *PushRegistryDefinition + S3 *PushS3Definition + func (*PushDefinition) Descriptor() ([]byte, []int) + func (*PushDefinition) ProtoMessage() + func (m *PushDefinition) GetRegistry() *PushRegistryDefinition + func (m *PushDefinition) GetS3() *PushS3Definition + func (m *PushDefinition) Reset() + func (m *PushDefinition) String() string + type PushRegistryDefinition struct + Repo string + func (*PushRegistryDefinition) Descriptor() ([]byte, []int) + func (*PushRegistryDefinition) ProtoMessage() + func (m *PushRegistryDefinition) GetRepo() string + func (m *PushRegistryDefinition) Reset() + func (m *PushRegistryDefinition) String() string + type PushS3Definition struct + Bucket string + KeyPrefix string + Region string + func (*PushS3Definition) Descriptor() ([]byte, []int) + func (*PushS3Definition) ProtoMessage() + func (m *PushS3Definition) GetBucket() string + func (m *PushS3Definition) GetKeyPrefix() string + func (m *PushS3Definition) GetRegion() string + func (m *PushS3Definition) Reset() + func (m *PushS3Definition) String() string
Go to main page