yolo

package module
v2.10.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 29, 2020 License: Apache-2.0 Imports: 51 Imported by: 0

README


The Berty Project

Berty is a secure peer-to-peer messaging app that works with or without internet access, cellular data or trust in the network.

berty.tech • Twitter • GitHub

Documentation

Overview

Package yolo is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthYolo        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowYolo          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupYolo = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Artifact_Kind_name = map[int32]string{
	0: "UnknownKind",
	1: "IPA",
	2: "APK",
	3: "DMG",
}
View Source 
var Artifact_Kind_value = map[string]int32{
	"UnknownKind": 0,
	"IPA":         1,
	"APK":         2,
	"DMG":         3,
}
View Source 
var Artifact_State_name = map[int32]string{
	0: "UnknownState",
	1: "Finished",
	2: "New",
	3: "Error",
	4: "Deleted",
}
View Source 
var Artifact_State_value = map[string]int32{
	"UnknownState": 0,
	"Finished":     1,
	"New":          2,
	"Error":        3,
	"Deleted":      4,
}
View Source 
var Build_State_name = map[int32]string{
	0: "UnknownState",
	1: "Running",
	2: "Failed",
	3: "Passed",
	4: "Canceled",
	5: "Scheduled",
	6: "Skipped",
	7: "NotRun",
	8: "Timedout",
}
View Source 
var Build_State_value = map[string]int32{
	"UnknownState": 0,
	"Running":      1,
	"Failed":       2,
	"Passed":       3,
	"Canceled":     4,
	"Scheduled":    5,
	"Skipped":      6,
	"NotRun":       7,
	"Timedout":     8,
}
View Source 
var Driver_name = map[int32]string{
	0: "UnknownDriver",
	1: "Buildkite",
	2: "CircleCI",
	3: "Bintray",
}
View Source 
var Driver_value = map[string]int32{
	"UnknownDriver": 0,
	"Buildkite":     1,
	"CircleCI":      2,
	"Bintray":       3,
}

Functions

func BintrayWorker added in v2.10.0 

func BintrayWorker(ctx context.Context, db *cayley.Handle, btc *bintray.Client, schema *schema.Config, opts BintrayWorkerOpts) error

BintrayWorker goals is to manage the bintray update routine, it should try to support as much errors as possible by itself

func BuildkiteWorker 

func BuildkiteWorker(ctx context.Context, db *cayley.Handle, bkc *buildkite.Client, schema *schema.Config, opts BuildkiteWorkerOpts) error

BuildkiteWorker goals is to manage the buildkite update routine, it should try to support as much errors as possible by itself

func CircleciWorker added in v2.8.0 

func CircleciWorker(ctx context.Context, db *cayley.Handle, ccc *circleci.Client, schema *schema.Config, opts CircleciWorkerOpts) error

CircleciWorker goals is to manage the circleci update routine, it should try to support as much errors as possible by itself

func RegisterYoloServiceHandler 

func RegisterYoloServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterYoloServiceHandler registers the http handlers for service YoloService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterYoloServiceHandlerClient 

func RegisterYoloServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client YoloServiceClient) error

RegisterYoloServiceHandlerClient registers the http handlers for service YoloService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "YoloServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "YoloServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "YoloServiceClient" to call the correct interceptors.

func RegisterYoloServiceHandlerFromEndpoint 

func RegisterYoloServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterYoloServiceHandlerFromEndpoint is same as RegisterYoloServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterYoloServiceHandlerServer 

func RegisterYoloServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server YoloServiceServer) error

RegisterYoloServiceHandlerServer registers the http handlers for service YoloService to "mux". UnaryRPC :call YoloServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterYoloServiceServer 

func RegisterYoloServiceServer(s *grpc.Server, srv YoloServiceServer)

func SchemaConfig 

func SchemaConfig() *schema.Config

Types

type Artifact 

