yolo

package module
v2.7.0 Latest Latest
Warning

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

 Go to latest Published: Feb 13, 2020 License: Apache-2.0 Imports: 47 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",
}
View Source 
var Artifact_Kind_value = map[string]int32{
	"UnknownKind": 0,
	"IPA":         1,
	"APK":         2,
}
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",
}
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,
}
View Source 
var Driver_name = map[int32]string{
	0: "UnknownDriver",
	1: "GitHub",
	2: "Buildkite",
}
View Source 
var Driver_value = map[string]int32{
	"UnknownDriver": 0,
	"GitHub":        1,
	"Buildkite":     2,
}

Functions

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 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"`
	State       Artifact_State                  `protobuf:"varint,8,opt,name=state,proto3,enum=yolo.Artifact_State" json:"state,omitempty" quad:"schema:state,optional"`
	Kind        Artifact_Kind                   `protobuf:"varint,9,opt,name=kind,proto3,enum=yolo.Artifact_Kind" json:"kind,omitempty" quad:"schema:kind,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 

func (m *Artifact) GetDownloadUrl() string

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) 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
)

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 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"`
	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) 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
)

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
	MaxPages int
}

type Driver 

type Driver int32
const (
	Driver_UnknownDriver Driver = 0
	Driver_GitHub        Driver = 1
	Driver_Buildkite     Driver = 2
)

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
	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
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.