 Documentation
      ¶
      Documentation
      ¶
    
    
  
    
  
    Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Stream ¶
func Stream(ctx context.Context, cwd string, streams *streams.Output, dialer WebSocketDialer, creds CredentialLookup, build *apiv1.AcornImageBuild) (*v1.AppImage, error)
Types ¶
type CredentialLookup ¶
type FileServer ¶
type FileServer struct {
	// contains filtered or unexported fields
}
    func NewFileServer ¶
func (*FileServer) DiffCopy ¶
func (f *FileServer) DiffCopy(server filesync.FileSync_DiffCopyServer) error
func (*FileServer) Register ¶
func (f *FileServer) Register(server *grpc.Server)
func (*FileServer) TarStream ¶
func (f *FileServer) TarStream(server filesync.FileSync_TarStreamServer) error
type Message ¶
type Message struct {
	FileSessionID         string       `json:"fileSessionID,omitempty"`
	StatusSessionID       string       `json:"statusSessionID,omitempty"`
	AppImage              *v1.AppImage `json:"appImage,omitempty"`
	Error                 string       `json:"error,omitempty"`
	Acornfile             string       `json:"acornfile,omitempty"`
	ReadFile              string       `json:"readFile,omitempty"`
	RegistryServerAddress string       `json:"registryServerAddress,omitempty"`
	FileSessionClose bool                `json:"fileSessionClose,omitempty"`
	RegistryAuth     *apiv1.RegistryAuth `json:"registryAuth,omitempty"`
	SyncOptions      *SyncOptions        `json:"syncOptions,omitempty"`
	Packet           *types.Packet       `json:"packet,omitempty"`
	PacketData       []byte              `json:"packetData,omitempty"`
	Status           *client.SolveStatus `json:"status,omitempty"`
	Compress         bool                `json:"compress,omitempty"`
}
    func (*Message) MarshalJSON ¶
func (*Message) UnmarshalJSON ¶
type SyncOptions ¶
type WebSocketDialer ¶
type WebsocketMessages ¶
type WebsocketMessages struct {
	// contains filtered or unexported fields
}
    func NewWebsocketMessages ¶
func NewWebsocketMessages(conn *websocket.Conn) *WebsocketMessages
func (*WebsocketMessages) Close ¶
func (m *WebsocketMessages) Close()
func (*WebsocketMessages) OnMessage ¶
func (m *WebsocketMessages) OnMessage(handler func(message *Message) error)
OnMessage is a synchronous handler that will block the input of messages until the handler finishes.
func (*WebsocketMessages) Recv ¶
func (m *WebsocketMessages) Recv() (<-chan *Message, func())
func (*WebsocketMessages) Send ¶
func (m *WebsocketMessages) Send(msg *Message) error
func (*WebsocketMessages) Start ¶
func (m *WebsocketMessages) Start(ctx context.Context)
 Click to show internal directories. 
   Click to hide internal directories.