type Artifact struct {
	ID          github_com_cayleygraph_quad.IRI `protobuf:"bytes,1,opt,name=id,proto3,casttype=github.com/cayleygraph/quad.IRI" json:"id,omitempty" quad:"@id"`
	CreatedAt   *time.Time                      `` /* 129-byte string literal not displayed */
	FileSize    int64                           `protobuf:"varint,3,opt,name=file_size,json=fileSize,proto3" json:"file_size,omitempty" quad:"schema:file_size,optional"`
	LocalPath   string                          `protobuf:"bytes,4,opt,name=local_path,json=localPath,proto3" json:"local_path,omitempty" quad:"schema:local_path,optional"`
	DownloadURL string                          `` /* 130-byte string literal not displayed */
	MimeType    string                          `protobuf:"bytes,6,opt,name=mime_type,json=mimeType,proto3" json:"mime_type,omitempty" quad:"schema:mime_type,optional"`
	Sha1Sum     string                          `protobuf:"bytes,7,opt,name=sha1_sum,json=sha1Sum,proto3" json:"sha1_sum,omitempty" quad:"schema:sha1_sum,optional"`
	Sha256Sum   string                          `protobuf:"bytes,8,opt,name=sha256_sum,json=sha256Sum,proto3" json:"sha256_sum,omitempty" quad:"schema:sha256_sum,optional"`
	State       Artifact_State                  `protobuf:"varint,9,opt,name=state,proto3,enum=yolo.Artifact_State" json:"state,omitempty" quad:"schema:state,optional"`
	Kind        Artifact_Kind                   `protobuf:"varint,10,opt,name=kind,proto3,enum=yolo.Artifact_Kind" json:"kind,omitempty" quad:"schema:kind,optional"`
	Driver      Driver                          `protobuf:"varint,11,opt,name=driver,proto3,enum=yolo.Driver" json:"driver,omitempty" quad:"schema:driver,optional"`
	HasBuild    *Build                          `protobuf:"bytes,101,opt,name=has_build,json=hasBuild,proto3" json:"has_build,omitempty" quad:"schema:hasBuild,optional"`
}

func (*Artifact) Descriptor 

func (*Artifact) Descriptor() ([]byte, []int)

func (*Artifact) GetCreatedAt 

func (m *Artifact) GetCreatedAt() *time.Time

func (*Artifact) GetDownloadURL added in v2.10.0 

func (m *Artifact) GetDownloadURL() string

func (*Artifact) GetDriver added in v2.8.0 

func (m *Artifact) GetDriver() Driver

func (*Artifact) GetFileSize 

func (m *Artifact) GetFileSize() int64

func (*Artifact) GetHasBuild 

func (m *Artifact) GetHasBuild() *Build

func (*Artifact) GetID 

func (m *Artifact) GetID() github_com_cayleygraph_quad.IRI

func (*Artifact) GetKind 

func (m *Artifact) GetKind() Artifact_Kind

func (*Artifact) GetLocalPath 

func (m *Artifact) GetLocalPath() string

func (*Artifact) GetMimeType 

func (m *Artifact) GetMimeType() string

func (*Artifact) GetSha1Sum 

func (m *Artifact) GetSha1Sum() string

func (*Artifact) GetSha256Sum added in v2.10.0 

func (m *Artifact) GetSha256Sum() string

func (*Artifact) GetState 

func (m *Artifact) GetState() Artifact_State

func (*Artifact) Marshal 

func (m *Artifact) Marshal() (dAtA []byte, err error)

func (*Artifact) MarshalTo 

func (m *Artifact) MarshalTo(dAtA []byte) (int, error)

func (*Artifact) MarshalToSizedBuffer 

func (m *Artifact) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Artifact) ProtoMessage 

func (*Artifact) ProtoMessage()

func (*Artifact) Reset 

func (m *Artifact) Reset()

func (*Artifact) Size 

func (m *Artifact) Size() (n int)

func (*Artifact) String 

func (m *Artifact) String() string

func (*Artifact) Unmarshal 

func (m *Artifact) Unmarshal(dAtA []byte) error

func (*Artifact) XXX_DiscardUnknown 

func (m *Artifact) XXX_DiscardUnknown()

func (*Artifact) XXX_Marshal 

func (m *Artifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Artifact) XXX_Merge 

func (m *Artifact) XXX_Merge(src proto.Message)

func (*Artifact) XXX_Size 

func (m *Artifact) XXX_Size() int

func (*Artifact) XXX_Unmarshal 

func (m *Artifact) XXX_Unmarshal(b []byte) error

type Artifact_Kind 

type Artifact_Kind int32
const (
	Artifact_UnknownKind Artifact_Kind = 0
	Artifact_IPA         Artifact_Kind = 1
	Artifact_APK         Artifact_Kind = 2
	Artifact_DMG         Artifact_Kind = 3
)

func (Artifact_Kind) EnumDescriptor 

func (Artifact_Kind) EnumDescriptor() ([]byte, []int)

func (Artifact_Kind) String 

func (x Artifact_Kind) String() string

type Artifact_State 

type Artifact_State int32
const (
	Artifact_UnknownState Artifact_State = 0
	Artifact_Finished     Artifact_State = 1
	Artifact_New          Artifact_State = 2
	Artifact_Error        Artifact_State = 3
	Artifact_Deleted      Artifact_State = 4
)

func (Artifact_State) EnumDescriptor 

func (Artifact_State) EnumDescriptor() ([]byte, []int)

func (Artifact_State) String 

func (x Artifact_State) String() string

type Batch 

type Batch struct {
	Builds    []*Build    `protobuf:"bytes,1,rep,name=builds,proto3" json:"builds,omitempty"`
	Artifacts []*Artifact `protobuf:"bytes,2,rep,name=artifacts,proto3" json:"artifacts,omitempty"`
}

func (*Batch) Descriptor 

func (*Batch) Descriptor() ([]byte, []int)

func (*Batch) GetArtifacts 

func (m *Batch) GetArtifacts() []*Artifact

func (*Batch) GetBuilds 

func (m *Batch) GetBuilds() []*Build

func (*Batch) Marshal 

func (m *Batch) Marshal() (dAtA []byte, err error)

func (*Batch) MarshalTo 

func (m *Batch) MarshalTo(dAtA []byte) (int, error)

func (*Batch) MarshalToSizedBuffer 

func (m *Batch) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Batch) ProtoMessage 

func (*Batch) ProtoMessage()

func (*Batch) Reset 

func (m *Batch) Reset()

func (*Batch) Size 

func (m *Batch) Size() (n int)

func (*Batch) String 

func (m *Batch) String() string

func (*Batch) Unmarshal 

func (m *Batch) Unmarshal(dAtA []byte) error

func (*Batch) XXX_DiscardUnknown 

func (m *Batch) XXX_DiscardUnknown()

func (*Batch) XXX_Marshal 

func (m *Batch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Batch) XXX_Merge 

func (m *Batch) XXX_Merge(src proto.Message)

func (*Batch) XXX_Size 

func (m *Batch) XXX_Size() int

func (*Batch) XXX_Unmarshal 

func (m *Batch) XXX_Unmarshal(b []byte) error

type BintrayWorkerOpts added in v2.10.0 

type BintrayWorkerOpts struct {
	Logger    *zap.Logger
	MaxBuilds int
}

type Build 

type Build struct {
	ID           github_com_cayleygraph_quad.IRI `protobuf:"bytes,1,opt,name=id,proto3,casttype=github.com/cayleygraph/quad.IRI" json:"id,omitempty" quad:"@id"`
	CreatedAt    *time.Time                      `` /* 129-byte string literal not displayed */
	UpdatedAt    *time.Time                      `` /* 129-byte string literal not displayed */
	State        Build_State                     `protobuf:"varint,4,opt,name=state,proto3,enum=yolo.Build_State" json:"state,omitempty" quad:"schema:state,optional"`
	CompletedAt  *time.Time                      `` /* 137-byte string literal not displayed */
	Message      string                          `protobuf:"bytes,6,opt,name=message,proto3" json:"message,omitempty" quad:"schema:message,optional"`
	StartedAt    *time.Time                      `` /* 129-byte string literal not displayed */
	FinishedAt   *time.Time                      `` /* 133-byte string literal not displayed */
	Commit       string                          `protobuf:"bytes,9,opt,name=commit,proto3" json:"commit,omitempty" quad:"schema:commit,optional"`
	Branch       string                          `protobuf:"bytes,10,opt,name=branch,proto3" json:"branch,omitempty" quad:"schema:branch,optional"`
	Driver       Driver                          `protobuf:"varint,11,opt,name=driver,proto3,enum=yolo.Driver" json:"driver,omitempty" quad:"schema:driver,optional"`
	HasArtifacts []*Artifact                     `` /* 135-byte string literal not displayed */
}

func (*Build) Descriptor 

func (*Build) Descriptor() ([]byte, []int)

func (*Build) GetBranch 

func (m *Build) GetBranch() string

func (*Build) GetCommit 

func (m *Build) GetCommit() string

func (*Build) GetCompletedAt 

func (m *Build) GetCompletedAt() *time.Time

func (*Build) GetCreatedAt 

func (m *Build) GetCreatedAt() *time.Time

func (*Build) GetDriver added in v2.8.0 

func (m *Build) GetDriver() Driver

func (*Build) GetFinishedAt 

func (m *Build) GetFinishedAt() *time.Time

func (*Build) GetHasArtifacts added in v2.3.0 

func (m *Build) GetHasArtifacts() []*Artifact

func (*Build) GetID 

func (m *Build) GetID() github_com_cayleygraph_quad.IRI

func (*Build) GetMessage 

func (m *Build) GetMessage() string

func (*Build) GetStartedAt 

func (m *Build) GetStartedAt() *time.Time

func (*Build) GetState 

func (m *Build) GetState() Build_State

func (*Build) GetUpdatedAt 

func (m *Build) GetUpdatedAt() *time.Time

func (*Build) Marshal 

func (m *Build) Marshal() (dAtA []byte, err error)

func (*Build) MarshalTo 

func (m *Build) MarshalTo(dAtA []byte) (int, error)

func (*Build) MarshalToSizedBuffer 

func (m *Build) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Build) ProtoMessage 

func (*Build) ProtoMessage()

func (*Build) Reset 

func (m *Build) Reset()

func (*Build) Size 

func (m *Build) Size() (n int)

func (*Build) String 

func (m *Build) String() string

func (*Build) Unmarshal 

func (m *Build) Unmarshal(dAtA []byte) error

func (*Build) XXX_DiscardUnknown 

func (m *Build) XXX_DiscardUnknown()

func (*Build) XXX_Marshal 

func (m *Build) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Build) XXX_Merge 

func (m *Build) XXX_Merge(src proto.Message)

func (*Build) XXX_Size 

func (m *Build) XXX_Size() int

func (*Build) XXX_Unmarshal 

func (m *Build) XXX_Unmarshal(b []byte) error

type BuildList 

type BuildList struct {
}

func (*BuildList) Descriptor 

func (*BuildList) Descriptor() ([]byte, []int)

func (*BuildList) Marshal 

func (m *BuildList) Marshal() (dAtA []byte, err error)

func (*BuildList) MarshalTo 

func (m *BuildList) MarshalTo(dAtA []byte) (int, error)

func (*BuildList) MarshalToSizedBuffer 

func (m *BuildList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BuildList) ProtoMessage 

func (*BuildList) ProtoMessage()

func (*BuildList) Reset 

func (m *BuildList) Reset()

func (*BuildList) Size 

func (m *BuildList) Size() (n int)

func (*BuildList) String 

func (m *BuildList) String() string

func (*BuildList) Unmarshal 

func (m *BuildList) Unmarshal(dAtA []byte) error

func (*BuildList) XXX_DiscardUnknown 

func (m *BuildList) XXX_DiscardUnknown()

func (*BuildList) XXX_Marshal 

func (m *BuildList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BuildList) XXX_Merge 

func (m *BuildList) XXX_Merge(src proto.Message)

func (*BuildList) XXX_Size 

func (m *BuildList) XXX_Size() int

func (*BuildList) XXX_Unmarshal 

func (m *BuildList) XXX_Unmarshal(b []byte) error

type BuildList_Request 

type BuildList_Request struct {
	ArtifactKind Artifact_Kind `protobuf:"varint,1,opt,name=artifact_kind,json=artifactKind,proto3,enum=yolo.Artifact_Kind" json:"artifact_kind,omitempty"`
}

func (*BuildList_Request) Descriptor 

func (*BuildList_Request) Descriptor() ([]byte, []int)

func (*BuildList_Request) GetArtifactKind added in v2.3.0 

func (m *BuildList_Request) GetArtifactKind() Artifact_Kind

func (*BuildList_Request) Marshal 

func (m *BuildList_Request) Marshal() (dAtA []byte, err error)

func (*BuildList_Request) MarshalTo 

func (m *BuildList_Request) MarshalTo(dAtA []byte) (int, error)

func (*BuildList_Request) MarshalToSizedBuffer 

func (m *BuildList_Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BuildList_Request) ProtoMessage 

func (*BuildList_Request) ProtoMessage()

func (*BuildList_Request) Reset 

func (m *BuildList_Request) Reset()

func (*BuildList_Request) Size 

func (m *BuildList_Request) Size() (n int)

func (*BuildList_Request) String 

func (m *BuildList_Request) String() string

func (*BuildList_Request) Unmarshal 

func (m *BuildList_Request) Unmarshal(dAtA []byte) error

func (*BuildList_Request) XXX_DiscardUnknown 

func (m *BuildList_Request) XXX_DiscardUnknown()

func (*BuildList_Request) XXX_Marshal 

func (m *BuildList_Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BuildList_Request) XXX_Merge 

func (m *BuildList_Request) XXX_Merge(src proto.Message)

func (*BuildList_Request) XXX_Size 

func (m *BuildList_Request) XXX_Size() int

func (*BuildList_Request) XXX_Unmarshal 

func (m *BuildList_Request) XXX_Unmarshal(b []byte) error

type BuildList_Response 

type BuildList_Response struct {
	Builds []*Build `protobuf:"bytes,1,rep,name=builds,proto3" json:"builds,omitempty"`
}

func (*BuildList_Response) Descriptor 

func (*BuildList_Response) Descriptor() ([]byte, []int)

func (*BuildList_Response) GetBuilds 

func (m *BuildList_Response) GetBuilds() []*Build

func (*BuildList_Response) Marshal 

func (m *BuildList_Response) Marshal() (dAtA []byte, err error)

func (*BuildList_Response) MarshalTo 

func (m *BuildList_Response) MarshalTo(dAtA []byte) (int, error)

func (*BuildList_Response) MarshalToSizedBuffer 

func (m *BuildList_Response) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BuildList_Response) ProtoMessage 

func (*BuildList_Response) ProtoMessage()

func (*BuildList_Response) Reset 

func (m *BuildList_Response) Reset()

func (*BuildList_Response) Size 

func (m *BuildList_Response) Size() (n int)

func (*BuildList_Response) String 

func (m *BuildList_Response) String() string

func (*BuildList_Response) Unmarshal 

func (m *BuildList_Response) Unmarshal(dAtA []byte) error

func (*BuildList_Response) XXX_DiscardUnknown 

func (m *BuildList_Response) XXX_DiscardUnknown()

func (*BuildList_Response) XXX_Marshal 

func (m *BuildList_Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BuildList_Response) XXX_Merge 

func (m *BuildList_Response) XXX_Merge(src proto.Message)

func (*BuildList_Response) XXX_Size 

func (m *BuildList_Response) XXX_Size() int

func (*BuildList_Response) XXX_Unmarshal 

func (m *BuildList_Response) XXX_Unmarshal(b []byte) error

type Build_State 

type Build_State int32
const (
	Build_UnknownState Build_State = 0
	Build_Running      Build_State = 1
	Build_Failed       Build_State = 2
	Build_Passed       Build_State = 3
	Build_Canceled     Build_State = 4
	Build_Scheduled    Build_State = 5
	Build_Skipped      Build_State = 6
	Build_NotRun       Build_State = 7
	Build_Timedout     Build_State = 8
)

func (Build_State) EnumDescriptor 

func (Build_State) EnumDescriptor() ([]byte, []int)

func (Build_State) String 

func (x Build_State) String() string

type BuildkiteWorkerOpts 

type BuildkiteWorkerOpts struct {
	Logger    *zap.Logger
	MaxBuilds int
}

type CircleciWorkerOpts added in v2.8.0 

type CircleciWorkerOpts struct {
	Logger    *zap.Logger
	MaxBuilds int
}

type Driver 

type Driver int32
const (
	Driver_UnknownDriver Driver = 0
	Driver_Buildkite     Driver = 1
	Driver_CircleCI      Driver = 2
	Driver_Bintray       Driver = 3
)

func (Driver) EnumDescriptor 

func (Driver) EnumDescriptor() ([]byte, []int)

func (Driver) String 

func (x Driver) String() string

type Ping 

type Ping struct {
}

func (*Ping) Descriptor 

func (*Ping) Descriptor() ([]byte, []int)

func (*Ping) Marshal 

func (m *Ping) Marshal() (dAtA []byte, err error)

func (*Ping) MarshalTo 

func (m *Ping) MarshalTo(dAtA []byte) (int, error)

func (*Ping) MarshalToSizedBuffer 

func (m *Ping) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Ping) ProtoMessage 

func (*Ping) ProtoMessage()

func (*Ping) Reset 

func (m *Ping) Reset()

func (*Ping) Size 

func (m *Ping) Size() (n int)

func (*Ping) String 

func (m *Ping) String() string

func (*Ping) Unmarshal 

func (m *Ping) Unmarshal(dAtA []byte) error

func (*Ping) XXX_DiscardUnknown 

func (m *Ping) XXX_DiscardUnknown()

func (*Ping) XXX_Marshal 

func (m *Ping) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Ping) XXX_Merge 

func (m *Ping) XXX_Merge(src proto.Message)

func (*Ping) XXX_Size 

func (m *Ping) XXX_Size() int

func (*Ping) XXX_Unmarshal 

func (m *Ping) XXX_Unmarshal(b []byte) error

type Ping_Request 

type Ping_Request struct {
}

func (*Ping_Request) Descriptor 

func (*Ping_Request) Descriptor() ([]byte, []int)

func (*Ping_Request) Marshal 

func (m *Ping_Request) Marshal() (dAtA []byte, err error)

func (*Ping_Request) MarshalTo 

func (m *Ping_Request) MarshalTo(dAtA []byte) (int, error)

func (*Ping_Request) MarshalToSizedBuffer 

func (m *Ping_Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Ping_Request) ProtoMessage 

func (*Ping_Request) ProtoMessage()

func (*Ping_Request) Reset 

func (m *Ping_Request) Reset()

func (*Ping_Request) Size 

func (m *Ping_Request) Size() (n int)

func (*Ping_Request) String 

func (m *Ping_Request) String() string

func (*Ping_Request) Unmarshal 

func (m *Ping_Request) Unmarshal(dAtA []byte) error

func (*Ping_Request) XXX_DiscardUnknown 

func (m *Ping_Request) XXX_DiscardUnknown()

func (*Ping_Request) XXX_Marshal 

func (m *Ping_Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Ping_Request) XXX_Merge 

func (m *Ping_Request) XXX_Merge(src proto.Message)

func (*Ping_Request) XXX_Size 

func (m *Ping_Request) XXX_Size() int

func (*Ping_Request) XXX_Unmarshal 

func (m *Ping_Request) XXX_Unmarshal(b []byte) error

type Ping_Response 

type Ping_Response struct {
}

func (*Ping_Response) Descriptor 

func (*Ping_Response) Descriptor() ([]byte, []int)

func (*Ping_Response) Marshal 

func (m *Ping_Response) Marshal() (dAtA []byte, err error)

func (*Ping_Response) MarshalTo 

func (m *Ping_Response) MarshalTo(dAtA []byte) (int, error)

func (*Ping_Response) MarshalToSizedBuffer 

func (m *Ping_Response) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Ping_Response) ProtoMessage 

func (*Ping_Response) ProtoMessage()

func (*Ping_Response) Reset 

func (m *Ping_Response) Reset()

func (*Ping_Response) Size 

