v1

package
v0.0.0-...-bd7fa6f Latest Latest
Warning

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

Go to latest
Published: Oct 19, 2019 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Overview

Package v1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterAuthV1Handler

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

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

func RegisterAuthV1HandlerClient

func RegisterAuthV1HandlerClient(ctx context.Context, mux *runtime.ServeMux, client AuthV1Client) error

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

func RegisterAuthV1HandlerFromEndpoint

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

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

func RegisterAuthV1HandlerServer

func RegisterAuthV1HandlerServer(ctx context.Context, mux *runtime.ServeMux, server AuthV1Server) error

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

func RegisterAuthV1Server

func RegisterAuthV1Server(s *grpc.Server, srv AuthV1Server)

func RegisterProjectsV1Handler

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

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

func RegisterProjectsV1HandlerClient

func RegisterProjectsV1HandlerClient(ctx context.Context, mux *runtime.ServeMux, client ProjectsV1Client) error

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

func RegisterProjectsV1HandlerFromEndpoint

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

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

func RegisterProjectsV1HandlerServer

func RegisterProjectsV1HandlerServer(ctx context.Context, mux *runtime.ServeMux, server ProjectsV1Server) error

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

func RegisterProjectsV1Server

func RegisterProjectsV1Server(s *grpc.Server, srv ProjectsV1Server)

func RegisterRunsV1Handler

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

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

func RegisterRunsV1HandlerClient

func RegisterRunsV1HandlerClient(ctx context.Context, mux *runtime.ServeMux, client RunsV1Client) error

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

func RegisterRunsV1HandlerFromEndpoint

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

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

func RegisterRunsV1HandlerServer

func RegisterRunsV1HandlerServer(ctx context.Context, mux *runtime.ServeMux, server RunsV1Server) error

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

func RegisterRunsV1Server

func RegisterRunsV1Server(s *grpc.Server, srv RunsV1Server)

func RegisterUsersV1Handler

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

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

func RegisterUsersV1HandlerClient

func RegisterUsersV1HandlerClient(ctx context.Context, mux *runtime.ServeMux, client UsersV1Client) error

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

func RegisterUsersV1HandlerFromEndpoint

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

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

func RegisterUsersV1HandlerServer

func RegisterUsersV1HandlerServer(ctx context.Context, mux *runtime.ServeMux, server UsersV1Server) error

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

func RegisterUsersV1Server

func RegisterUsersV1Server(s *grpc.Server, srv UsersV1Server)

func RegisterVersionsV1Handler

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

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

func RegisterVersionsV1HandlerClient

func RegisterVersionsV1HandlerClient(ctx context.Context, mux *runtime.ServeMux, client VersionsV1Client) error

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

func RegisterVersionsV1HandlerFromEndpoint

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

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

func RegisterVersionsV1HandlerServer

func RegisterVersionsV1HandlerServer(ctx context.Context, mux *runtime.ServeMux, server VersionsV1Server) error

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

func RegisterVersionsV1Server

func RegisterVersionsV1Server(s *grpc.Server, srv VersionsV1Server)

Types

type Auth

