Versions in this module Expand all Collapse all v0 v0.8.105 Sep 17, 2019 v0.8.104 Sep 9, 2019 v0.8.103 Jul 23, 2019 v0.8.103-login-form Jul 24, 2019 v0.8.102 Jul 16, 2019 v0.8.101 Jul 10, 2019 v0.8.100 Jun 28, 2019 v0.8.100-kube Jul 3, 2019 v0.8.99 Jun 28, 2019 v0.8.98 Jun 27, 2019 v0.8.97 Jun 26, 2019 v0.8.96 Jun 19, 2019 v0.8.95 Jun 5, 2019 v0.8.95-bitbucket Jun 13, 2019 v0.8.94 May 30, 2019 v0.8.93 May 27, 2019 v0.8.92 Apr 24, 2019 Changes in this version + const LineExitCode + const LineMetadata + const LineProgress + const LineStderr + const LineStdout + var NoFilter = Filter + type Client struct + func NewClient(endpoint string, opts ...Option) (*Client, error) + func (t *Client) Close() error + func (t *Client) Done(c context.Context, id string, state State) error + func (t *Client) Extend(c context.Context, id string) error + func (t *Client) Init(c context.Context, id string, state State) error + func (t *Client) Log(c context.Context, id string, line *Line) error + func (t *Client) Next(c context.Context, f Filter) (*Pipeline, error) + func (t *Client) Update(c context.Context, id string, state State) error + func (t *Client) Upload(c context.Context, id string, file *File) error + func (t *Client) Wait(c context.Context, id string) error + type File struct + Data []byte + Meta map[string]string + Mime string + Name string + Proc string + Size int + Time int64 + type Filter struct + Expr string + Labels map[string]string + type Health interface + Check func(c context.Context) (bool, error) + func NewGrpcHealthClient(conn *grpc.ClientConn) Health + type Line struct + Out string + Pos int + Proc string + Time int64 + Type int + func (l *Line) String() string + type LineWriter struct + func NewLineWriter(peer Peer, id, name string, secret ...string) *LineWriter + func (w *LineWriter) Clear() + func (w *LineWriter) Lines() []*Line + func (w *LineWriter) Write(p []byte) (n int, err error) + type Option func(*Client) + func WithBackoff(d time.Duration) Option + func WithHeader(key, value string) Option + func WithRetryLimit(i int) Option + func WithToken(t string) Option + type Peer interface + Done func(c context.Context, id string, state State) error + Extend func(c context.Context, id string) error + Init func(c context.Context, id string, state State) error + Log func(c context.Context, id string, line *Line) error + Next func(c context.Context, f Filter) (*Pipeline, error) + Update func(c context.Context, id string, state State) error + Upload func(c context.Context, id string, file *File) error + Wait func(c context.Context, id string) error + func NewGrpcClient(conn *grpc.ClientConn) Peer + type Pipeline struct + Config *backend.Config + ID string + Timeout int64 + type Server struct + func NewServer(peer Peer) *Server + func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) + type State struct + Error string + ExitCode int + Exited bool + Finished int64 + Proc string + Started int64