func (m *Ping_Response) Size() (n int)

func (*Ping_Response) String 

func (m *Ping_Response) String() string

func (*Ping_Response) Unmarshal 

func (m *Ping_Response) Unmarshal(dAtA []byte) error

func (*Ping_Response) XXX_DiscardUnknown 

func (m *Ping_Response) XXX_DiscardUnknown()

func (*Ping_Response) XXX_Marshal 

func (m *Ping_Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Ping_Response) XXX_Merge 

func (m *Ping_Response) XXX_Merge(src proto.Message)

func (*Ping_Response) XXX_Size 

func (m *Ping_Response) XXX_Size() int

func (*Ping_Response) XXX_Unmarshal 

func (m *Ping_Response) XXX_Unmarshal(b []byte) error

type Server 

type Server struct {
	// contains filtered or unexported fields
}

func NewServer 

func NewServer(ctx context.Context, svc Service, opts ServerOpts) (*Server, error)

func (*Server) Start 

func (srv *Server) Start() error

func (*Server) Stop 

func (srv *Server) Stop()

type ServerOpts 

type ServerOpts struct {
	Logger             *zap.Logger
	HTTPBind           string
	GRPCBind           string
	CORSAllowedOrigins string
	RequestTimeout     time.Duration
	ShutdownTimeout    time.Duration
	BasicAuth          string
	Realm              string
}

type Service 

type Service interface {
	YoloServiceServer
	PlistGenerator(w http.ResponseWriter, r *http.Request)
	ArtifactDownloader(w http.ResponseWriter, r *http.Request)
}

func NewService 

func NewService(db *cayley.Handle, schema *schema.Config, opts ServiceOpts) Service

type ServiceOpts 

type ServiceOpts struct {
	BuildkiteClient *buildkite.Client
	CircleciClient  *circleci.Client
	BintrayClient   *bintray.Client
	Logger          *zap.Logger
}

type Status 

type Status struct {
}

func (*Status) Descriptor 

func (*Status) Descriptor() ([]byte, []int)

func (*Status) Marshal 

func (m *Status) Marshal() (dAtA []byte, err error)

func (*Status) MarshalTo 

func (m *Status) MarshalTo(dAtA []byte) (int, error)

func (*Status) MarshalToSizedBuffer 

func (m *Status) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) Reset 

func (m *Status) Reset()

func (*Status) Size 

func (m *Status) Size() (n int)

func (*Status) String 

func (m *Status) String() string

func (*Status) Unmarshal 

func (m *Status) Unmarshal(dAtA []byte) error

func (*Status) XXX_DiscardUnknown 

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal 

func (m *Status) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Status) XXX_Merge 

func (m *Status) XXX_Merge(src proto.Message)

func (*Status) XXX_Size 

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal 

func (m *Status) XXX_Unmarshal(b []byte) error

type Status_Request 

type Status_Request struct {
}

func (*Status_Request) Descriptor 

func (*Status_Request) Descriptor() ([]byte, []int)

func (*Status_Request) Marshal 

func (m *Status_Request) Marshal() (dAtA []byte, err error)

func (*Status_Request) MarshalTo 

func (m *Status_Request) MarshalTo(dAtA []byte) (int, error)

func (*Status_Request) MarshalToSizedBuffer 

func (m *Status_Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Status_Request) ProtoMessage 

func (*Status_Request) ProtoMessage()

func (*Status_Request) Reset 

func (m *Status_Request) Reset()

func (*Status_Request) Size 

func (m *Status_Request) Size() (n int)

func (*Status_Request) String 

func (m *Status_Request) String() string

func (*Status_Request) Unmarshal 

func (m *Status_Request) Unmarshal(dAtA []byte) error

func (*Status_Request) XXX_DiscardUnknown 

func (m *Status_Request) XXX_DiscardUnknown()

func (*Status_Request) XXX_Marshal 

func (m *Status_Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Status_Request) XXX_Merge 

func (m *Status_Request) XXX_Merge(src proto.Message)

func (*Status_Request) XXX_Size 

func (m *Status_Request) XXX_Size() int

func (*Status_Request) XXX_Unmarshal 