type Auth struct {
	// UUID
	Token                string   `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Auth specification

func (*Auth) Descriptor

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

func (*Auth) GetToken

func (m *Auth) GetToken() string

func (*Auth) ProtoMessage

func (*Auth) ProtoMessage()

func (*Auth) Reset

func (m *Auth) Reset()

func (*Auth) String

func (m *Auth) String() string

func (*Auth) XXX_DiscardUnknown

func (m *Auth) XXX_DiscardUnknown()

func (*Auth) XXX_Marshal

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

func (*Auth) XXX_Merge

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

func (*Auth) XXX_Size

func (m *Auth) XXX_Size() int

func (*Auth) XXX_Unmarshal

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

type AuthV1Client

type AuthV1Client interface {
	// Login
	Login(ctx context.Context, in *CredsBodyRequest, opts ...grpc.CallOption) (*Auth, error)
}

AuthV1Client is the client API for AuthV1 service.

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

func NewAuthV1Client

func NewAuthV1Client(cc *grpc.ClientConn) AuthV1Client

type AuthV1Server

type AuthV1Server interface {
	// Login
	Login(context.Context, *CredsBodyRequest) (*Auth, error)
}

AuthV1Server is the server API for AuthV1 service.

type CodeRefBodyRequest

type CodeRefBodyRequest struct {
	// Owner of the code ref
	Entity *EntityResourceRequest `protobuf:"bytes,1,opt,name=entity,proto3" json:"entity,omitempty"`
	// Code ref object
	CodeReference        *CodeReference `protobuf:"bytes,2,opt,name=code_reference,json=codeReference,proto3" json:"code_reference,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

Request data to create/update CodeReference

func (*CodeRefBodyRequest) Descriptor

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

func (*CodeRefBodyRequest) GetCodeReference

func (m *CodeRefBodyRequest) GetCodeReference() *CodeReference

func (*CodeRefBodyRequest) GetEntity

func (m *CodeRefBodyRequest) GetEntity() *EntityResourceRequest

func (*CodeRefBodyRequest) ProtoMessage

func (*CodeRefBodyRequest) ProtoMessage()

func (*CodeRefBodyRequest) Reset

func (m *CodeRefBodyRequest) Reset()

func (*CodeRefBodyRequest) String

func (m *CodeRefBodyRequest) String() string

func (*CodeRefBodyRequest) XXX_DiscardUnknown

func (m *CodeRefBodyRequest) XXX_DiscardUnknown()

func (*CodeRefBodyRequest) XXX_Marshal

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

func (*CodeRefBodyRequest) XXX_Merge

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

func (*CodeRefBodyRequest) XXX_Size

func (m *CodeRefBodyRequest) XXX_Size() int

func (*CodeRefBodyRequest) XXX_Unmarshal

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

type CodeReference

type CodeReference struct {
	// UUID
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// Optional commit of the code ref
	Commit string `protobuf:"bytes,2,opt,name=commit,proto3" json:"commit,omitempty"`
	// Optional head of the code ref
	UpdatedAt *timestamp.Timestamp `protobuf:"bytes,3,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// Optional branch of the code ref
	Status string `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	// Optional git url for this code ref
	GitUrl string `protobuf:"bytes,5,opt,name=git_url,json=gitUrl,proto3" json:"git_url,omitempty"`
	// Optional whether this code ref is dirty
	IsDirty              bool     `protobuf:"varint,6,opt,name=is_dirty,json=isDirty,proto3" json:"is_dirty,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Code Reference specification

func (*CodeReference) Descriptor

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

func (*CodeReference) GetCommit

func (m *CodeReference) GetCommit() string

func (*CodeReference) GetGitUrl

func (m *CodeReference) GetGitUrl() string

func (*CodeReference) GetIsDirty

func (m *CodeReference) GetIsDirty() bool

func (*CodeReference) GetStatus

func (m *CodeReference) GetStatus() string

func (*CodeReference) GetUpdatedAt

func (m *CodeReference) GetUpdatedAt() *timestamp.Timestamp

func (*CodeReference) GetUuid

func (m *CodeReference) GetUuid() string

func (*CodeReference) ProtoMessage

func (*CodeReference) ProtoMessage()

func (*CodeReference) Reset

func (m *CodeReference) Reset()

func (*CodeReference) String

func (m *CodeReference) String() string

func (*CodeReference) XXX_DiscardUnknown

func (m *CodeReference) XXX_DiscardUnknown()

func (*CodeReference) XXX_Marshal

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

func (*CodeReference) XXX_Merge

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

func (*CodeReference) XXX_Size

func (m *CodeReference) XXX_Size() int

func (*CodeReference) XXX_Unmarshal

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

type CredsBodyRequest

type CredsBodyRequest struct {
	// User username or email
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	// Project where the experiement will be assigned
	Password             string   `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Login

func (*CredsBodyRequest) Descriptor

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

func (*CredsBodyRequest) GetPassword

func (m *CredsBodyRequest) GetPassword() string

func (*CredsBodyRequest) GetUsername

func (m *CredsBodyRequest) GetUsername() string

func (*CredsBodyRequest) ProtoMessage

func (*CredsBodyRequest) ProtoMessage()

func (*CredsBodyRequest) Reset

func (m *CredsBodyRequest) Reset()

func (*CredsBodyRequest) String

func (m *CredsBodyRequest) String() string

func (*CredsBodyRequest) XXX_DiscardUnknown

func (m *CredsBodyRequest) XXX_DiscardUnknown()

func (*CredsBodyRequest) XXX_Marshal

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

func (*CredsBodyRequest) XXX_Merge

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

func (*CredsBodyRequest) XXX_Size

func (m *CredsBodyRequest) XXX_Size() int

func (*CredsBodyRequest) XXX_Unmarshal

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

type EntityResourceRequest

type EntityResourceRequest struct {
	// Owner of the namespace
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	// Project where the experiement will be assigned
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// Unique integer identifier of the entity
	Uuid                 string   `protobuf:"bytes,3,opt,name=uuid,proto3" json:"uuid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request data to get/delete entity

func (*EntityResourceRequest) Descriptor

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

func (*EntityResourceRequest) GetOwner

func (m *EntityResourceRequest) GetOwner() string

func (*EntityResourceRequest) GetProject

func (m *EntityResourceRequest) GetProject() string

func (*EntityResourceRequest) GetUuid

func (m *EntityResourceRequest) GetUuid() string

func (*EntityResourceRequest) ProtoMessage

func (*EntityResourceRequest) ProtoMessage()

func (*EntityResourceRequest) Reset

func (m *EntityResourceRequest) Reset()

func (*EntityResourceRequest) String

func (m *EntityResourceRequest) String() string

func (*EntityResourceRequest) XXX_DiscardUnknown

func (m *EntityResourceRequest) XXX_DiscardUnknown()

func (*EntityResourceRequest) XXX_Marshal

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

func (*EntityResourceRequest) XXX_Merge

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

func (*EntityResourceRequest) XXX_Size

func (m *EntityResourceRequest) XXX_Size() int

func (*EntityResourceRequest) XXX_Unmarshal

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

type EntityRunBodyRequest

type EntityRunBodyRequest struct {
	// Enitity Run
	Entity *EntityResourceRequest `protobuf:"bytes,1,opt,name=entity,proto3" json:"entity,omitempty"`
	// Run object
	Run                  *Run     `protobuf:"bytes,2,opt,name=run,proto3" json:"run,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request data to update run

func (*EntityRunBodyRequest) Descriptor

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

func (*EntityRunBodyRequest) GetEntity

func (*EntityRunBodyRequest) GetRun

func (m *EntityRunBodyRequest) GetRun() *Run

func (*EntityRunBodyRequest) ProtoMessage

func (*EntityRunBodyRequest) ProtoMessage()

func (*EntityRunBodyRequest) Reset

func (m *EntityRunBodyRequest) Reset()

func (*EntityRunBodyRequest) String

func (m *EntityRunBodyRequest) String() string

func (*EntityRunBodyRequest) XXX_DiscardUnknown

func (m *EntityRunBodyRequest) XXX_DiscardUnknown()

func (*EntityRunBodyRequest) XXX_Marshal

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

func (*EntityRunBodyRequest) XXX_Merge

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

func (*EntityRunBodyRequest) XXX_Size

func (m *EntityRunBodyRequest) XXX_Size() int

func (*EntityRunBodyRequest) XXX_Unmarshal

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

type EntityStatusBodyRequest

type EntityStatusBodyRequest struct {
	// Owner of the namespace
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	// Project where the experiement will be assigned
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// Unique integer identifier of the entity
	Uuid string `protobuf:"bytes,3,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// Status to set
	Status               *Status  `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request data to create/update entity status

func (*EntityStatusBodyRequest) Descriptor

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

func (*EntityStatusBodyRequest) GetOwner

func (m *EntityStatusBodyRequest) GetOwner() string

func (*EntityStatusBodyRequest) GetProject

func (m *EntityStatusBodyRequest) GetProject() string

func (*EntityStatusBodyRequest) GetStatus

func (m *EntityStatusBodyRequest) GetStatus() *Status

func (*EntityStatusBodyRequest) GetUuid

func (m *EntityStatusBodyRequest) GetUuid() string

func (*EntityStatusBodyRequest) ProtoMessage

func (*EntityStatusBodyRequest) ProtoMessage()

func (*EntityStatusBodyRequest) Reset

func (m *EntityStatusBodyRequest) Reset()

func (*EntityStatusBodyRequest) String

func (m *EntityStatusBodyRequest) String() string

func (*EntityStatusBodyRequest) XXX_DiscardUnknown

func (m *EntityStatusBodyRequest) XXX_DiscardUnknown()

func (*EntityStatusBodyRequest) XXX_Marshal

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

func (*EntityStatusBodyRequest) XXX_Merge

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

func (*EntityStatusBodyRequest) XXX_Size

func (m *EntityStatusBodyRequest) XXX_Size() int

func (*EntityStatusBodyRequest) XXX_Unmarshal

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

type KV

type KV struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                *any.Any `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KV) Descriptor

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

func (*KV) GetKey

func (m *KV) GetKey() string

func (*KV) GetValue

func (m *KV) GetValue() *any.Any

func (*KV) ProtoMessage

func (*KV) ProtoMessage()

func (*KV) Reset

func (m *KV) Reset()

func (*KV) String

func (m *KV) String() string

func (*KV) XXX_DiscardUnknown

func (m *KV) XXX_DiscardUnknown()

func (*KV) XXX_Marshal

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

func (*KV) XXX_Merge

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

func (*KV) XXX_Size

func (m *KV) XXX_Size() int

func (*KV) XXX_Unmarshal

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

type ListCodeRefsResponse

type ListCodeRefsResponse struct {
	// Count of the entities
	Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// List of all entities
	Results []*CodeReference `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"`
	// Previous page
	Previous string `protobuf:"bytes,3,opt,name=previous,proto3" json:"previous,omitempty"`
	// Next page
	Next                 string   `protobuf:"bytes,4,opt,name=next,proto3" json:"next,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Contains list runs

func (*ListCodeRefsResponse) Descriptor

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

func (*ListCodeRefsResponse) GetCount

func (m *ListCodeRefsResponse) GetCount() int32

func (*ListCodeRefsResponse) GetNext

func (m *ListCodeRefsResponse) GetNext() string

func (*ListCodeRefsResponse) GetPrevious

func (m *ListCodeRefsResponse) GetPrevious() string

func (*ListCodeRefsResponse) GetResults

func (m *ListCodeRefsResponse) GetResults() []*CodeReference

func (*ListCodeRefsResponse) ProtoMessage

func (*ListCodeRefsResponse) ProtoMessage()

func (*ListCodeRefsResponse) Reset

func (m *ListCodeRefsResponse) Reset()

func (*ListCodeRefsResponse) String

func (m *ListCodeRefsResponse) String() string

func (*ListCodeRefsResponse) XXX_DiscardUnknown

func (m *ListCodeRefsResponse) XXX_DiscardUnknown()

func (*ListCodeRefsResponse) XXX_Marshal

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

func (*ListCodeRefsResponse) XXX_Merge

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

func (*ListCodeRefsResponse) XXX_Size

func (m *ListCodeRefsResponse) XXX_Size() int

func (*ListCodeRefsResponse) XXX_Unmarshal

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

type ListProjectsResponse

type ListProjectsResponse struct {
	// Count of the entities
	Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// List of all entities
	Results []*Project `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"`
	// Previous page
	Previous string `protobuf:"bytes,3,opt,name=previous,proto3" json:"previous,omitempty"`
	// Next page
	Next                 string   `protobuf:"bytes,4,opt,name=next,proto3" json:"next,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Contains list projects

func (*ListProjectsResponse) Descriptor

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

func (*ListProjectsResponse) GetCount

func (m *ListProjectsResponse) GetCount() int32

func (*ListProjectsResponse) GetNext

func (m *ListProjectsResponse) GetNext() string

func (*ListProjectsResponse) GetPrevious

func (m *ListProjectsResponse) GetPrevious() string

func (*ListProjectsResponse) GetResults

func (m *ListProjectsResponse) GetResults() []*Project

func (*ListProjectsResponse) ProtoMessage

func (*ListProjectsResponse) ProtoMessage()

func (*ListProjectsResponse) Reset

func (m *ListProjectsResponse) Reset()

func (*ListProjectsResponse) String

func (m *ListProjectsResponse) String() string

func (*ListProjectsResponse) XXX_DiscardUnknown

func (m *ListProjectsResponse) XXX_DiscardUnknown()

func (*ListProjectsResponse) XXX_Marshal

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

func (*ListProjectsResponse) XXX_Merge

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

func (*ListProjectsResponse) XXX_Size

func (m *ListProjectsResponse) XXX_Size() int

func (*ListProjectsResponse) XXX_Unmarshal

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

type ListRunsResponse

type ListRunsResponse struct {
	// Count of the entities
	Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// List of all entities
	Results []*Run `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"`
	// Previous page
	Previous string `protobuf:"bytes,3,opt,name=previous,proto3" json:"previous,omitempty"`
	// Next page
	Next                 string   `protobuf:"bytes,4,opt,name=next,proto3" json:"next,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Contains list runs

func (*ListRunsResponse) Descriptor

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

func (*ListRunsResponse) GetCount

func (m *ListRunsResponse) GetCount() int32

func (*ListRunsResponse) GetNext

func (m *ListRunsResponse) GetNext() string

func (*ListRunsResponse) GetPrevious

func (m *ListRunsResponse) GetPrevious() string

func (*ListRunsResponse) GetResults

func (m *ListRunsResponse) GetResults() []*Run

func (*ListRunsResponse) ProtoMessage

func (*ListRunsResponse) ProtoMessage()

func (*ListRunsResponse) Reset

func (m *ListRunsResponse) Reset()

func (*ListRunsResponse) String

func (m *ListRunsResponse) String() string

func (*ListRunsResponse) XXX_DiscardUnknown

func (m *ListRunsResponse) XXX_DiscardUnknown()

func (*ListRunsResponse) XXX_Marshal

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

func (*ListRunsResponse) XXX_Merge

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

func (*ListRunsResponse) XXX_Size

func (m *ListRunsResponse) XXX_Size() int

func (*ListRunsResponse) XXX_Unmarshal

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

type LogHandler

type LogHandler struct {
	Dsn                  string   `protobuf:"bytes,1,opt,name=dsn,proto3" json:"dsn,omitempty"`
	Environment          string   `protobuf:"bytes,2,opt,name=environment,proto3" json:"environment,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogHandler) Descriptor

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

func (*LogHandler) GetDsn

func (m *LogHandler) GetDsn() string

func (*LogHandler) GetEnvironment

func (m *LogHandler) GetEnvironment() string

func (*LogHandler) ProtoMessage

func (*LogHandler) ProtoMessage()

func (*LogHandler) Reset

func (m *LogHandler) Reset()

func (*LogHandler) String

func (m *LogHandler) String() string

func (*LogHandler) XXX_DiscardUnknown

func (m *LogHandler) XXX_DiscardUnknown()

func (*LogHandler) XXX_Marshal

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

func (*LogHandler) XXX_Merge

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

func (*LogHandler) XXX_Size

func (m *LogHandler) XXX_Size() int

func (*LogHandler) XXX_Unmarshal

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

type OwnerResouceListRequest

type OwnerResouceListRequest struct {
	// Owner of the namespace
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	// Pagination offset
	Offset int32 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// Limit size
	Limit int32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// Sort to order the search
	Sort string `protobuf:"bytes,4,opt,name=sort,proto3" json:"sort,omitempty"`
	// Query filter the search search
	Query                string   `protobuf:"bytes,5,opt,name=query,proto3" json:"query,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request list data with owner namespace

func (*OwnerResouceListRequest) Descriptor

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

func (*OwnerResouceListRequest) GetLimit

func (m *OwnerResouceListRequest) GetLimit() int32

func (*OwnerResouceListRequest) GetOffset

func (m *OwnerResouceListRequest) GetOffset() int32

func (*OwnerResouceListRequest) GetOwner

func (m *OwnerResouceListRequest) GetOwner() string

func (*OwnerResouceListRequest) GetQuery

func (m *OwnerResouceListRequest) GetQuery() string

func (*OwnerResouceListRequest) GetSort

func (m *OwnerResouceListRequest) GetSort() string

func (*OwnerResouceListRequest) ProtoMessage

func (*OwnerResouceListRequest) ProtoMessage()

func (*OwnerResouceListRequest) Reset

func (m *OwnerResouceListRequest) Reset()

func (*OwnerResouceListRequest) String

func (m *OwnerResouceListRequest) String() string

func (*OwnerResouceListRequest) XXX_DiscardUnknown

func (m *OwnerResouceListRequest) XXX_DiscardUnknown()

func (*OwnerResouceListRequest) XXX_Marshal

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

func (*OwnerResouceListRequest) XXX_Merge

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

func (*OwnerResouceListRequest) XXX_Size

func (m *OwnerResouceListRequest) XXX_Size() int

func (*OwnerResouceListRequest) XXX_Unmarshal

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

type OwnerResourceRequest

type OwnerResourceRequest struct {
	// Owner of the namespace
	Owner                string   `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request data with owner namespace

func (*OwnerResourceRequest) Descriptor

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

func (*OwnerResourceRequest) GetOwner

func (m *OwnerResourceRequest) GetOwner() string

func (*OwnerResourceRequest) ProtoMessage

func (*OwnerResourceRequest) ProtoMessage()

func (*OwnerResourceRequest) Reset

func (m *OwnerResourceRequest) Reset()

func (*OwnerResourceRequest) String

func (m *OwnerResourceRequest) String() string

func (*OwnerResourceRequest) XXX_DiscardUnknown

func (m *OwnerResourceRequest) XXX_DiscardUnknown()

func (*OwnerResourceRequest) XXX_Marshal

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

func (*OwnerResourceRequest) XXX_Merge

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

func (*OwnerResourceRequest) XXX_Size

func (m *OwnerResourceRequest) XXX_Size() int

func (*OwnerResourceRequest) XXX_Unmarshal

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

type Project

type Project struct {
	// UUID
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// Required name of user who created this entity
	User string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	// Required name
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Optional description
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// Optional time when the entityt was created
	CreatedAt *timestamp.Timestamp `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Optional last time the entity was updated
	UpdatedAt *timestamp.Timestamp `protobuf:"bytes,6,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// Optional flag to tell if this project is public
	IsPublic string `protobuf:"bytes,7,opt,name=is_public,json=isPublic,proto3" json:"is_public,omitempty"`
	// Optional if this entity was bookmarked
	Bookmarked           bool     `protobuf:"varint,8,opt,name=bookmarked,proto3" json:"bookmarked,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Project specification

func (*Project) Descriptor

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

func (*Project) GetBookmarked

func (m *Project) GetBookmarked() bool

func (*Project) GetCreatedAt

func (m *Project) GetCreatedAt() *timestamp.Timestamp

func (*Project) GetDescription

func (m *Project) GetDescription() string

func (*Project) GetIsPublic

func (m *Project) GetIsPublic() string

func (*Project) GetName

func (m *Project) GetName() string

func (*Project) GetUpdatedAt

func (m *Project) GetUpdatedAt() *timestamp.Timestamp

func (*Project) GetUser

func (m *Project) GetUser() string

func (*Project) GetUuid

func (m *Project) GetUuid() string

func (*Project) ProtoMessage

func (*Project) ProtoMessage()

func (*Project) Reset

func (m *Project) Reset()

func (*Project) String

func (m *Project) String() string

func (*Project) XXX_DiscardUnknown

func (m *Project) XXX_DiscardUnknown()

func (*Project) XXX_Marshal

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

func (*Project) XXX_Merge

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

func (*Project) XXX_Size

func (m *Project) XXX_Size() int

func (*Project) XXX_Unmarshal

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

type ProjectBodyRequest

type ProjectBodyRequest struct {
	// Owner of the namespace
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	// Project body
	Project              *Project `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request data to create/update project

func (*ProjectBodyRequest) Descriptor

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

func (*ProjectBodyRequest) GetOwner

func (m *ProjectBodyRequest) GetOwner() string

func (*ProjectBodyRequest) GetProject

func (m *ProjectBodyRequest) GetProject() *Project

func (*ProjectBodyRequest) ProtoMessage

func (*ProjectBodyRequest) ProtoMessage()

func (*ProjectBodyRequest) Reset

func (m *ProjectBodyRequest) Reset()

func (*ProjectBodyRequest) String

func (m *ProjectBodyRequest) String() string

func (*ProjectBodyRequest) XXX_DiscardUnknown

func (m *ProjectBodyRequest) XXX_DiscardUnknown()

func (*ProjectBodyRequest) XXX_Marshal

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

func (*ProjectBodyRequest) XXX_Merge

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

func (*ProjectBodyRequest) XXX_Size

func (m *ProjectBodyRequest) XXX_Size() int

func (*ProjectBodyRequest) XXX_Unmarshal

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

type ProjectResourceListRequest

type ProjectResourceListRequest struct {
	// Owner of the namespace
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	// Project under namesapce
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// Pagination offset
	Offset int32 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	// Limit size
	Limit int32 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// Sort to order the search
	Sort string `protobuf:"bytes,5,opt,name=sort,proto3" json:"sort,omitempty"`
	// Query filter the search search
	Query                string   `protobuf:"bytes,6,opt,name=query,proto3" json:"query,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request list data with owner/project namespace

func (*ProjectResourceListRequest) Descriptor

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

func (*ProjectResourceListRequest) GetLimit

func (m *ProjectResourceListRequest) GetLimit() int32

func (*ProjectResourceListRequest) GetOffset

func (m *ProjectResourceListRequest) GetOffset() int32

func (*ProjectResourceListRequest) GetOwner

func (m *ProjectResourceListRequest) GetOwner() string

func (*ProjectResourceListRequest) GetProject

func (m *ProjectResourceListRequest) GetProject() string

func (*ProjectResourceListRequest) GetQuery

func (m *ProjectResourceListRequest) GetQuery() string

func (*ProjectResourceListRequest) GetSort

func (m *ProjectResourceListRequest) GetSort() string

func (*ProjectResourceListRequest) ProtoMessage

func (*ProjectResourceListRequest) ProtoMessage()

func (*ProjectResourceListRequest) Reset

func (m *ProjectResourceListRequest) Reset()

func (*ProjectResourceListRequest) String

func (m *ProjectResourceListRequest) String() string

func (*ProjectResourceListRequest) XXX_DiscardUnknown

func (m *ProjectResourceListRequest) XXX_DiscardUnknown()

func (*ProjectResourceListRequest) XXX_Marshal

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

func (*ProjectResourceListRequest) XXX_Merge

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

func (*ProjectResourceListRequest) XXX_Size

func (m *ProjectResourceListRequest) XXX_Size() int

func (*ProjectResourceListRequest) XXX_Unmarshal

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

type ProjectResourceRequest

type ProjectResourceRequest struct {
	// Owner of the namespace
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	// Project under namesapce
	Project              string   `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request data with owner/project namespace

func (*ProjectResourceRequest) Descriptor

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

func (*ProjectResourceRequest) GetOwner

func (m *ProjectResourceRequest) GetOwner() string

func (*ProjectResourceRequest) GetProject

func (m *ProjectResourceRequest) GetProject() string

func (*ProjectResourceRequest) ProtoMessage

func (*ProjectResourceRequest) ProtoMessage()

func (*ProjectResourceRequest) Reset

func (m *ProjectResourceRequest) Reset()

func (*ProjectResourceRequest) String

func (m *ProjectResourceRequest) String() string

func (*ProjectResourceRequest) XXX_DiscardUnknown

func (m *ProjectResourceRequest) XXX_DiscardUnknown()

func (*ProjectResourceRequest) XXX_Marshal

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

func (*ProjectResourceRequest) XXX_Merge

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

func (*ProjectResourceRequest) XXX_Size

func (m *ProjectResourceRequest) XXX_Size() int

func (*ProjectResourceRequest) XXX_Unmarshal

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

type ProjectResourceUuidsBodyRequest

type ProjectResourceUuidsBodyRequest struct {
	// Owner of the namespace
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	// Project under namesapce
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// Uuids of the entities
	Uuids                *Uuids   `protobuf:"bytes,3,opt,name=uuids,proto3" json:"uuids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request to act on multiple entities under project

func (*ProjectResourceUuidsBodyRequest) Descriptor

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

func (*ProjectResourceUuidsBodyRequest) GetOwner

func (*ProjectResourceUuidsBodyRequest) GetProject

func (m *ProjectResourceUuidsBodyRequest) GetProject() string

func (*ProjectResourceUuidsBodyRequest) GetUuids

func (m *ProjectResourceUuidsBodyRequest) GetUuids() *Uuids

func (*ProjectResourceUuidsBodyRequest) ProtoMessage

func (*ProjectResourceUuidsBodyRequest) ProtoMessage()

func (*ProjectResourceUuidsBodyRequest) Reset

func (*ProjectResourceUuidsBodyRequest) String

func (*ProjectResourceUuidsBodyRequest) XXX_DiscardUnknown

func (m *ProjectResourceUuidsBodyRequest) XXX_DiscardUnknown()

func (*ProjectResourceUuidsBodyRequest) XXX_Marshal

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

func (*ProjectResourceUuidsBodyRequest) XXX_Merge

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

func (*ProjectResourceUuidsBodyRequest) XXX_Size

func (m *ProjectResourceUuidsBodyRequest) XXX_Size() int

func (*ProjectResourceUuidsBodyRequest) XXX_Unmarshal

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

type ProjectsV1Client

type ProjectsV1Client interface {
	// List projects
	ListProjects(ctx context.Context, in *OwnerResouceListRequest, opts ...grpc.CallOption) (*ListProjectsResponse, error)
	// List project namess
	ListProjectNames(ctx context.Context, in *OwnerResouceListRequest, opts ...grpc.CallOption) (*ListProjectsResponse, error)
	// List bookmarked projects for user
	ListBookmarkedProjects(ctx context.Context, in *UserResouceListRequest, opts ...grpc.CallOption) (*ListProjectsResponse, error)
	// List archived projects for user
	ListArchivedProjects(ctx context.Context, in *UserResouceListRequest, opts ...grpc.CallOption) (*ListProjectsResponse, error)
	// Create new project
	CreateProject(ctx context.Context, in *ProjectBodyRequest, opts ...grpc.CallOption) (*Project, error)
	// Get project
	GetProject(ctx context.Context, in *ProjectResourceRequest, opts ...grpc.CallOption) (*Project, error)
	// Update project
	UpdateProject(ctx context.Context, in *ProjectBodyRequest, opts ...grpc.CallOption) (*Project, error)
	// Patch project
	PatchProject(ctx context.Context, in *ProjectBodyRequest, opts ...grpc.CallOption) (*Project, error)
	// Delete project
	DeleteProject(ctx context.Context, in *ProjectResourceRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Archive project
	ArchiveProject(ctx context.Context, in *ProjectResourceRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Restore project
	RestoreExperiment(ctx context.Context, in *ProjectResourceRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Bookmark project
	BookmarkProject(ctx context.Context, in *ProjectResourceRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Unbookmark project
	UnbookmarkProject(ctx context.Context, in *ProjectResourceRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Enable project CI
	EnableProjectCI(ctx context.Context, in *ProjectResourceRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Disbale project CI
	DisableProjectCI(ctx context.Context, in *ProjectResourceRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

ProjectsV1Client is the client API for ProjectsV1 service.

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

func NewProjectsV1Client

func NewProjectsV1Client(cc *grpc.ClientConn) ProjectsV1Client

type ProjectsV1Server

type ProjectsV1Server interface {
	// List projects
	ListProjects(context.Context, *OwnerResouceListRequest) (*ListProjectsResponse, error)
	// List project namess
	ListProjectNames(context.Context, *OwnerResouceListRequest) (*ListProjectsResponse, error)
	// List bookmarked projects for user
	ListBookmarkedProjects(context.Context, *UserResouceListRequest) (*ListProjectsResponse, error)
	// List archived projects for user
	ListArchivedProjects(context.Context, *UserResouceListRequest) (*ListProjectsResponse, error)
	// Create new project
	CreateProject(context.Context, *ProjectBodyRequest) (*Project, error)
	// Get project
	GetProject(context.Context, *ProjectResourceRequest) (*Project, error)
	// Update project
	UpdateProject(context.Context, *ProjectBodyRequest) (*Project, error)
	// Patch project
	PatchProject(context.Context, *ProjectBodyRequest) (*Project, error)
	// Delete project
	DeleteProject(context.Context, *ProjectResourceRequest) (*empty.Empty, error)
	// Archive project
	ArchiveProject(context.Context, *ProjectResourceRequest) (*empty.Empty, error)
	// Restore project
	RestoreExperiment(context.Context, *ProjectResourceRequest) (*empty.Empty, error)
	// Bookmark project
	BookmarkProject(context.Context, *ProjectResourceRequest) (*empty.Empty, error)
	// Unbookmark project
	UnbookmarkProject(context.Context, *ProjectResourceRequest) (*empty.Empty, error)
	// Enable project CI
	EnableProjectCI(context.Context, *ProjectResourceRequest) (*empty.Empty, error)
	// Disbale project CI
	DisableProjectCI(context.Context, *ProjectResourceRequest) (*empty.Empty, error)
}

ProjectsV1Server is the server API for ProjectsV1 service.

type Run

type Run struct {
	// UUID
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// Optional name
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Optional description
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Optional Tags of this entity
	Tags []string `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty"`
	// Optional if the entity has been deleted
	Deleted bool `protobuf:"varint,5,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// Required name of user started this entity
	User string `protobuf:"bytes,6,opt,name=user,proto3" json:"user,omitempty"`
	// Required name of owner of this entity
	Owner string `protobuf:"bytes,7,opt,name=owner,proto3" json:"owner,omitempty"`
	// Required project name
	Project string `protobuf:"bytes,8,opt,name=project,proto3" json:"project,omitempty"`
	// Optional time when the entityt was created
	CreatedAt *timestamp.Timestamp `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Optional last time the entity was updated
	UpdatedAt *timestamp.Timestamp `protobuf:"bytes,10,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// Optional last time the entity was started
	StartedAt *timestamp.Timestamp `protobuf:"bytes,11,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	// Optional last time the entity was started
	FinishedAt *timestamp.Timestamp `protobuf:"bytes,12,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	// Optional flag to tell if this entity is managed by the platform
	IsManaged string `protobuf:"bytes,13,opt,name=is_managed,json=isManaged,proto3" json:"is_managed,omitempty"`
	// Optional content of the entity's spec
	Content string `protobuf:"bytes,14,opt,name=content,proto3" json:"content,omitempty"`
	// Optional latest status of this entity
	Status string `protobuf:"bytes,15,opt,name=status,proto3" json:"status,omitempty"`
	// Optional a readme text describing this entity
	Readme string `protobuf:"bytes,16,opt,name=readme,proto3" json:"readme,omitempty"`
	// Optional if this entity was bookmarked
	Bookmarked bool `protobuf:"varint,17,opt,name=bookmarked,proto3" json:"bookmarked,omitempty"`
	// Optional inputs of this entity
	Inputs map[string]string `` /* 154-byte string literal not displayed */
	// Optional outputs of this entity
	Outputs map[string]string `` /* 156-byte string literal not displayed */
	// Optional run environment tracked
	RunEnv map[string]string `` /* 168-byte string literal not displayed */
	// Id instance is clone
	IsClone bool `protobuf:"varint,21,opt,name=is_clone,json=isClone,proto3" json:"is_clone,omitempty"`
	// Optional uuid of the original run and pipeline
	Pipeline     string `protobuf:"bytes,22,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	Original     string `protobuf:"bytes,23,opt,name=original,proto3" json:"original,omitempty"`
	PipelineName string `protobuf:"bytes,24,opt,name=pipeline_name,json=pipelineName,proto3" json:"pipeline_name,omitempty"`
	OriginalName string `protobuf:"bytes,25,opt,name=original_name,json=originalName,proto3" json:"original_name,omitempty"`
	// Optional if this run was restarted/copied/resumed
	CloningStrategy      string   `protobuf:"bytes,26,opt,name=cloning_strategy,json=cloningStrategy,proto3" json:"cloning_strategy,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Run specification

func (*Run) Descriptor

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

func (*Run) GetBookmarked

func (m *Run) GetBookmarked() bool

func (*Run) GetCloningStrategy

func (m *Run) GetCloningStrategy() string

func (*Run) GetContent

func (m *Run) GetContent() string

func (*Run) GetCreatedAt

func (m *Run) GetCreatedAt() *timestamp.Timestamp

func (*Run) GetDeleted

func (m *Run) GetDeleted() bool

func (*Run) GetDescription

func (m *Run) GetDescription() string

func (*Run) GetFinishedAt

func (m *Run) GetFinishedAt() *timestamp.Timestamp

func (*Run) GetInputs

func (m *Run) GetInputs() map[string]string

func (*Run) GetIsClone

func (m *Run) GetIsClone() bool

func (*Run) GetIsManaged

func (m *Run) GetIsManaged() string

func (*Run) GetName

func (m *Run) GetName() string

func (*Run) GetOriginal

func (m *Run) GetOriginal() string

func (*Run) GetOriginalName

func (m *Run) GetOriginalName() string

func (*Run) GetOutputs

func (m *Run) GetOutputs() map[string]string

func (*Run) GetOwner

func (m *Run) GetOwner() string

func (*Run) GetPipeline

func (m *Run) GetPipeline() string

func (*Run) GetPipelineName

func (m *Run) GetPipelineName() string

func (*Run) GetProject

func (m *Run) GetProject() string

func (*Run) GetReadme

func (m *Run) GetReadme() string

func (*Run) GetRunEnv

func (m *Run) GetRunEnv() map[string]string

func (*Run) GetStartedAt

func (m *Run) GetStartedAt() *timestamp.Timestamp

func (*Run) GetStatus

func (m *Run) GetStatus() string

func (*Run) GetTags

func (m *Run) GetTags() []string

func (*Run) GetUpdatedAt

func (m *Run) GetUpdatedAt() *timestamp.Timestamp

func (*Run) GetUser

func (m *Run) GetUser() string

func (*Run) GetUuid

func (m *Run) GetUuid() string

func (*Run) ProtoMessage

func (*Run) ProtoMessage()

func (*Run) Reset

func (m *Run) Reset()

func (*Run) String

func (m *Run) String() string

func (*Run) XXX_DiscardUnknown

func (m *Run) XXX_DiscardUnknown()

func (*Run) XXX_Marshal

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

func (*Run) XXX_Merge

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

func (*Run) XXX_Size

func (m *Run) XXX_Size() int

func (*Run) XXX_Unmarshal

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

type RunBodyRequest

type RunBodyRequest struct {
	// Owner of the namespace
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	// Project where the experiement will be assigned
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// Run object
	Run                  *Run     `protobuf:"bytes,3,opt,name=run,proto3" json:"run,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request data to create run

func (*RunBodyRequest) Descriptor

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

func (*RunBodyRequest) GetOwner

func (m *RunBodyRequest) GetOwner() string

func (*RunBodyRequest) GetProject

func (m *RunBodyRequest) GetProject() string

func (*RunBodyRequest) GetRun

func (m *RunBodyRequest) GetRun() *Run

func (*RunBodyRequest) ProtoMessage

func (*RunBodyRequest) ProtoMessage()

func (*RunBodyRequest) Reset

func (m *RunBodyRequest) Reset()

func (*RunBodyRequest) String

func (m *RunBodyRequest) String() string

func (*RunBodyRequest) XXX_DiscardUnknown

func (m *RunBodyRequest) XXX_DiscardUnknown()

func (*RunBodyRequest) XXX_Marshal

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

func (*RunBodyRequest) XXX_Merge

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

func (*RunBodyRequest) XXX_Size

func (m *RunBodyRequest) XXX_Size() int

func (*RunBodyRequest) XXX_Unmarshal

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

type RunsV1Client

type RunsV1Client interface {
	// List bookmarked runs for user
	ListBookmarkedRuns(ctx context.Context, in *UserResouceListRequest, opts ...grpc.CallOption) (*ListRunsResponse, error)
	// List archived runs for user
	ListArchivedRuns(ctx context.Context, in *UserResouceListRequest, opts ...grpc.CallOption) (*ListRunsResponse, error)
	// List runs
	ListRuns(ctx context.Context, in *ProjectResourceListRequest, opts ...grpc.CallOption) (*ListRunsResponse, error)
	// Create new run
	CreateRun(ctx context.Context, in *RunBodyRequest, opts ...grpc.CallOption) (*Run, error)
	// Get run
	GetRun(ctx context.Context, in *EntityResourceRequest, opts ...grpc.CallOption) (*Run, error)
	// Update run
	UpdateRun(ctx context.Context, in *RunBodyRequest, opts ...grpc.CallOption) (*Run, error)
	// Patch run
	PatchRun(ctx context.Context, in *RunBodyRequest, opts ...grpc.CallOption) (*Run, error)
	// Delete run
	DeleteRun(ctx context.Context, in *EntityResourceRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Delete runs
	DeleteRuns(ctx context.Context, in *ProjectResourceUuidsBodyRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Stop run
	StopRun(ctx context.Context, in *EntityResourceRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Stop runs
	StopRuns(ctx context.Context, in *ProjectResourceUuidsBodyRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Invalidate run
	InvalidateRun(ctx context.Context, in *EntityResourceRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Invalidate runs
	InvalidateRuns(ctx context.Context, in *ProjectResourceUuidsBodyRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Restart run with copy
	CopyRun(ctx context.Context, in *EntityRunBodyRequest, opts ...grpc.CallOption) (*Run, error)
	// Restart run
	RestartRun(ctx context.Context, in *EntityRunBodyRequest, opts ...grpc.CallOption) (*Run, error)
	// Resume run
	ResumeRun(ctx context.Context, in *EntityRunBodyRequest, opts ...grpc.CallOption) (*Run, error)
	// Archive run
	ArchiveRun(ctx context.Context, in *EntityResourceRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Restore run
	RestoreRun(ctx context.Context, in *EntityResourceRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Bookmark run
	BookmarkRun(ctx context.Context, in *EntityResourceRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Unbookmark run
	UnbookmarkRun(ctx context.Context, in *EntityResourceRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Start run tensorboard
	StartRunTensorboard(ctx context.Context, in *EntityResourceRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Stop run tensorboard
	StopRunTensorboard(ctx context.Context, in *EntityResourceRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Get run status
	GetRunStatuses(ctx context.Context, in *EntityResourceRequest, opts ...grpc.CallOption) (*Status, error)
	// Create new run status
	CreateRunStatus(ctx context.Context, in *EntityStatusBodyRequest, opts ...grpc.CallOption) (*Status, error)
	// Get run code ref
	GetRunCodeRefs(ctx context.Context, in *EntityResourceRequest, opts ...grpc.CallOption) (*ListCodeRefsResponse, error)
	// Get run code ref
	CreateRunCodeRef(ctx context.Context, in *CodeRefBodyRequest, opts ...grpc.CallOption) (*CodeReference, error)
	// Impersonate run token
	ImpersonateToken(ctx context.Context, in *EntityResourceRequest, opts ...grpc.CallOption) (*Auth, error)
}

RunsV1Client is the client API for RunsV1 service.

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

func NewRunsV1Client

func NewRunsV1Client(cc *grpc.ClientConn) RunsV1Client

type RunsV1Server

type RunsV1Server interface {
	// List bookmarked runs for user
	ListBookmarkedRuns(context.Context, *UserResouceListRequest) (*ListRunsResponse, error)
	// List archived runs for user
	ListArchivedRuns(context.Context, *UserResouceListRequest) (*ListRunsResponse, error)
	// List runs
	ListRuns(context.Context, *ProjectResourceListRequest) (*ListRunsResponse, error)
	// Create new run
	CreateRun(context.Context, *RunBodyRequest) (*Run, error)
	// Get run
	GetRun(context.Context, *EntityResourceRequest) (*Run, error)
	// Update run
	UpdateRun(context.Context, *RunBodyRequest) (*Run, error)
	// Patch run
	PatchRun(context.Context, *RunBodyRequest) (*Run, error)
	// Delete run
	DeleteRun(context.Context, *EntityResourceRequest) (*empty.Empty, error)
	// Delete runs
	DeleteRuns(context.Context, *ProjectResourceUuidsBodyRequest) (*empty.Empty, error)
	// Stop run
	StopRun(context.Context, *EntityResourceRequest) (*empty.Empty, error)
	// Stop runs
	StopRuns(context.Context, *ProjectResourceUuidsBodyRequest) (*empty.Empty, error)
	// Invalidate run
	InvalidateRun(context.Context, *EntityResourceRequest) (*empty.Empty, error)
	// Invalidate runs
	InvalidateRuns(context.Context, *ProjectResourceUuidsBodyRequest) (*empty.Empty, error)
	// Restart run with copy
	CopyRun(context.Context, *EntityRunBodyRequest) (*Run, error)
	// Restart run
	RestartRun(context.Context, *EntityRunBodyRequest) (*Run, error)
	// Resume run
	ResumeRun(context.Context, *EntityRunBodyRequest) (*Run, error)
	// Archive run
	ArchiveRun(context.Context, *EntityResourceRequest) (*empty.Empty, error)
	// Restore run
	RestoreRun(context.Context, *EntityResourceRequest) (*empty.Empty, error)
	// Bookmark run
	BookmarkRun(context.Context, *EntityResourceRequest) (*empty.Empty, error)
	// Unbookmark run
	UnbookmarkRun(context.Context, *EntityResourceRequest) (*empty.Empty, error)
	// Start run tensorboard
	StartRunTensorboard(context.Context, *EntityResourceRequest) (*empty.Empty, error)
	// Stop run tensorboard
	StopRunTensorboard(context.Context, *EntityResourceRequest) (*empty.Empty, error)
	// Get run status
	GetRunStatuses(context.Context, *EntityResourceRequest) (*Status, error)
	// Create new run status
	CreateRunStatus(context.Context, *EntityStatusBodyRequest) (*Status, error)
	// Get run code ref
	GetRunCodeRefs(context.Context, *EntityResourceRequest) (*ListCodeRefsResponse, error)
	// Get run code ref
	CreateRunCodeRef(context.Context, *CodeRefBodyRequest) (*CodeReference, error)
	// Impersonate run token
	ImpersonateToken(context.Context, *EntityResourceRequest) (*Auth, error)
}

RunsV1Server is the server API for RunsV1 service.

type Status

type Status struct {
	// The uuid of the run
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// The current status
	Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// The status conditions timeline
	StatusConditions     []*StatusCondition `protobuf:"bytes,3,rep,name=status_conditions,json=statusConditions,proto3" json:"status_conditions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

Status specification

func (*Status) Descriptor

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

func (*Status) GetStatus

func (m *Status) GetStatus() string

func (*Status) GetStatusConditions

func (m *Status) GetStatusConditions() []*StatusCondition

func (*Status) GetUuid

func (m *Status) GetUuid() string

func (*Status) ProtoMessage

func (*Status) ProtoMessage()

func (*Status) Reset

func (m *Status) Reset()

func (*Status) String

func (m *Status) String() string

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 StatusCondition

type StatusCondition struct {
	// Status type
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// Status state
	Status bool `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`
	// Status reason
	Reason string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	// Status message
	Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// last update time
	LastUpdateTime *timestamp.Timestamp `protobuf:"bytes,5,opt,name=last_update_time,json=lastUpdateTime,proto3" json:"last_update_time,omitempty"`
	// last transition time
	LastTransitionTime   *timestamp.Timestamp `protobuf:"bytes,6,opt,name=last_transition_time,json=lastTransitionTime,proto3" json:"last_transition_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Status condition specification

func (*StatusCondition) Descriptor

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

func (*StatusCondition) GetLastTransitionTime

func (m *StatusCondition) GetLastTransitionTime() *timestamp.Timestamp

func (*StatusCondition) GetLastUpdateTime

func (m *StatusCondition) GetLastUpdateTime() *timestamp.Timestamp

func (*StatusCondition) GetMessage

func (m *StatusCondition) GetMessage() string

func (*StatusCondition) GetReason

func (m *StatusCondition) GetReason() string

func (*StatusCondition) GetStatus

func (m *StatusCondition) GetStatus() bool

func (*StatusCondition) GetType

func (m *StatusCondition) GetType() string

func (*StatusCondition) ProtoMessage

func (*StatusCondition) ProtoMessage()

func (*StatusCondition) Reset

func (m *StatusCondition) Reset()

func (*StatusCondition) String

func (m *StatusCondition) String() string

func (*StatusCondition) XXX_DiscardUnknown

func (m *StatusCondition) XXX_DiscardUnknown()

func (*StatusCondition) XXX_Marshal

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

func (*StatusCondition) XXX_Merge

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

func (*StatusCondition) XXX_Size

func (m *StatusCondition) XXX_Size() int

func (*StatusCondition) XXX_Unmarshal

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

type UnimplementedAuthV1Server

type UnimplementedAuthV1Server struct {
}

UnimplementedAuthV1Server can be embedded to have forward compatible implementations.

func (*UnimplementedAuthV1Server) Login

type UnimplementedProjectsV1Server

type UnimplementedProjectsV1Server struct {
}

UnimplementedProjectsV1Server can be embedded to have forward compatible implementations.

func (*UnimplementedProjectsV1Server) ArchiveProject

func (*UnimplementedProjectsV1Server) BookmarkProject

func (*UnimplementedProjectsV1Server) CreateProject

func (*UnimplementedProjectsV1Server) DeleteProject

func (*UnimplementedProjectsV1Server) DisableProjectCI

func (*UnimplementedProjectsV1Server) EnableProjectCI

func (*UnimplementedProjectsV1Server) GetProject

func (*UnimplementedProjectsV1Server) ListArchivedProjects

func (*UnimplementedProjectsV1Server) ListBookmarkedProjects

func (*UnimplementedProjectsV1Server) ListProjectNames

func (*UnimplementedProjectsV1Server) ListProjects

func (*UnimplementedProjectsV1Server) PatchProject

func (*UnimplementedProjectsV1Server) RestoreExperiment

func (*UnimplementedProjectsV1Server) UnbookmarkProject

func (*UnimplementedProjectsV1Server) UpdateProject

type UnimplementedRunsV1Server

type UnimplementedRunsV1Server struct {
}

UnimplementedRunsV1Server can be embedded to have forward compatible implementations.

func (*UnimplementedRunsV1Server) ArchiveRun

func (*UnimplementedRunsV1Server) BookmarkRun

func (*UnimplementedRunsV1Server) CopyRun

func (*UnimplementedRunsV1Server) CreateRun

func (*UnimplementedRunsV1Server) CreateRunCodeRef

func (*UnimplementedRunsV1Server) CreateRunStatus

func (*UnimplementedRunsV1Server) DeleteRun

func (*UnimplementedRunsV1Server) DeleteRuns

func (*UnimplementedRunsV1Server) GetRun

func (*UnimplementedRunsV1Server) GetRunCodeRefs

func (*UnimplementedRunsV1Server) GetRunStatuses

func (*UnimplementedRunsV1Server) ImpersonateToken

func (*UnimplementedRunsV1Server) ImpersonateToken(ctx context.Context, req *EntityResourceRequest) (*Auth, error)

func (*UnimplementedRunsV1Server) InvalidateRun

func (*UnimplementedRunsV1Server) InvalidateRuns

func (*UnimplementedRunsV1Server) ListArchivedRuns

func (*UnimplementedRunsV1Server) ListBookmarkedRuns

func (*UnimplementedRunsV1Server) ListRuns

func (*UnimplementedRunsV1Server) PatchRun

func (*UnimplementedRunsV1Server) RestartRun

func (*UnimplementedRunsV1Server) RestoreRun

func (*UnimplementedRunsV1Server) ResumeRun

func (*UnimplementedRunsV1Server) StartRunTensorboard

func (*UnimplementedRunsV1Server) StartRunTensorboard(ctx context.Context, req *EntityResourceRequest) (*empty.Empty, error)

func (*UnimplementedRunsV1Server) StopRun

func (*UnimplementedRunsV1Server) StopRunTensorboard

func (*UnimplementedRunsV1Server) StopRunTensorboard(ctx context.Context, req *EntityResourceRequest) (*empty.Empty, error)

func (*UnimplementedRunsV1Server) StopRuns

func (*UnimplementedRunsV1Server) UnbookmarkRun

func (*UnimplementedRunsV1Server) UpdateRun

type UnimplementedUsersV1Server

type UnimplementedUsersV1Server struct {
}

UnimplementedUsersV1Server can be embedded to have forward compatible implementations.

func (*UnimplementedUsersV1Server) GetUser

type UnimplementedVersionsV1Server

type UnimplementedVersionsV1Server struct {
}

UnimplementedVersionsV1Server can be embedded to have forward compatible implementations.

func (*UnimplementedVersionsV1Server) GetLogHandler

func (*UnimplementedVersionsV1Server) GetVersions

type User

type User struct {
	// Username
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	// Email
	Email string `protobuf:"bytes,2,opt,name=email,proto3" json:"email,omitempty"`
	// Role
	Role                 string   `protobuf:"bytes,3,opt,name=role,proto3" json:"role,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Auth specification

func (*User) Descriptor

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

func (*User) GetEmail

func (m *User) GetEmail() string

func (*User) GetRole

func (m *User) GetRole() string

func (*User) GetUsername

func (m *User) GetUsername() string

func (*User) ProtoMessage

func (*User) ProtoMessage()

func (*User) Reset

func (m *User) Reset()

func (*User) String

func (m *User) String() string

func (*User) XXX_DiscardUnknown

func (m *User) XXX_DiscardUnknown()

func (*User) XXX_Marshal

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

func (*User) XXX_Merge

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

func (*User) XXX_Size

func (m *User) XXX_Size() int

func (*User) XXX_Unmarshal

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

type UserResouceListRequest

type UserResouceListRequest struct {
	// User
	User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// Pagination offset
	Offset int32 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// Limit size
	Limit int32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// Sort to order the search
	Sort string `protobuf:"bytes,4,opt,name=sort,proto3" json:"sort,omitempty"`
	// Query filter the search search
	Query                string   `protobuf:"bytes,5,opt,name=query,proto3" json:"query,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request list data with user namespace

func (*UserResouceListRequest) Descriptor

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

func (*UserResouceListRequest) GetLimit

func (m *UserResouceListRequest) GetLimit() int32

func (*UserResouceListRequest) GetOffset

func (m *UserResouceListRequest) GetOffset() int32

func (*UserResouceListRequest) GetQuery

func (m *UserResouceListRequest) GetQuery() string

func (*UserResouceListRequest) GetSort

func (m *UserResouceListRequest) GetSort() string

func (*UserResouceListRequest) GetUser

func (m *UserResouceListRequest) GetUser() string

func (*UserResouceListRequest) ProtoMessage

func (*UserResouceListRequest) ProtoMessage()

func (*UserResouceListRequest) Reset

func (m *UserResouceListRequest) Reset()

func (*UserResouceListRequest) String

func (m *UserResouceListRequest) String() string

func (*UserResouceListRequest) XXX_DiscardUnknown

func (m *UserResouceListRequest) XXX_DiscardUnknown()

func (*UserResouceListRequest) XXX_Marshal

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

func (*UserResouceListRequest) XXX_Merge

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

func (*UserResouceListRequest) XXX_Size

func (m *UserResouceListRequest) XXX_Size() int

func (*UserResouceListRequest) XXX_Unmarshal

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

type UserResourceRequest

type UserResourceRequest struct {
	// User
	User                 string   `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request data with user namespace

func (*UserResourceRequest) Descriptor

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

func (*UserResourceRequest) GetUser

func (m *UserResourceRequest) GetUser() string

func (*UserResourceRequest) ProtoMessage

func (*UserResourceRequest) ProtoMessage()

func (*UserResourceRequest) Reset

func (m *UserResourceRequest) Reset()

func (*UserResourceRequest) String

func (m *UserResourceRequest) String() string

func (*UserResourceRequest) XXX_DiscardUnknown

func (m *UserResourceRequest) XXX_DiscardUnknown()

func (*UserResourceRequest) XXX_Marshal

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

func (*UserResourceRequest) XXX_Merge

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

func (*UserResourceRequest) XXX_Size

func (m *UserResourceRequest) XXX_Size() int

func (*UserResourceRequest) XXX_Unmarshal

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

type UsersV1Client

type UsersV1Client interface {
	// Get current user
	GetUser(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*User, error)
}

UsersV1Client is the client API for UsersV1 service.

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

func NewUsersV1Client

func NewUsersV1Client(cc *grpc.ClientConn) UsersV1Client

type UsersV1Server

type UsersV1Server interface {
	// Get current user
	GetUser(context.Context, *empty.Empty) (*User, error)
}

UsersV1Server is the server API for UsersV1 service.

type Uuids

type Uuids struct {
	Uuids                []string `protobuf:"bytes,1,rep,name=uuids,proto3" json:"uuids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Uuids) Descriptor

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

func (*Uuids) GetUuids

func (m *Uuids) GetUuids() []string

func (*Uuids) ProtoMessage

func (*Uuids) ProtoMessage()

func (*Uuids) Reset

func (m *Uuids) Reset()

func (*Uuids) String

func (m *Uuids) String() string

func (*Uuids) XXX_DiscardUnknown

func (m *Uuids) XXX_DiscardUnknown()

func (*Uuids) XXX_Marshal

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

func (*Uuids) XXX_Merge

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

func (*Uuids) XXX_Size

func (m *Uuids) XXX_Size() int

func (*Uuids) XXX_Unmarshal

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

type Version

type Version struct {
	// Min version
	MinVersion string `protobuf:"bytes,1,opt,name=min_version,json=minVersion,proto3" json:"min_version,omitempty"`
	// Latest version
	LatestVersion        string   `protobuf:"bytes,2,opt,name=latest_version,json=latestVersion,proto3" json:"latest_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Version specification

func (*Version) Descriptor

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

func (*Version) GetLatestVersion

func (m *Version) GetLatestVersion() string

func (*Version) GetMinVersion

func (m *Version) GetMinVersion() string

func (*Version) ProtoMessage

func (*Version) ProtoMessage()

func (*Version) Reset

func (m *Version) Reset()

func (*Version) String

func (m *Version) String() string

func (*Version) XXX_DiscardUnknown

func (m *Version) XXX_DiscardUnknown()

func (*Version) XXX_Marshal

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

func (*Version) XXX_Merge

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

func (*Version) XXX_Size

func (m *Version) XXX_Size() int

func (*Version) XXX_Unmarshal

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

type Versions

type Versions struct {
	CurrentVersion       string   `protobuf:"bytes,1,opt,name=current_version,json=currentVersion,proto3" json:"current_version,omitempty"`
	Cli                  *Version `protobuf:"bytes,2,opt,name=cli,proto3" json:"cli,omitempty"`
	Platform             *Version `protobuf:"bytes,3,opt,name=platform,proto3" json:"platform,omitempty"`
	Agent                *Version `protobuf:"bytes,4,opt,name=agent,proto3" json:"agent,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Versions) Descriptor

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

func (*Versions) GetAgent

func (m *Versions) GetAgent() *Version

func (*Versions) GetCli

func (m *Versions) GetCli() *Version

func (*Versions) GetCurrentVersion

func (m *Versions) GetCurrentVersion() string

func (*Versions) GetPlatform

func (m *Versions) GetPlatform() *Version

func (*Versions) ProtoMessage

func (*Versions) ProtoMessage()

func (*Versions) Reset

func (m *Versions) Reset()

func (*Versions) String

func (m *Versions) String() string

func (*Versions) XXX_DiscardUnknown

func (m *Versions) XXX_DiscardUnknown()

func (*Versions) XXX_Marshal

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

func (*Versions) XXX_Merge

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

func (*Versions) XXX_Size

func (m *Versions) XXX_Size() int

func (*Versions) XXX_Unmarshal

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

type VersionsV1Client

type VersionsV1Client interface {
	// Get versions
	GetVersions(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Versions, error)
	// Get log handler
	GetLogHandler(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*LogHandler, error)
}

VersionsV1Client is the client API for VersionsV1 service.

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

func NewVersionsV1Client

func NewVersionsV1Client(cc *grpc.ClientConn) VersionsV1Client

type VersionsV1Server

type VersionsV1Server interface {
	// Get versions
	GetVersions(context.Context, *empty.Empty) (*Versions, error)
	// Get log handler
	GetLogHandler(context.Context, *empty.Empty) (*LogHandler, error)
}

VersionsV1Server is the server API for VersionsV1 service.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL