host_server

package
v0.0.0-...-841f565 Latest Latest
Warning

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

 Go to latest Published: Sep 28, 2022 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_host_server_proto protoreflect.FileDescriptor

Functions

func RegisterHostServer 

func RegisterHostServer(s *grpc.Server, srv HostServer)

Types

type AddWorkspaceRequest 

type AddWorkspaceRequest struct {
	Root string `protobuf:"bytes,1,opt,name=root,proto3" json:"root,omitempty"`
	// contains filtered or unexported fields
}

ark add workspace -- does not exist yet

func (*AddWorkspaceRequest) Descriptor deprecated 

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

Deprecated: Use AddWorkspaceRequest.ProtoReflect.Descriptor instead.

func (*AddWorkspaceRequest) GetRoot 

func (x *AddWorkspaceRequest) GetRoot() string

func (*AddWorkspaceRequest) ProtoMessage 

func (*AddWorkspaceRequest) ProtoMessage()

func (*AddWorkspaceRequest) ProtoReflect 

func (x *AddWorkspaceRequest) ProtoReflect() protoreflect.Message

func (*AddWorkspaceRequest) Reset 

func (x *AddWorkspaceRequest) Reset()

func (*AddWorkspaceRequest) String 

func (x *AddWorkspaceRequest) String() string

type AddWorkspaceResponse 

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

func (*AddWorkspaceResponse) Descriptor deprecated 

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

Deprecated: Use AddWorkspaceResponse.ProtoReflect.Descriptor instead.

func (*AddWorkspaceResponse) ProtoMessage 

func (*AddWorkspaceResponse) ProtoMessage()

func (*AddWorkspaceResponse) ProtoReflect 

func (x *AddWorkspaceResponse) ProtoReflect() protoreflect.Message

func (*AddWorkspaceResponse) Reset 

func (x *AddWorkspaceResponse) Reset()

func (*AddWorkspaceResponse) String 

func (x *AddWorkspaceResponse) String() string

type ArkStore 

type ArkStore struct{}

ArkStore represents a set of fields that are global to all workspaces

func (ArkStore) Clean 

func (s ArkStore) Clean() error

Clean removes generated files from the /ark/artifacts directory this is used to reset the local state and artifacts cache

func (ArkStore) GetArtifactsDir 

func (s ArkStore) GetArtifactsDir() string

GetArtifactsDir returns the artifacts directory

func (ArkStore) GetRootDir 

func (s ArkStore) GetRootDir() string

GetRootDir returns the /ark directory

type CleanHostArtifactsRequest 

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

ark clean

func (*CleanHostArtifactsRequest) Descriptor deprecated 

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

Deprecated: Use CleanHostArtifactsRequest.ProtoReflect.Descriptor instead.

func (*CleanHostArtifactsRequest) ProtoMessage 

func (*CleanHostArtifactsRequest) ProtoMessage()

func (*CleanHostArtifactsRequest) ProtoReflect 

func (x *CleanHostArtifactsRequest) ProtoReflect() protoreflect.Message

func (*CleanHostArtifactsRequest) Reset 

func (x *CleanHostArtifactsRequest) Reset()

func (*CleanHostArtifactsRequest) String 

func (x *CleanHostArtifactsRequest) String() string

type CleanHostArtifactsResponse 

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

func (*CleanHostArtifactsResponse) Descriptor deprecated 

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

Deprecated: Use CleanHostArtifactsResponse.ProtoReflect.Descriptor instead.

func (*CleanHostArtifactsResponse) ProtoMessage 

func (*CleanHostArtifactsResponse) ProtoMessage()

func (*CleanHostArtifactsResponse) ProtoReflect 

func (x *CleanHostArtifactsResponse) ProtoReflect() protoreflect.Message

func (*CleanHostArtifactsResponse) Reset 

func (x *CleanHostArtifactsResponse) Reset()

func (*CleanHostArtifactsResponse) String 

func (x *CleanHostArtifactsResponse) String() string

type HostClient 

type HostClient interface {
	CleanHostArtifacts(ctx context.Context, in *CleanHostArtifactsRequest, opts ...grpc.CallOption) (*CleanHostArtifactsResponse, error)
	PullArtifacts(ctx context.Context, in *PullArtifactsRequest, opts ...grpc.CallOption) (Host_PullArtifactsClient, error)
	PushArtifacts(ctx context.Context, in *PushArtifactsRequest, opts ...grpc.CallOption) (Host_PushArtifactsClient, error)
	ListTargets(ctx context.Context, in *ListTargetsRequest, opts ...grpc.CallOption) (*ListTargetsResponse, error)
	RunTarget(ctx context.Context, in *RunTargetRequest, opts ...grpc.CallOption) (Host_RunTargetClient, error)
	AddWorkspace(ctx context.Context, in *AddWorkspaceRequest, opts ...grpc.CallOption) (*AddWorkspaceResponse, error)
	ValidateWorkspace(ctx context.Context, in *ValidateWorkspaceRequest, opts ...grpc.CallOption) (*ValidateWorkspaceResponse, error)
	WatchWorkspace(ctx context.Context, in *WatchWorkspaceRequest, opts ...grpc.CallOption) (Host_WatchWorkspaceClient, error)
	Shutdown(ctx context.Context, in *ShutdownRequest, opts ...grpc.CallOption) (*ShutdownResponse, error)
}

HostClient is the client API for Host service.

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

func NewHostClient 

func NewHostClient(cc grpc.ClientConnInterface) HostClient

type HostServer 

type HostServer interface {
	CleanHostArtifacts(context.Context, *CleanHostArtifactsRequest) (*CleanHostArtifactsResponse, error)
	PullArtifacts(*PullArtifactsRequest, Host_PullArtifactsServer) error
	PushArtifacts(*PushArtifactsRequest, Host_PushArtifactsServer) error
	ListTargets(context.Context, *ListTargetsRequest) (*ListTargetsResponse, error)
	RunTarget(*RunTargetRequest, Host_RunTargetServer) error
	AddWorkspace(context.Context, *AddWorkspaceRequest) (*AddWorkspaceResponse, error)
	ValidateWorkspace(context.Context, *ValidateWorkspaceRequest) (*ValidateWorkspaceResponse, error)
	WatchWorkspace(*WatchWorkspaceRequest, Host_WatchWorkspaceServer) error
	Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error)
}

HostServer is the server API for Host service.

type Host_PullArtifactsClient 

type Host_PullArtifactsClient interface {
	Recv() (*LogStreamResponse, error)
	grpc.ClientStream
}

type Host_PullArtifactsServer 

type Host_PullArtifactsServer interface {
	Send(*LogStreamResponse) error
	grpc.ServerStream
}

type Host_PushArtifactsClient 

type Host_PushArtifactsClient interface {
	Recv() (*LogStreamResponse, error)
	grpc.ClientStream
}

type Host_PushArtifactsServer 

type Host_PushArtifactsServer interface {
	Send(*LogStreamResponse) error
	grpc.ServerStream
}

type Host_RunTargetClient 

type Host_RunTargetClient interface {
	Recv() (*LogStreamResponse, error)
	grpc.ClientStream
}

type Host_RunTargetServer 

type Host_RunTargetServer interface {
	Send(*LogStreamResponse) error
	grpc.ServerStream
}

type Host_WatchWorkspaceClient 

type Host_WatchWorkspaceClient interface {
	Recv() (*LogStreamResponse, error)
	grpc.ClientStream
}

type Host_WatchWorkspaceServer 

type Host_WatchWorkspaceServer interface {
	Send(*LogStreamResponse) error
	grpc.ServerStream
}

type ListTargetsRequest 

type ListTargetsRequest struct {
	Root             string `protobuf:"bytes,1,opt,name=root,proto3" json:"root,omitempty"` // workspace root
	CheckRemoteCache bool   `protobuf:"varint,2,opt,name=check_remote_cache,json=checkRemoteCache,proto3" json:"check_remote_cache,omitempty"`
	// contains filtered or unexported fields
}

ark targets list

func (*ListTargetsRequest) Descriptor deprecated 

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

Deprecated: Use ListTargetsRequest.ProtoReflect.Descriptor instead.

func (*ListTargetsRequest) GetCheckRemoteCache 

func (x *ListTargetsRequest) GetCheckRemoteCache() bool

func (*ListTargetsRequest) GetRoot 

func (x *ListTargetsRequest) GetRoot() string

func (*ListTargetsRequest) ProtoMessage 

func (*ListTargetsRequest) ProtoMessage()

func (*ListTargetsRequest) ProtoReflect 

func (x *ListTargetsRequest) ProtoReflect() protoreflect.Message

func (*ListTargetsRequest) Reset 

func (x *ListTargetsRequest) Reset()

func (*ListTargetsRequest) String 

func (x *ListTargetsRequest) String() string

type ListTargetsResponse 

type ListTargetsResponse struct {
	Targets []*Target `protobuf:"bytes,1,rep,name=targets,proto3" json:"targets,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTargetsResponse) Descriptor deprecated 

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

Deprecated: Use ListTargetsResponse.ProtoReflect.Descriptor instead.

func (*ListTargetsResponse) GetTargets 

func (x *ListTargetsResponse) GetTargets() []*Target

func (*ListTargetsResponse) ProtoMessage 

func (*ListTargetsResponse) ProtoMessage()

func (*ListTargetsResponse) ProtoReflect 

func (x *ListTargetsResponse) ProtoReflect() protoreflect.Message

func (*ListTargetsResponse) Reset 

func (x *ListTargetsResponse) Reset()

func (*ListTargetsResponse) String 

func (x *ListTargetsResponse) String() string

type LogStreamResponse 

type LogStreamResponse struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

used for all log streams

func (*LogStreamResponse) Descriptor deprecated 

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

Deprecated: Use LogStreamResponse.ProtoReflect.Descriptor instead.

func (*LogStreamResponse) GetData 

func (x *LogStreamResponse) GetData() []byte

func (*LogStreamResponse) ProtoMessage 

func (*LogStreamResponse) ProtoMessage()

func (*LogStreamResponse) ProtoReflect 

func (x *LogStreamResponse) ProtoReflect() protoreflect.Message

func (*LogStreamResponse) Reset 

func (x *LogStreamResponse) Reset()

func (*LogStreamResponse) String 

func (x *LogStreamResponse) String() string

type PullArtifactsRequest 

type PullArtifactsRequest struct {
	Root string `protobuf:"bytes,1,opt,name=root,proto3" json:"root,omitempty"` // workspace root
	// contains filtered or unexported fields
}

ark artifacts pull

func (*PullArtifactsRequest) Descriptor deprecated 

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

Deprecated: Use PullArtifactsRequest.ProtoReflect.Descriptor instead.

func (*PullArtifactsRequest) GetRoot 

func (x *PullArtifactsRequest) GetRoot() string

func (*PullArtifactsRequest) ProtoMessage 

func (*PullArtifactsRequest) ProtoMessage()

func (*PullArtifactsRequest) ProtoReflect 

func (x *PullArtifactsRequest) ProtoReflect() protoreflect.Message

func (*PullArtifactsRequest) Reset 

func (x *PullArtifactsRequest) Reset()

func (*PullArtifactsRequest) String 

func (x *PullArtifactsRequest) String() string

type PushArtifactsRequest 

type PushArtifactsRequest struct {
	Root string `protobuf:"bytes,1,opt,name=root,proto3" json:"root,omitempty"` // workspace root
	// contains filtered or unexported fields
}

ark artifacts push

func (*PushArtifactsRequest) Descriptor deprecated 

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

Deprecated: Use PushArtifactsRequest.ProtoReflect.Descriptor instead.

func (*PushArtifactsRequest) GetRoot 

func (x *PushArtifactsRequest) GetRoot() string

func (*PushArtifactsRequest) ProtoMessage 

func (*PushArtifactsRequest) ProtoMessage()

func (*PushArtifactsRequest) ProtoReflect 

func (x *PushArtifactsRequest) ProtoReflect() protoreflect.Message

func (*PushArtifactsRequest) Reset 

func (x *PushArtifactsRequest) Reset()

func (*PushArtifactsRequest) String 

func (x *PushArtifactsRequest) String() string

type RunTargetRequest 

type RunTargetRequest struct {
	Root             string `protobuf:"bytes,1,opt,name=root,proto3" json:"root,omitempty"` // workspace root
	Address          string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Force            bool   `protobuf:"varint,3,opt,name=force,proto3" json:"force,omitempty"`
	Push             bool   `protobuf:"varint,4,opt,name=push,proto3" json:"push,omitempty"`
	Pull             bool   `protobuf:"varint,5,opt,name=pull,proto3" json:"pull,omitempty"`
	Watch            bool   `protobuf:"varint,6,opt,name=watch,proto3" json:"watch,omitempty"`
	StopOnFirstError bool   `protobuf:"varint,7,opt,name=stop_on_first_error,json=stopOnFirstError,proto3" json:"stop_on_first_error,omitempty"`
	Args             string `protobuf:"bytes,8,opt,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

ark run

func (*RunTargetRequest) Descriptor deprecated 

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

Deprecated: Use RunTargetRequest.ProtoReflect.Descriptor instead.

func (*RunTargetRequest) GetAddress 

func (x *RunTargetRequest) GetAddress() string

func (*RunTargetRequest) GetArgs 

func (x *RunTargetRequest) GetArgs() string

func (*RunTargetRequest) GetForce 

func (x *RunTargetRequest) GetForce() bool

func (*RunTargetRequest) GetPull 

func (x *RunTargetRequest) GetPull() bool

func (*RunTargetRequest) GetPush 

func (x *RunTargetRequest) GetPush() bool

func (*RunTargetRequest) GetRoot 

func (x *RunTargetRequest) GetRoot() string

func (*RunTargetRequest) GetStopOnFirstError 

func (x *RunTargetRequest) GetStopOnFirstError() bool

func (*RunTargetRequest) GetWatch 

func (x *RunTargetRequest) GetWatch() bool

func (*RunTargetRequest) ProtoMessage 

func (*RunTargetRequest) ProtoMessage()

func (*RunTargetRequest) ProtoReflect 

func (x *RunTargetRequest) ProtoReflect() protoreflect.Message

func (*RunTargetRequest) Reset 

func (x *RunTargetRequest) Reset()

func (*RunTargetRequest) String 

func (x *RunTargetRequest) String() string

type ShutdownRequest 

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

ark shutdown -- does not exist yet

func (*ShutdownRequest) Descriptor deprecated 

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

Deprecated: Use ShutdownRequest.ProtoReflect.Descriptor instead.

func (*ShutdownRequest) ProtoMessage 

func (*ShutdownRequest) ProtoMessage()

func (*ShutdownRequest) ProtoReflect 

func (x *ShutdownRequest) ProtoReflect() protoreflect.Message

func (*ShutdownRequest) Reset 

func (x *ShutdownRequest) Reset()

func (*ShutdownRequest) String 

func (x *ShutdownRequest) String() string

type ShutdownResponse 

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

func (*ShutdownResponse) Descriptor deprecated 

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

Deprecated: Use ShutdownResponse.ProtoReflect.Descriptor instead.

func (*ShutdownResponse) ProtoMessage 

func (*ShutdownResponse) ProtoMessage()

func (*ShutdownResponse) ProtoReflect 

func (x *ShutdownResponse) ProtoReflect() protoreflect.Message

func (*ShutdownResponse) Reset 

func (x *ShutdownResponse) Reset()

func (*ShutdownResponse) String 

func (x *ShutdownResponse) String() string

type Target 

type Target struct {
	Address        string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	ShortHash      string `protobuf:"bytes,2,opt,name=short_hash,json=shortHash,proto3" json:"short_hash,omitempty"`
	Hash           string `protobuf:"bytes,3,opt,name=hash,proto3" json:"hash,omitempty"`
	LocallyCached  bool   `protobuf:"varint,4,opt,name=locally_cached,json=locallyCached,proto3" json:"locally_cached,omitempty"`
	RemotelyCached bool   `protobuf:"varint,5,opt,name=remotely_cached,json=remotelyCached,proto3" json:"remotely_cached,omitempty"`
	Description    string `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

used for aggregating target information

func (*Target) Descriptor deprecated 

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

Deprecated: Use Target.ProtoReflect.Descriptor instead.

func (*Target) GetAddress 

func (x *Target) GetAddress() string

func (*Target) GetDescription 

func (x *Target) GetDescription() string

func (*Target) GetHash 

func (x *Target) GetHash() string

func (*Target) GetLocallyCached 

func (x *Target) GetLocallyCached() bool

func (*Target) GetRemotelyCached 

func (x *Target) GetRemotelyCached() bool

func (*Target) GetShortHash 

func (x *Target) GetShortHash() string

func (*Target) ProtoMessage 

func (*Target) ProtoMessage()

func (*Target) ProtoReflect 

func (x *Target) ProtoReflect() protoreflect.Message

func (*Target) Reset 

func (x *Target) Reset()

func (*Target) String 

func (x *Target) String() string

type UnimplementedHostServer 

type UnimplementedHostServer struct {
}

UnimplementedHostServer can be embedded to have forward compatible implementations.

func (*UnimplementedHostServer) AddWorkspace 

func (*UnimplementedHostServer) AddWorkspace(context.Context, *AddWorkspaceRequest) (*AddWorkspaceResponse, error)

func (*UnimplementedHostServer) CleanHostArtifacts 

func (*UnimplementedHostServer) CleanHostArtifacts(context.Context, *CleanHostArtifactsRequest) (*CleanHostArtifactsResponse, error)

func (*UnimplementedHostServer) ListTargets 

func (*UnimplementedHostServer) ListTargets(context.Context, *ListTargetsRequest) (*ListTargetsResponse, error)

func (*UnimplementedHostServer) PullArtifacts 

func (*UnimplementedHostServer) PullArtifacts(*PullArtifactsRequest, Host_PullArtifactsServer) error

func (*UnimplementedHostServer) PushArtifacts 

func (*UnimplementedHostServer) PushArtifacts(*PushArtifactsRequest, Host_PushArtifactsServer) error

func (*UnimplementedHostServer) RunTarget 

func (*UnimplementedHostServer) RunTarget(*RunTargetRequest, Host_RunTargetServer) error

func (*UnimplementedHostServer) Shutdown 

func (*UnimplementedHostServer) Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error)

func (*UnimplementedHostServer) ValidateWorkspace 

func (*UnimplementedHostServer) ValidateWorkspace(context.Context, *ValidateWorkspaceRequest) (*ValidateWorkspaceResponse, error)

func (*UnimplementedHostServer) WatchWorkspace 

func (*UnimplementedHostServer) WatchWorkspace(*WatchWorkspaceRequest, Host_WatchWorkspaceServer) error

type ValidateWorkspaceRequest 

type ValidateWorkspaceRequest struct {
	Root string `protobuf:"bytes,1,opt,name=root,proto3" json:"root,omitempty"`
	// contains filtered or unexported fields
}

ark validate workspace -- does not exist yet

func (*ValidateWorkspaceRequest) Descriptor deprecated 

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

Deprecated: Use ValidateWorkspaceRequest.ProtoReflect.Descriptor instead.

func (*ValidateWorkspaceRequest) GetRoot 

func (x *ValidateWorkspaceRequest) GetRoot() string

func (*ValidateWorkspaceRequest) ProtoMessage 

func (*ValidateWorkspaceRequest) ProtoMessage()

func (*ValidateWorkspaceRequest) ProtoReflect 

func (x *ValidateWorkspaceRequest) ProtoReflect() protoreflect.Message

func (*ValidateWorkspaceRequest) Reset 

func (x *ValidateWorkspaceRequest) Reset()

func (*ValidateWorkspaceRequest) String 

func (x *ValidateWorkspaceRequest) String() string

type ValidateWorkspaceResponse 

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

func (*ValidateWorkspaceResponse) Descriptor deprecated 

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

Deprecated: Use ValidateWorkspaceResponse.ProtoReflect.Descriptor instead.

func (*ValidateWorkspaceResponse) ProtoMessage 

func (*ValidateWorkspaceResponse) ProtoMessage()

func (*ValidateWorkspaceResponse) ProtoReflect 

func (x *ValidateWorkspaceResponse) ProtoReflect() protoreflect.Message

func (*ValidateWorkspaceResponse) Reset 

func (x *ValidateWorkspaceResponse) Reset()

func (*ValidateWorkspaceResponse) String 

func (x *ValidateWorkspaceResponse) String() string

type WatchWorkspaceRequest 

type WatchWorkspaceRequest struct {
	Root string `protobuf:"bytes,1,opt,name=root,proto3" json:"root,omitempty"`
	// contains filtered or unexported fields
}

ark watch -- does not exist yet

func (*WatchWorkspaceRequest) Descriptor deprecated 

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

Deprecated: Use WatchWorkspaceRequest.ProtoReflect.Descriptor instead.

func (*WatchWorkspaceRequest) GetRoot 

func (x *WatchWorkspaceRequest) GetRoot() string

func (*WatchWorkspaceRequest) ProtoMessage 

func (*WatchWorkspaceRequest) ProtoMessage()

func (*WatchWorkspaceRequest) ProtoReflect 

func (x *WatchWorkspaceRequest) ProtoReflect() protoreflect.Message

func (*WatchWorkspaceRequest) Reset 

func (x *WatchWorkspaceRequest) Reset()

func (*WatchWorkspaceRequest) String 

func (x *WatchWorkspaceRequest) String() string

Source Files

View all Source files

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.