func (m *Status_Request) XXX_Unmarshal(b []byte) error

type Status_Response 

type Status_Response struct {
	Uptime  int32  `protobuf:"varint,1,opt,name=uptime,proto3" json:"uptime,omitempty"`
	DbErr   string `protobuf:"bytes,2,opt,name=db_err,json=dbErr,proto3" json:"db_err,omitempty"`
	DbNodes int64  `protobuf:"varint,3,opt,name=db_nodes,json=dbNodes,proto3" json:"db_nodes,omitempty"`
	DbQuads int64  `protobuf:"varint,4,opt,name=db_quads,json=dbQuads,proto3" json:"db_quads,omitempty"`
}

func (*Status_Response) Descriptor 

func (*Status_Response) Descriptor() ([]byte, []int)

func (*Status_Response) GetDbErr 

func (m *Status_Response) GetDbErr() string

func (*Status_Response) GetDbNodes 

func (m *Status_Response) GetDbNodes() int64

func (*Status_Response) GetDbQuads 

func (m *Status_Response) GetDbQuads() int64

func (*Status_Response) GetUptime 

func (m *Status_Response) GetUptime() int32

func (*Status_Response) Marshal 

func (m *Status_Response) Marshal() (dAtA []byte, err error)

func (*Status_Response) MarshalTo 

func (m *Status_Response) MarshalTo(dAtA []byte) (int, error)

func (*Status_Response) MarshalToSizedBuffer 

func (m *Status_Response) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Status_Response) ProtoMessage 

func (*Status_Response) ProtoMessage()

func (*Status_Response) Reset 

func (m *Status_Response) Reset()

func (*Status_Response) Size 

func (m *Status_Response) Size() (n int)

func (*Status_Response) String 

func (m *Status_Response) String() string

func (*Status_Response) Unmarshal 

func (m *Status_Response) Unmarshal(dAtA []byte) error

func (*Status_Response) XXX_DiscardUnknown 

func (m *Status_Response) XXX_DiscardUnknown()

func (*Status_Response) XXX_Marshal 

func (m *Status_Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Status_Response) XXX_Merge 

func (m *Status_Response) XXX_Merge(src proto.Message)

func (*Status_Response) XXX_Size 

func (m *Status_Response) XXX_Size() int

func (*Status_Response) XXX_Unmarshal 

func (m *Status_Response) XXX_Unmarshal(b []byte) error

type UnimplementedYoloServiceServer 

type UnimplementedYoloServiceServer struct {
}

UnimplementedYoloServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedYoloServiceServer) BuildList 

func (*UnimplementedYoloServiceServer) BuildList(ctx context.Context, req *BuildList_Request) (*BuildList_Response, error)

func (*UnimplementedYoloServiceServer) Ping 

func (*UnimplementedYoloServiceServer) Ping(ctx context.Context, req *Ping_Request) (*Ping_Response, error)

func (*UnimplementedYoloServiceServer) Status 

func (*UnimplementedYoloServiceServer) Status(ctx context.Context, req *Status_Request) (*Status_Response, error)

type YoloServiceClient 

type YoloServiceClient interface {
	Ping(ctx context.Context, in *Ping_Request, opts ...grpc.CallOption) (*Ping_Response, error)
	Status(ctx context.Context, in *Status_Request, opts ...grpc.CallOption) (*Status_Response, error)
	BuildList(ctx context.Context, in *BuildList_Request, opts ...grpc.CallOption) (*BuildList_Response, error)
}

YoloServiceClient is the client API for YoloService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewYoloServiceClient 

func NewYoloServiceClient(cc *grpc.ClientConn) YoloServiceClient

type YoloServiceServer 

type YoloServiceServer interface {
	Ping(context.Context, *Ping_Request) (*Ping_Response, error)
	Status(context.Context, *Status_Request) (*Status_Response, error)
	BuildList(context.Context, *BuildList_Request) (*BuildList_Response, error)
}

YoloServiceServer is the server API for YoloService service.

Source Files

View all Source files

Directories

Path Synopsis
cmd
yolo
pkg
bintray
plistgen

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.