pb

package
v0.0.0-...-84310d3 Latest Latest
Warning

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

 Go to latest Published: Jun 19, 2020 License: Apache-2.0 Imports: 5 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var LifecycleRequest_Req_name = map[int32]string{
	0: "CONNECT",
	1: "TERM",
	2: "PING",
	3: "PONG",
}
View Source 
var LifecycleRequest_Req_value = map[string]int32{
	"CONNECT": 0,
	"TERM":    1,
	"PING":    2,
	"PONG":    3,
}

Functions

func RegisterInventoryServer 

func RegisterInventoryServer(s *grpc.Server, srv InventoryServer)

func RegisterLifecycleServer 

func RegisterLifecycleServer(s *grpc.Server, srv LifecycleServer)

func RegisterRemoteServer 

func RegisterRemoteServer(s *grpc.Server, srv RemoteServer)

func RegisterRequestProcessorServer 

func RegisterRequestProcessorServer(s *grpc.Server, srv RequestProcessorServer)

Types

type Address 

type Address struct {
	// name associated with this address. primary, primary4, primary6, etc.
	Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	// The address
	Address              string   `protobuf:"bytes,2,opt,name=Address,proto3" json:"Address,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Address) Descriptor 

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

func (*Address) GetAddress 

func (m *Address) GetAddress() string

func (*Address) GetName 

func (m *Address) GetName() string

func (*Address) ProtoMessage 

func (*Address) ProtoMessage()

func (*Address) Reset 

func (m *Address) Reset()

func (*Address) String 

func (m *Address) String() string

func (*Address) XXX_DiscardUnknown 

func (m *Address) XXX_DiscardUnknown()

func (*Address) XXX_Marshal 

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

func (*Address) XXX_Merge 

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

func (*Address) XXX_Size 

func (m *Address) XXX_Size() int

func (*Address) XXX_Unmarshal 

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

type Args 

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

func (*Args) Descriptor 

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

func (*Args) GetArgs 

func (m *Args) GetArgs() []string

func (*Args) ProtoMessage 

func (*Args) ProtoMessage()

func (*Args) Reset 

func (m *Args) Reset()

func (*Args) String 

func (m *Args) String() string

func (*Args) XXX_DiscardUnknown 

func (m *Args) XXX_DiscardUnknown()

func (*Args) XXX_Marshal 

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

func (*Args) XXX_Merge 

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

func (*Args) XXX_Size 

func (m *Args) XXX_Size() int

func (*Args) XXX_Unmarshal 

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

type CfgRequest 

type CfgRequest struct {
	Session              string   `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	HostId               string   `protobuf:"bytes,2,opt,name=hostId,proto3" json:"hostId,omitempty"`
	Path                 string   `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Configuration request, using a json pointer

func (*CfgRequest) Descriptor 

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

func (*CfgRequest) GetHostId 

func (m *CfgRequest) GetHostId() string

func (*CfgRequest) GetPath 

func (m *CfgRequest) GetPath() string

func (*CfgRequest) GetSession 

func (m *CfgRequest) GetSession() string

func (*CfgRequest) ProtoMessage 

func (*CfgRequest) ProtoMessage()

func (*CfgRequest) Reset 

func (m *CfgRequest) Reset()

func (*CfgRequest) String 

func (m *CfgRequest) String() string

func (*CfgRequest) XXX_DiscardUnknown 

func (m *CfgRequest) XXX_DiscardUnknown()

func (*CfgRequest) XXX_Marshal 

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

func (*CfgRequest) XXX_Merge 

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

func (*CfgRequest) XXX_Size 

func (m *CfgRequest) XXX_Size() int

func (*CfgRequest) XXX_Unmarshal 

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

type CfgResponse 

type CfgResponse struct {
	Data                 []byte   `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Configuration response, contains JSON document. If the variable is not found, contains nil (empty array)

func (*CfgResponse) Descriptor 

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

func (*CfgResponse) GetData 

func (m *CfgResponse) GetData() []byte

func (*CfgResponse) ProtoMessage 

func (*CfgResponse) ProtoMessage()

func (*CfgResponse) Reset 

func (m *CfgResponse) Reset()

func (*CfgResponse) String 

func (m *CfgResponse) String() string

func (*CfgResponse) XXX_DiscardUnknown 

func (m *CfgResponse) XXX_DiscardUnknown()

func (*CfgResponse) XXX_Marshal 

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

func (*CfgResponse) XXX_Merge 

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

func (*CfgResponse) XXX_Size 

func (m *CfgResponse) XXX_Size() int

func (*CfgResponse) XXX_Unmarshal 

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

type ChmodRequest 

type ChmodRequest struct {
	Session              string   `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	HostId               string   `protobuf:"bytes,2,opt,name=hostId,proto3" json:"hostId,omitempty"`
	Path                 string   `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	Mode                 int32    `protobuf:"varint,4,opt,name=mode,proto3" json:"mode,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ChmodRequest) Descriptor 

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

func (*ChmodRequest) GetHostId 

func (m *ChmodRequest) GetHostId() string

func (*ChmodRequest) GetMode 

func (m *ChmodRequest) GetMode() int32

func (*ChmodRequest) GetPath 

func (m *ChmodRequest) GetPath() string

func (*ChmodRequest) GetSession 

func (m *ChmodRequest) GetSession() string

func (*ChmodRequest) ProtoMessage 

func (*ChmodRequest) ProtoMessage()

func (*ChmodRequest) Reset 

func (m *ChmodRequest) Reset()

func (*ChmodRequest) String 

func (m *ChmodRequest) String() string

func (*ChmodRequest) XXX_DiscardUnknown 

func (m *ChmodRequest) XXX_DiscardUnknown()

func (*ChmodRequest) XXX_Marshal 

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

func (*ChmodRequest) XXX_Merge 

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

func (*ChmodRequest) XXX_Size 

func (m *ChmodRequest) XXX_Size() int

func (*ChmodRequest) XXX_Unmarshal 

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

type ChownRequest 

type ChownRequest struct {
	Session              string   `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	HostId               string   `protobuf:"bytes,2,opt,name=hostId,proto3" json:"hostId,omitempty"`
	Path                 string   `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	User                 string   `protobuf:"bytes,4,opt,name=user,proto3" json:"user,omitempty"`
	Group                string   `protobuf:"bytes,5,opt,name=group,proto3" json:"group,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ChownRequest) Descriptor 

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

func (*ChownRequest) GetGroup 

func (m *ChownRequest) GetGroup() string

func (*ChownRequest) GetHostId 

func (m *ChownRequest) GetHostId() string

func (*ChownRequest) GetPath 

func (m *ChownRequest) GetPath() string

func (*ChownRequest) GetSession 

func (m *ChownRequest) GetSession() string

func (*ChownRequest) GetUser 

func (m *ChownRequest) GetUser() string

func (*ChownRequest) ProtoMessage 

func (*ChownRequest) ProtoMessage()

func (*ChownRequest) Reset 

func (m *ChownRequest) Reset()

func (*ChownRequest) String 

func (m *ChownRequest) String() string

func (*ChownRequest) XXX_DiscardUnknown 

func (m *ChownRequest) XXX_DiscardUnknown()

func (*ChownRequest) XXX_Marshal 

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

func (*ChownRequest) XXX_Merge 

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

func (*ChownRequest) XXX_Size 

func (m *ChownRequest) XXX_Size() int

func (*ChownRequest) XXX_Unmarshal 

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

type CommandError 

type CommandError struct {
	Host                 string   `protobuf:"bytes,1,opt,name=Host,proto3" json:"Host,omitempty"`
	Msg                  string   `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CommandError

func (*CommandError) Descriptor 

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

func (*CommandError) GetHost 

func (m *CommandError) GetHost() string

func (*CommandError) GetMsg 

func (m *CommandError) GetMsg() string

func (*CommandError) ProtoMessage 

func (*CommandError) ProtoMessage()

func (*CommandError) Reset 

func (m *CommandError) Reset()

func (*CommandError) String 

func (m *CommandError) String() string

func (*CommandError) XXX_DiscardUnknown 

func (m *CommandError) XXX_DiscardUnknown()

func (*CommandError) XXX_Marshal 

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

func (*CommandError) XXX_Merge 

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

func (*CommandError) XXX_Size 

func (m *CommandError) XXX_Size() int

func (*CommandError) XXX_Unmarshal 

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

type CommandRequest 

type CommandRequest struct {
	Session              string   `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	HostId               string   `protobuf:"bytes,2,opt,name=hostId,proto3" json:"hostId,omitempty"`
	Command              string   `protobuf:"bytes,3,opt,name=command,proto3" json:"command,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Execute a command on a remote host

func (*CommandRequest) Descriptor 

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

func (*CommandRequest) GetCommand 

func (m *CommandRequest) GetCommand() string

func (*CommandRequest) GetHostId 

func (m *CommandRequest) GetHostId() string

func (*CommandRequest) GetSession 

func (m *CommandRequest) GetSession() string

func (*CommandRequest) ProtoMessage 

func (*CommandRequest) ProtoMessage()

func (*CommandRequest) Reset 

func (m *CommandRequest) Reset()

func (*CommandRequest) String 

func (m *CommandRequest) String() string

func (*CommandRequest) XXX_DiscardUnknown 

func (m *CommandRequest) XXX_DiscardUnknown()

func (*CommandRequest) XXX_Marshal 

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

func (*CommandRequest) XXX_Merge 

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

func (*CommandRequest) XXX_Size 

func (m *CommandRequest) XXX_Size() int

func (*CommandRequest) XXX_Unmarshal 

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

type CommandResponse 

type CommandResponse struct {
	Stdout               []byte   `protobuf:"bytes,1,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr               []byte   `protobuf:"bytes,2,opt,name=stderr,proto3" json:"stderr,omitempty"`
	ExitCode             int64    `protobuf:"varint,3,opt,name=exitCode,proto3" json:"exitCode,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response of a remote command execution

func (*CommandResponse) Descriptor 

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

func (*CommandResponse) GetExitCode 

func (m *CommandResponse) GetExitCode() int64

func (*CommandResponse) GetStderr 

func (m *CommandResponse) GetStderr() []byte

func (*CommandResponse) GetStdout 

func (m *CommandResponse) GetStdout() []byte

func (*CommandResponse) ProtoMessage 

func (*CommandResponse) ProtoMessage()

func (*CommandResponse) Reset 

func (m *CommandResponse) Reset()

func (*CommandResponse) String 

func (m *CommandResponse) String() string

func (*CommandResponse) XXX_DiscardUnknown 

func (m *CommandResponse) XXX_DiscardUnknown()

func (*CommandResponse) XXX_Marshal 

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

func (*CommandResponse) XXX_Merge 

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

func (*CommandResponse) XXX_Size 

func (m *CommandResponse) XXX_Size() int

func (*CommandResponse) XXX_Unmarshal 

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

type Connect 

type Connect struct {
	Port                 int32    `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Connect message sent from the module to the server to notify the grpc port listening on the module to receive requests along with the module name.

func (*Connect) Descriptor 

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

func (*Connect) GetPort 

func (m *Connect) GetPort() int32

func (*Connect) ProtoMessage 

func (*Connect) ProtoMessage()

func (*Connect) Reset 

func (m *Connect) Reset()

func (*Connect) String 

func (m *Connect) String() string

func (*Connect) XXX_DiscardUnknown 

func (m *Connect) XXX_DiscardUnknown()

func (*Connect) XXX_Marshal 

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

func (*Connect) XXX_Merge 

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

func (*Connect) XXX_Size 

func (m *Connect) XXX_Size() int

func (*Connect) XXX_Unmarshal 

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

type CopyRequest 

type CopyRequest struct {
	Session              string   `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	FromHost             string   `protobuf:"bytes,2,opt,name=fromHost,proto3" json:"fromHost,omitempty"`
	FromPath             string   `protobuf:"bytes,3,opt,name=fromPath,proto3" json:"fromPath,omitempty"`
	ToHost               string   `protobuf:"bytes,4,opt,name=toHost,proto3" json:"toHost,omitempty"`
	ToPath               string   `protobuf:"bytes,5,opt,name=toPath,proto3" json:"toPath,omitempty"`
	OnlyIfDifferent      bool     `protobuf:"varint,6,opt,name=onlyIfDifferent,proto3" json:"onlyIfDifferent,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CopyRequest) Descriptor 

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

func (*CopyRequest) GetFromHost 

func (m *CopyRequest) GetFromHost() string

func (*CopyRequest) GetFromPath 

func (m *CopyRequest) GetFromPath() string

func (*CopyRequest) GetOnlyIfDifferent 

func (m *CopyRequest) GetOnlyIfDifferent() bool

func (*CopyRequest) GetSession 

func (m *CopyRequest) GetSession() string

func (*CopyRequest) GetToHost 

func (m *CopyRequest) GetToHost() string

func (*CopyRequest) GetToPath 

func (m *CopyRequest) GetToPath() string

func (*CopyRequest) ProtoMessage 

func (*CopyRequest) ProtoMessage()

func (*CopyRequest) Reset 

func (m *CopyRequest) Reset()

func (*CopyRequest) String 

func (m *CopyRequest) String() string

func (*CopyRequest) XXX_DiscardUnknown 

func (m *CopyRequest) XXX_DiscardUnknown()

func (*CopyRequest) XXX_Marshal 

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

func (*CopyRequest) XXX_Merge 

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

func (*CopyRequest) XXX_Size 

func (m *CopyRequest) XXX_Size() int

func (*CopyRequest) XXX_Unmarshal 

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

type CopyResponse 

type CopyResponse struct {
	Changed              bool          `protobuf:"varint,1,opt,name=changed,proto3" json:"changed,omitempty"`
	Error                *CommandError `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*CopyResponse) Descriptor 

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

func (*CopyResponse) GetChanged 

func (m *CopyResponse) GetChanged() bool

func (*CopyResponse) GetError 

func (m *CopyResponse) GetError() *CommandError

func (*CopyResponse) ProtoMessage 

func (*CopyResponse) ProtoMessage()

func (*CopyResponse) Reset 

func (m *CopyResponse) Reset()

func (*CopyResponse) String 

func (m *CopyResponse) String() string

func (*CopyResponse) XXX_DiscardUnknown 

func (m *CopyResponse) XXX_DiscardUnknown()

func (*CopyResponse) XXX_Marshal 

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

func (*CopyResponse) XXX_Merge 

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

func (*CopyResponse) XXX_Size 

func (m *CopyResponse) XXX_Size() int

func (*CopyResponse) XXX_Unmarshal 

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

type Empty 

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Empty) Descriptor 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

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

func (*Empty) XXX_Merge 

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

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

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

type EnsureRequest 

type EnsureRequest struct {
	Path                 string   `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Mode                 int32    `protobuf:"varint,3,opt,name=mode,proto3" json:"mode,omitempty"`
	SetMode              bool     `protobuf:"varint,4,opt,name=setMode,proto3" json:"setMode,omitempty"`
	Uid                  string   `protobuf:"bytes,5,opt,name=uid,proto3" json:"uid,omitempty"`
	SetUid               bool     `protobuf:"varint,6,opt,name=setUid,proto3" json:"setUid,omitempty"`
	Gid                  string   `protobuf:"bytes,7,opt,name=gid,proto3" json:"gid,omitempty"`
	SetGid               bool     `protobuf:"varint,8,opt,name=setGid,proto3" json:"setGid,omitempty"`
	User                 string   `protobuf:"bytes,9,opt,name=user,proto3" json:"user,omitempty"`
	SetUser              bool     `protobuf:"varint,10,opt,name=setUser,proto3" json:"setUser,omitempty"`
	Group                string   `protobuf:"bytes,11,opt,name=group,proto3" json:"group,omitempty"`
	SetGroup             bool     `protobuf:"varint,12,opt,name=setGroup,proto3" json:"setGroup,omitempty"`
	Dir                  bool     `protobuf:"varint,13,opt,name=dir,proto3" json:"dir,omitempty"`
	CheckDir             bool     `protobuf:"varint,14,opt,name=checkDir,proto3" json:"checkDir,omitempty"`
	Session              string   `protobuf:"bytes,20,opt,name=session,proto3" json:"session,omitempty"`
	HostId               string   `protobuf:"bytes,21,opt,name=hostId,proto3" json:"hostId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EnsureRequest) Descriptor 

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

func (*EnsureRequest) GetCheckDir 

func (m *EnsureRequest) GetCheckDir() bool

func (*EnsureRequest) GetDir 

func (m *EnsureRequest) GetDir() bool

func (*EnsureRequest) GetGid 

func (m *EnsureRequest) GetGid() string

func (*EnsureRequest) GetGroup 

func (m *EnsureRequest) GetGroup() string

func (*EnsureRequest) GetHostId 

func (m *EnsureRequest) GetHostId() string

func (*EnsureRequest) GetMode 

func (m *EnsureRequest) GetMode() int32

func (*EnsureRequest) GetPath 

func (m *EnsureRequest) GetPath() string

func (*EnsureRequest) GetSession 

func (m *EnsureRequest) GetSession() string

func (*EnsureRequest) GetSetGid 

func (m *EnsureRequest) GetSetGid() bool

func (*EnsureRequest) GetSetGroup 

func (m *EnsureRequest) GetSetGroup() bool

func (*EnsureRequest) GetSetMode 

func (m *EnsureRequest) GetSetMode() bool

func (*EnsureRequest) GetSetUid 

func (m *EnsureRequest) GetSetUid() bool

func (*EnsureRequest) GetSetUser 

func (m *EnsureRequest) GetSetUser() bool

func (*EnsureRequest) GetUid 

func (m *EnsureRequest) GetUid() string

func (*EnsureRequest) GetUser 

func (m *EnsureRequest) GetUser() string

func (*EnsureRequest) ProtoMessage 

func (*EnsureRequest) ProtoMessage()

func (*EnsureRequest) Reset 

func (m *EnsureRequest) Reset()

func (*EnsureRequest) String 

func (m *EnsureRequest) String() string

func (*EnsureRequest) XXX_DiscardUnknown 

func (m *EnsureRequest) XXX_DiscardUnknown()

func (*EnsureRequest) XXX_Marshal 

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

func (*EnsureRequest) XXX_Merge 

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

func (*EnsureRequest) XXX_Size 

func (m *EnsureRequest) XXX_Size() int

func (*EnsureRequest) XXX_Unmarshal 

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

type EnsureResponse 

type EnsureResponse struct {
	Changed              bool          `protobuf:"varint,1,opt,name=changed,proto3" json:"changed,omitempty"`
	Error                *CommandError `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*EnsureResponse) Descriptor 

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

func (*EnsureResponse) GetChanged 

func (m *EnsureResponse) GetChanged() bool

func (*EnsureResponse) GetError 

func (m *EnsureResponse) GetError() *CommandError

func (*EnsureResponse) ProtoMessage 

func (*EnsureResponse) ProtoMessage()

func (*EnsureResponse) Reset 

func (m *EnsureResponse) Reset()

func (*EnsureResponse) String 

func (m *EnsureResponse) String() string

func (*EnsureResponse) XXX_DiscardUnknown 

func (m *EnsureResponse) XXX_DiscardUnknown()

func (*EnsureResponse) XXX_Marshal 

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

func (*EnsureResponse) XXX_Merge 

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

func (*EnsureResponse) XXX_Size 

func (m *EnsureResponse) XXX_Size() int

func (*EnsureResponse) XXX_Unmarshal 

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

type FileInfo 

type FileInfo struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Size                 int64    `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	Mode                 int32    `protobuf:"varint,3,opt,name=mode,proto3" json:"mode,omitempty"`
	Time                 int64    `protobuf:"varint,4,opt,name=time,proto3" json:"time,omitempty"`
	Dir                  bool     `protobuf:"varint,5,opt,name=dir,proto3" json:"dir,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FileInfo) Descriptor 

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

func (*FileInfo) GetDir 

func (m *FileInfo) GetDir() bool

func (*FileInfo) GetMode 

func (m *FileInfo) GetMode() int32

func (*FileInfo) GetName 

func (m *FileInfo) GetName() string

func (*FileInfo) GetSize 

func (m *FileInfo) GetSize() int64

func (*FileInfo) GetTime 

func (m *FileInfo) GetTime() int64

func (*FileInfo) ProtoMessage 

func (*FileInfo) ProtoMessage()

func (*FileInfo) Reset 

func (m *FileInfo) Reset()

func (*FileInfo) String 

func (m *FileInfo) String() string

func (*FileInfo) XXX_DiscardUnknown 

func (m *FileInfo) XXX_DiscardUnknown()

func (*FileInfo) XXX_Marshal 

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

func (*FileInfo) XXX_Merge 

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

func (*FileInfo) XXX_Size 

func (m *FileInfo) XXX_Size() int

func (*FileInfo) XXX_Unmarshal 

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

type FileOwner 

type FileOwner struct {
	OwnerName            string   `protobuf:"bytes,1,opt,name=OwnerName,proto3" json:"OwnerName,omitempty"`
	OwnerID              string   `protobuf:"bytes,2,opt,name=OwnerID,proto3" json:"OwnerID,omitempty"`
	GroupName            string   `protobuf:"bytes,3,opt,name=GroupName,proto3" json:"GroupName,omitempty"`
	GroupID              string   `protobuf:"bytes,4,opt,name=GroupID,proto3" json:"GroupID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FileOwner) Descriptor 

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

func (*FileOwner) GetGroupID 

func (m *FileOwner) GetGroupID() string

func (*FileOwner) GetGroupName 

func (m *FileOwner) GetGroupName() string

func (*FileOwner) GetOwnerID 

func (m *FileOwner) GetOwnerID() string

func (*FileOwner) GetOwnerName 

func (m *FileOwner) GetOwnerName() string

func (*FileOwner) ProtoMessage 

func (*FileOwner) ProtoMessage()

func (*FileOwner) Reset 

func (m *FileOwner) Reset()

func (*FileOwner) String 

func (m *FileOwner) String() string

func (*FileOwner) XXX_DiscardUnknown 

func (m *FileOwner) XXX_DiscardUnknown()

func (*FileOwner) XXX_Marshal 

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

func (*FileOwner) XXX_Merge 

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

func (*FileOwner) XXX_Size 

func (m *FileOwner) XXX_Size() int

func (*FileOwner) XXX_Unmarshal 

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

type GetFileInfoResponse 

type GetFileInfoResponse struct {
	Owner                *FileOwner    `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	Info                 *FileInfo     `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	Error                *CommandError `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*GetFileInfoResponse) Descriptor 

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

func (*GetFileInfoResponse) GetError 

func (m *GetFileInfoResponse) GetError() *CommandError

func (*GetFileInfoResponse) GetInfo 

func (m *GetFileInfoResponse) GetInfo() *FileInfo

func (*GetFileInfoResponse) GetOwner 

func (m *GetFileInfoResponse) GetOwner() *FileOwner

func (*GetFileInfoResponse) ProtoMessage 

func (*GetFileInfoResponse) ProtoMessage()

func (*GetFileInfoResponse) Reset 

func (m *GetFileInfoResponse) Reset()

func (*GetFileInfoResponse) String 

func (m *GetFileInfoResponse) String() string

func (*GetFileInfoResponse) XXX_DiscardUnknown 

func (m *GetFileInfoResponse) XXX_DiscardUnknown()

func (*GetFileInfoResponse) XXX_Marshal 

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

func (*GetFileInfoResponse) XXX_Merge 

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

func (*GetFileInfoResponse) XXX_Size 

func (m *GetFileInfoResponse) XXX_Size() int

func (*GetFileInfoResponse) XXX_Unmarshal 

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

type HostIdSet 

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

HostIdSet defines a set of host ids to use in a host selector

func (*HostIdSet) Descriptor 

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

func (*HostIdSet) GetIDs 

func (m *HostIdSet) GetIDs() []string

func (*HostIdSet) ProtoMessage 

func (*HostIdSet) ProtoMessage()

func (*HostIdSet) Reset 

func (m *HostIdSet) Reset()

func (*HostIdSet) String 

func (m *HostIdSet) String() string

func (*HostIdSet) XXX_DiscardUnknown 

func (m *HostIdSet) XXX_DiscardUnknown()

func (*HostIdSet) XXX_Marshal 

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

func (*HostIdSet) XXX_Merge 

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

func (*HostIdSet) XXX_Size 

func (m *HostIdSet) XXX_Size() int

func (*HostIdSet) XXX_Unmarshal 

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

type HostIds 

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

HostIds contains a set of host ids

func (*HostIds) Descriptor 

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

func (*HostIds) GetHostIds 

func (m *HostIds) GetHostIds() []string

func (*HostIds) GetSession 

func (m *HostIds) GetSession() string

func (*HostIds) ProtoMessage 

func (*HostIds) ProtoMessage()

func (*HostIds) Reset 

func (m *HostIds) Reset()

func (*HostIds) String 

func (m *HostIds) String() string

func (*HostIds) XXX_DiscardUnknown 

func (m *HostIds) XXX_DiscardUnknown()

func (*HostIds) XXX_Marshal 

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

func (*HostIds) XXX_Merge 

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

func (*HostIds) XXX_Size 

func (m *HostIds) XXX_Size() int

func (*HostIds) XXX_Unmarshal 

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

type HostInfo 

type HostInfo struct {
	// HostId is the unique identifier for this host. It could be fqdn,
	// ip, or any other symbolic name
	ID        string     `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Addresses []*Address `protobuf:"bytes,3,rep,name=Addresses,proto3" json:"Addresses,omitempty"`
	// labels associated with this host
	Labels []string `protobuf:"bytes,4,rep,name=Labels,proto3" json:"Labels,omitempty"`
	// key-value pairs associated with this host
	Properties           map[string]string `` /* 161-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

HostInfo describes a host.

func (*HostInfo) Descriptor 

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

func (*HostInfo) GetAddresses 

func (m *HostInfo) GetAddresses() []*Address

func (*HostInfo) GetID 

func (m *HostInfo) GetID() string

func (*HostInfo) GetLabels 

func (m *HostInfo) GetLabels() []string

func (*HostInfo) GetProperties 

func (m *HostInfo) GetProperties() map[string]string

func (*HostInfo) ProtoMessage 

func (*HostInfo) ProtoMessage()

func (*HostInfo) Reset 

func (m *HostInfo) Reset()

func (*HostInfo) String 

func (m *HostInfo) String() string

func (*HostInfo) XXX_DiscardUnknown 

func (m *HostInfo) XXX_DiscardUnknown()

func (*HostInfo) XXX_Marshal 

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

func (*HostInfo) XXX_Merge 

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

func (*HostInfo) XXX_Size 

func (m *HostInfo) XXX_Size() int

func (*HostInfo) XXX_Unmarshal 

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

type HostInfos 

type HostInfos struct {
	// Requested host information
	HostInfos            []*HostInfo `protobuf:"bytes,1,rep,name=HostInfos,proto3" json:"HostInfos,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

HostInfos contains a set of host infos

func (*HostInfos) Descriptor 

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

func (*HostInfos) GetHostInfos 

func (m *HostInfos) GetHostInfos() []*HostInfo

func (*HostInfos) ProtoMessage 

func (*HostInfos) ProtoMessage()

func (*HostInfos) Reset 

func (m *HostInfos) Reset()

func (*HostInfos) String 

func (m *HostInfos) String() string

func (*HostInfos) XXX_DiscardUnknown 

func (m *HostInfos) XXX_DiscardUnknown()

func (*HostInfos) XXX_Marshal 

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

func (*HostInfos) XXX_Merge 

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

func (*HostInfos) XXX_Size 

func (m *HostInfos) XXX_Size() int

func (*HostInfos) XXX_Unmarshal 

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

type InvAddRequest 

type InvAddRequest struct {
	Inv                  string     `protobuf:"bytes,1,opt,name=Inv,proto3" json:"Inv,omitempty"`
	Hosts                *HostIdSet `protobuf:"bytes,2,opt,name=Hosts,proto3" json:"Hosts,omitempty"`
	Session              string     `protobuf:"bytes,3,opt,name=Session,proto3" json:"Session,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

Add a host to inventory

func (*InvAddRequest) Descriptor 

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

func (*InvAddRequest) GetHosts 

func (m *InvAddRequest) GetHosts() *HostIdSet

func (*InvAddRequest) GetInv 

func (m *InvAddRequest) GetInv() string

func (*InvAddRequest) GetSession 

func (m *InvAddRequest) GetSession() string

func (*InvAddRequest) ProtoMessage 

func (*InvAddRequest) ProtoMessage()

func (*InvAddRequest) Reset 

func (m *InvAddRequest) Reset()

func (*InvAddRequest) String 

func (m *InvAddRequest) String() string

func (*InvAddRequest) XXX_DiscardUnknown 

func (m *InvAddRequest) XXX_DiscardUnknown()

func (*InvAddRequest) XXX_Marshal 

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

func (*InvAddRequest) XXX_Merge 

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

func (*InvAddRequest) XXX_Size 

func (m *InvAddRequest) XXX_Size() int

func (*InvAddRequest) XXX_Unmarshal 

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

type InvId 

type InvId struct {
	// id identifies a set of hosts. id="all" is the inventory containing
	// all known hosts
	ID                   string   `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

InvId contains an inventory id

func (*InvId) Descriptor 

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

func (*InvId) GetID 

func (m *InvId) GetID() string

func (*InvId) ProtoMessage 

func (*InvId) ProtoMessage()

func (*InvId) Reset 

func (m *InvId) Reset()

func (*InvId) String 

func (m *InvId) String() string

func (*InvId) XXX_DiscardUnknown 

func (m *InvId) XXX_DiscardUnknown()

func (*InvId) XXX_Marshal 

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

func (*InvId) XXX_Merge 

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

func (*InvId) XXX_Size 

func (m *InvId) XXX_Size() int

func (*InvId) XXX_Unmarshal 

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

type InvIdRequest 

type InvIdRequest struct {
	// id identifies a set of hosts. id="all" is the inventory containing
	// all known hosts
	ID                   string   `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Session              string   `protobuf:"bytes,2,opt,name=Session,proto3" json:"Session,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

InvIdRequest contains an inventory id

func (*InvIdRequest) Descriptor 

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

func (*InvIdRequest) GetID 

func (m *InvIdRequest) GetID() string

func (*InvIdRequest) GetSession 

func (m *InvIdRequest) GetSession() string

func (*InvIdRequest) ProtoMessage 

func (*InvIdRequest) ProtoMessage()

func (*InvIdRequest) Reset 

func (m *InvIdRequest) Reset()

func (*InvIdRequest) String 

func (m *InvIdRequest) String() string

func (*InvIdRequest) XXX_DiscardUnknown 

func (m *InvIdRequest) XXX_DiscardUnknown()

func (*InvIdRequest) XXX_Marshal 

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

func (*InvIdRequest) XXX_Merge 

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

func (*InvIdRequest) XXX_Size 

func (m *InvIdRequest) XXX_Size() int

func (*InvIdRequest) XXX_Unmarshal 

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

type InvSelectRequest 

type InvSelectRequest struct {
	// Select from which inventory
	From string `protobuf:"bytes,1,opt,name=From,proto3" json:"From,omitempty"`
	// Describe how to select from the inventory. Hosts
	// matching all these selectors will be included
	Sel                  []*Selector `protobuf:"bytes,3,rep,name=Sel,proto3" json:"Sel,omitempty"`
	Session              string      `protobuf:"bytes,4,opt,name=Session,proto3" json:"Session,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

InvSelectRequest is used to select a subset of hosts from an inventory

func (*InvSelectRequest) Descriptor 

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

func (*InvSelectRequest) GetFrom 

func (m *InvSelectRequest) GetFrom() string

func (*InvSelectRequest) GetSel 

func (m *InvSelectRequest) GetSel() []*Selector

func (*InvSelectRequest) GetSession 

func (m *InvSelectRequest) GetSession() string

func (*InvSelectRequest) ProtoMessage 

func (*InvSelectRequest) ProtoMessage()

func (*InvSelectRequest) Reset 

func (m *InvSelectRequest) Reset()

func (*InvSelectRequest) String 

func (m *InvSelectRequest) String() string

func (*InvSelectRequest) XXX_DiscardUnknown 

func (m *InvSelectRequest) XXX_DiscardUnknown()

func (*InvSelectRequest) XXX_Marshal 

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

func (*InvSelectRequest) XXX_Merge 

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

func (*InvSelectRequest) XXX_Size 

func (m *InvSelectRequest) XXX_Size() int

func (*InvSelectRequest) XXX_Unmarshal 

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

type InvUnionRequest 

type InvUnionRequest struct {
	// Combine these inventories
	Sources              []string `protobuf:"bytes,1,rep,name=Sources,proto3" json:"Sources,omitempty"`
	Session              string   `protobuf:"bytes,2,opt,name=Session,proto3" json:"Session,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InvUnionRequest) Descriptor 

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

func (*InvUnionRequest) GetSession 

func (m *InvUnionRequest) GetSession() string

func (*InvUnionRequest) GetSources 

func (m *InvUnionRequest) GetSources() []string

func (*InvUnionRequest) ProtoMessage 

func (*InvUnionRequest) ProtoMessage()

func (*InvUnionRequest) Reset 

func (m *InvUnionRequest) Reset()

func (*InvUnionRequest) String 

func (m *InvUnionRequest) String() string

func (*InvUnionRequest) XXX_DiscardUnknown 

func (m *InvUnionRequest) XXX_DiscardUnknown()

func (*InvUnionRequest) XXX_Marshal 

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

func (*InvUnionRequest) XXX_Merge 

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

func (*InvUnionRequest) XXX_Size 

func (m *InvUnionRequest) XXX_Size() int

func (*InvUnionRequest) XXX_Unmarshal 

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

type InventoryClient 

type InventoryClient interface {
	// Selects a subset of an inventory based on the given criteria, and
	// returns a new inventory id representing the subset
	Select(ctx context.Context, in *InvSelectRequest, opts ...grpc.CallOption) (*InvId, error)
	// Union takes a union of a set of inventories and returns a new inventory
	// containing all the hosts in the combined inventories
	Union(ctx context.Context, in *InvUnionRequest, opts ...grpc.CallOption) (*InvId, error)
	// Make creates a new inventory containing the given hosts
	Make(ctx context.Context, in *HostIds, opts ...grpc.CallOption) (*InvId, error)
	// Adds new hosts to an inventory
	Add(ctx context.Context, in *InvAddRequest, opts ...grpc.CallOption) (*InvId, error)
	// Returns the host ids for all the hosts in an inventory
	GetHostIds(ctx context.Context, in *InvIdRequest, opts ...grpc.CallOption) (*HostIds, error)
	// Returns information about some hosts
	GetHostInfo(ctx context.Context, in *HostIds, opts ...grpc.CallOption) (*HostInfos, error)
	// Returns all hosts in an inventory
	GetHosts(ctx context.Context, in *InvIdRequest, opts ...grpc.CallOption) (*HostInfos, error)
	// Release notifies the server that this inventory is no longer needed
	Release(ctx context.Context, in *InvIdRequest, opts ...grpc.CallOption) (*Empty, error)
}

InventoryClient is the client API for Inventory service.

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

func NewInventoryClient 

func NewInventoryClient(cc *grpc.ClientConn) InventoryClient

type InventoryServer 

type InventoryServer interface {
	// Selects a subset of an inventory based on the given criteria, and
	// returns a new inventory id representing the subset
	Select(context.Context, *InvSelectRequest) (*InvId, error)
	// Union takes a union of a set of inventories and returns a new inventory
	// containing all the hosts in the combined inventories
	Union(context.Context, *InvUnionRequest) (*InvId, error)
	// Make creates a new inventory containing the given hosts
	Make(context.Context, *HostIds) (*InvId, error)
	// Adds new hosts to an inventory
	Add(context.Context, *InvAddRequest) (*InvId, error)
	// Returns the host ids for all the hosts in an inventory
	GetHostIds(context.Context, *InvIdRequest) (*HostIds, error)
	// Returns information about some hosts
	GetHostInfo(context.Context, *HostIds) (*HostInfos, error)
	// Returns all hosts in an inventory
	GetHosts(context.Context, *InvIdRequest) (*HostInfos, error)
	// Release notifies the server that this inventory is no longer needed
	Release(context.Context, *InvIdRequest) (*Empty, error)
}

InventoryServer is the server API for Inventory service.

type LabelSet 

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

LabelSet defines a set of labels to use in a host selector

func (*LabelSet) Descriptor 

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

func (*LabelSet) GetLabels 

func (m *LabelSet) GetLabels() []string

func (*LabelSet) ProtoMessage 

func (*LabelSet) ProtoMessage()

func (*LabelSet) Reset 

func (m *LabelSet) Reset()

func (*LabelSet) String 

func (m *LabelSet) String() string

func (*LabelSet) XXX_DiscardUnknown 

func (m *LabelSet) XXX_DiscardUnknown()

func (*LabelSet) XXX_Marshal 

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

func (*LabelSet) XXX_Merge 

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

func (*LabelSet) XXX_Size 

func (m *LabelSet) XXX_Size() int

func (*LabelSet) XXX_Unmarshal 

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

type LifecycleClient 

type LifecycleClient interface {
	// Connect sends the initial request to the server to connect. Then
	// the module waits for lifecycle management messages from server LifecycleRequest
	// stream.
	Connect(ctx context.Context, opts ...grpc.CallOption) (Lifecycle_ConnectClient, error)
	// Make a module call. If the module call runs, but the command returns
	// an errors (e.g. runs a command on a host, but that command returns error), the
	// error information is returned in Response. If somehow the execution of
	// the function fails (e.g. cannot dial to host), that is returned as grpc error.
	ModuleCall(ctx context.Context, in *ModuleWorkRequest, opts ...grpc.CallOption) (*Response, error)
	// Log for a host
	Log(ctx context.Context, in *LogRequest, opts ...grpc.CallOption) (*Empty, error)
	// Print a msg on server console
	Print(ctx context.Context, in *LogRequest, opts ...grpc.CallOption) (*Empty, error)
	// Get configuration
	GetCfg(ctx context.Context, in *CfgRequest, opts ...grpc.CallOption) (*CfgResponse, error)
	// Get arguments to the program
	GetArgs(ctx context.Context, in *Session, opts ...grpc.CallOption) (*Args, error)
	// Loads a module by its name, and returns the GRPC location for the module
	// Use this to setup a direct GRPC link to the module
	LoadModule(ctx context.Context, in *LoadModuleRequest, opts ...grpc.CallOption) (*LoadModuleResponse, error)
}

LifecycleClient is the client API for Lifecycle service.

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

func NewLifecycleClient 

func NewLifecycleClient(cc *grpc.ClientConn) LifecycleClient

type LifecycleRequest 

type LifecycleRequest struct {
	RequestType LifecycleRequest_Req `protobuf:"varint,1,opt,name=requestType,proto3,enum=pb.LifecycleRequest_Req" json:"requestType,omitempty"`
	// Types that are valid to be assigned to Msg:
	//	*LifecycleRequest_ConnectMsg
	Msg                  isLifecycleRequest_Msg `protobuf_oneof:"msg"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*LifecycleRequest) Descriptor 

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

func (*LifecycleRequest) GetConnectMsg 

func (m *LifecycleRequest) GetConnectMsg() *Connect

func (*LifecycleRequest) GetMsg 

func (m *LifecycleRequest) GetMsg() isLifecycleRequest_Msg

func (*LifecycleRequest) GetRequestType 

func (m *LifecycleRequest) GetRequestType() LifecycleRequest_Req

func (*LifecycleRequest) ProtoMessage 

func (*LifecycleRequest) ProtoMessage()

func (*LifecycleRequest) Reset 

func (m *LifecycleRequest) Reset()

func (*LifecycleRequest) String 

func (m *LifecycleRequest) String() string

func (*LifecycleRequest) XXX_DiscardUnknown 

func (m *LifecycleRequest) XXX_DiscardUnknown()

func (*LifecycleRequest) XXX_Marshal 

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

func (*LifecycleRequest) XXX_Merge 

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

func (*LifecycleRequest) XXX_OneofFuncs 

func (*LifecycleRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*LifecycleRequest) XXX_Size 

func (m *LifecycleRequest) XXX_Size() int

func (*LifecycleRequest) XXX_Unmarshal 

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

type LifecycleRequest_ConnectMsg 

type LifecycleRequest_ConnectMsg struct {
	ConnectMsg *Connect `protobuf:"bytes,2,opt,name=connectMsg,proto3,oneof"`
}

type LifecycleRequest_Req 

type LifecycleRequest_Req int32
const (
	LifecycleRequest_CONNECT LifecycleRequest_Req = 0
	LifecycleRequest_TERM    LifecycleRequest_Req = 1
	LifecycleRequest_PING    LifecycleRequest_Req = 2
	LifecycleRequest_PONG    LifecycleRequest_Req = 3
)

func (LifecycleRequest_Req) EnumDescriptor 

func (LifecycleRequest_Req) EnumDescriptor() ([]byte, []int)

func (LifecycleRequest_Req) String 

func (x LifecycleRequest_Req) String() string

type LifecycleServer 

type LifecycleServer interface {
	// Connect sends the initial request to the server to connect. Then
	// the module waits for lifecycle management messages from server LifecycleRequest
	// stream.
	Connect(Lifecycle_ConnectServer) error
	// Make a module call. If the module call runs, but the command returns
	// an errors (e.g. runs a command on a host, but that command returns error), the
	// error information is returned in Response. If somehow the execution of
	// the function fails (e.g. cannot dial to host), that is returned as grpc error.
	ModuleCall(context.Context, *ModuleWorkRequest) (*Response, error)
	// Log for a host
	Log(context.Context, *LogRequest) (*Empty, error)
	// Print a msg on server console
	Print(context.Context, *LogRequest) (*Empty, error)
	// Get configuration
	GetCfg(context.Context, *CfgRequest) (*CfgResponse, error)
	// Get arguments to the program
	GetArgs(context.Context, *Session) (*Args, error)
	// Loads a module by its name, and returns the GRPC location for the module
	// Use this to setup a direct GRPC link to the module
	LoadModule(context.Context, *LoadModuleRequest) (*LoadModuleResponse, error)
}

LifecycleServer is the server API for Lifecycle service.

type Lifecycle_ConnectClient 

type Lifecycle_ConnectClient interface {
	Send(*LifecycleRequest) error
	Recv() (*LifecycleRequest, error)
	grpc.ClientStream
}

type Lifecycle_ConnectServer 

type Lifecycle_ConnectServer interface {
	Send(*LifecycleRequest) error
	Recv() (*LifecycleRequest, error)
	grpc.ServerStream
}

type LoadModuleRequest 

type LoadModuleRequest struct {
	Module               string   `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LoadModuleRequest) Descriptor 

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

func (*LoadModuleRequest) GetModule 

func (m *LoadModuleRequest) GetModule() string

func (*LoadModuleRequest) ProtoMessage 

func (*LoadModuleRequest) ProtoMessage()

func (*LoadModuleRequest) Reset 

func (m *LoadModuleRequest) Reset()

func (*LoadModuleRequest) String 

func (m *LoadModuleRequest) String() string

func (*LoadModuleRequest) XXX_DiscardUnknown 

func (m *LoadModuleRequest) XXX_DiscardUnknown()

func (*LoadModuleRequest) XXX_Marshal 

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

func (*LoadModuleRequest) XXX_Merge 

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

func (*LoadModuleRequest) XXX_Size 

func (m *LoadModuleRequest) XXX_Size() int

func (*LoadModuleRequest) XXX_Unmarshal 

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

type LoadModuleResponse 

type LoadModuleResponse struct {
	Address              string   `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LoadModuleResponse) Descriptor 

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

func (*LoadModuleResponse) GetAddress 

func (m *LoadModuleResponse) GetAddress() string

func (*LoadModuleResponse) ProtoMessage 

func (*LoadModuleResponse) ProtoMessage()

func (*LoadModuleResponse) Reset 

func (m *LoadModuleResponse) Reset()

func (*LoadModuleResponse) String 

func (m *LoadModuleResponse) String() string

func (*LoadModuleResponse) XXX_DiscardUnknown 

func (m *LoadModuleResponse) XXX_DiscardUnknown()

func (*LoadModuleResponse) XXX_Marshal 

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

func (*LoadModuleResponse) XXX_Merge 

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

func (*LoadModuleResponse) XXX_Size 

func (m *LoadModuleResponse) XXX_Size() int

func (*LoadModuleResponse) XXX_Unmarshal 

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

type LogRequest 

type LogRequest struct {
	Session              string   `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	HostId               string   `protobuf:"bytes,2,opt,name=hostId,proto3" json:"hostId,omitempty"`
	Msg                  string   `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

LogRequest has the host id and log msg

func (*LogRequest) Descriptor 

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

func (*LogRequest) GetHostId 

func (m *LogRequest) GetHostId() string

func (*LogRequest) GetMsg 

func (m *LogRequest) GetMsg() string

func (*LogRequest) GetSession 

func (m *LogRequest) GetSession() string

func (*LogRequest) ProtoMessage 

func (*LogRequest) ProtoMessage()

func (*LogRequest) Reset 

func (m *LogRequest) Reset()

func (*LogRequest) String 

func (m *LogRequest) String() string

func (*LogRequest) XXX_DiscardUnknown 

func (m *LogRequest) XXX_DiscardUnknown()

func (*LogRequest) XXX_Marshal 

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

func (*LogRequest) XXX_Merge 

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

func (*LogRequest) XXX_Size 

func (m *LogRequest) XXX_Size() int

func (*LogRequest) XXX_Unmarshal 

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

type ModuleWorkRequest 

type ModuleWorkRequest struct {
	// Name of the module to call
	ModuleName string `protobuf:"bytes,1,opt,name=moduleName,proto3" json:"moduleName,omitempty"`
	// Request contains the function name to call, and the parameters to the function
	Req                  *Request `protobuf:"bytes,2,opt,name=req,proto3" json:"req,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ModuleWorkRequest selects a module to call, and sends a request to that module.

func (*ModuleWorkRequest) Descriptor 

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

func (*ModuleWorkRequest) GetModuleName 

func (m *ModuleWorkRequest) GetModuleName() string

func (*ModuleWorkRequest) GetReq 

func (m *ModuleWorkRequest) GetReq() *Request

func (*ModuleWorkRequest) ProtoMessage 

func (*ModuleWorkRequest) ProtoMessage()

func (*ModuleWorkRequest) Reset 

func (m *ModuleWorkRequest) Reset()

func (*ModuleWorkRequest) String 

func (m *ModuleWorkRequest) String() string

func (*ModuleWorkRequest) XXX_DiscardUnknown 

func (m *ModuleWorkRequest) XXX_DiscardUnknown()

func (*ModuleWorkRequest) XXX_Marshal 

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

func (*ModuleWorkRequest) XXX_Merge 

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

func (*ModuleWorkRequest) XXX_Size 

func (m *ModuleWorkRequest) XXX_Size() int

func (*ModuleWorkRequest) XXX_Unmarshal 

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

type OSResponse 

type OSResponse struct {
	Error                *CommandError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*OSResponse) Descriptor 

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

func (*OSResponse) GetError 

func (m *OSResponse) GetError() *CommandError

func (*OSResponse) ProtoMessage 

func (*OSResponse) ProtoMessage()

func (*OSResponse) Reset 

func (m *OSResponse) Reset()

func (*OSResponse) String 

func (m *OSResponse) String() string

func (*OSResponse) XXX_DiscardUnknown 

func (m *OSResponse) XXX_DiscardUnknown()

func (*OSResponse) XXX_Marshal 

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

func (*OSResponse) XXX_Merge 

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

func (*OSResponse) XXX_Size 

func (m *OSResponse) XXX_Size() int

func (*OSResponse) XXX_Unmarshal 

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

type PathRequest 

type PathRequest struct {
	Session              string   `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	HostId               string   `protobuf:"bytes,2,opt,name=hostId,proto3" json:"hostId,omitempty"`
	Path                 string   `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PathRequest) Descriptor 

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

func (*PathRequest) GetHostId 

func (m *PathRequest) GetHostId() string

func (*PathRequest) GetPath 

func (m *PathRequest) GetPath() string

func (*PathRequest) GetSession 

func (m *PathRequest) GetSession() string

func (*PathRequest) ProtoMessage 

func (*PathRequest) ProtoMessage()

func (*PathRequest) Reset 

func (m *PathRequest) Reset()

func (*PathRequest) String 

func (m *PathRequest) String() string

func (*PathRequest) XXX_DiscardUnknown 

func (m *PathRequest) XXX_DiscardUnknown()

func (*PathRequest) XXX_Marshal 

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

func (*PathRequest) XXX_Merge 

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

func (*PathRequest) XXX_Size 

func (m *PathRequest) XXX_Size() int

func (*PathRequest) XXX_Unmarshal 

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

type PropertySet 

type PropertySet struct {
	Properties           []*PropertySet_KVS `protobuf:"bytes,1,rep,name=Properties,proto3" json:"Properties,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

PropertySet defines a set of property key-value pairs to select hosts

func (*PropertySet) Descriptor 

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

func (*PropertySet) GetProperties 

func (m *PropertySet) GetProperties() []*PropertySet_KVS

func (*PropertySet) ProtoMessage 

func (*PropertySet) ProtoMessage()

func (*PropertySet) Reset 

func (m *PropertySet) Reset()

func (*PropertySet) String 

func (m *PropertySet) String() string

func (*PropertySet) XXX_DiscardUnknown 

func (m *PropertySet) XXX_DiscardUnknown()

func (*PropertySet) XXX_Marshal 

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

func (*PropertySet) XXX_Merge 

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

func (*PropertySet) XXX_Size 

func (m *PropertySet) XXX_Size() int

func (*PropertySet) XXX_Unmarshal 

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

type PropertySet_KVS 

type PropertySet_KVS struct {
	Key string `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	// Select hosts that has any of the given values for the key
	Values               []string `protobuf:"bytes,2,rep,name=Values,proto3" json:"Values,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PropertySet_KVS) Descriptor 

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

func (*PropertySet_KVS) GetKey 

func (m *PropertySet_KVS) GetKey() string

func (*PropertySet_KVS) GetValues 

func (m *PropertySet_KVS) GetValues() []string

func (*PropertySet_KVS) ProtoMessage 

func (*PropertySet_KVS) ProtoMessage()

func (*PropertySet_KVS) Reset 

func (m *PropertySet_KVS) Reset()

func (*PropertySet_KVS) String 

func (m *PropertySet_KVS) String() string

func (*PropertySet_KVS) XXX_DiscardUnknown 

func (m *PropertySet_KVS) XXX_DiscardUnknown()

func (*PropertySet_KVS) XXX_Marshal 

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

func (*PropertySet_KVS) XXX_Merge 

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

func (*PropertySet_KVS) XXX_Size 

func (m *PropertySet_KVS) XXX_Size() int

func (*PropertySet_KVS) XXX_Unmarshal 

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

type ReadRequest 

type ReadRequest struct {
	Session              string   `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	HostId               string   `protobuf:"bytes,2,opt,name=hostId,proto3" json:"hostId,omitempty"`
	File                 string   `protobuf:"bytes,3,opt,name=file,proto3" json:"file,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadRequest) Descriptor 

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

func (*ReadRequest) GetFile 

func (m *ReadRequest) GetFile() string

func (*ReadRequest) GetHostId 

func (m *ReadRequest) GetHostId() string

func (*ReadRequest) GetSession 

func (m *ReadRequest) GetSession() string

func (*ReadRequest) ProtoMessage 

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) Reset 

func (m *ReadRequest) Reset()

func (*ReadRequest) String 

func (m *ReadRequest) String() string

func (*ReadRequest) XXX_DiscardUnknown 

func (m *ReadRequest) XXX_DiscardUnknown()

func (*ReadRequest) XXX_Marshal 

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

func (*ReadRequest) XXX_Merge 

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

func (*ReadRequest) XXX_Size 

func (m *ReadRequest) XXX_Size() int

func (*ReadRequest) XXX_Unmarshal 

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

type ReadResponse 

type ReadResponse struct {
	Data                 []byte        `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Size                 int64         `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	Info                 *FileInfo     `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	Found                bool          `protobuf:"varint,4,opt,name=found,proto3" json:"found,omitempty"`
	Error                *CommandError `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

ReadResponse is processes as a stream. Only the first received block contains file info, remaining segments only contain the data.

func (*ReadResponse) Descriptor 

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

func (*ReadResponse) GetData 

func (m *ReadResponse) GetData() []byte

func (*ReadResponse) GetError 

func (m *ReadResponse) GetError() *CommandError

func (*ReadResponse) GetFound 

func (m *ReadResponse) GetFound() bool

func (*ReadResponse) GetInfo 

func (m *ReadResponse) GetInfo() *FileInfo

func (*ReadResponse) GetSize 

func (m *ReadResponse) GetSize() int64

func (*ReadResponse) ProtoMessage 

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) Reset 

func (m *ReadResponse) Reset()

func (*ReadResponse) String 

func (m *ReadResponse) String() string

func (*ReadResponse) XXX_DiscardUnknown 

func (m *ReadResponse) XXX_DiscardUnknown()

func (*ReadResponse) XXX_Marshal 

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

func (*ReadResponse) XXX_Merge 

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

func (*ReadResponse) XXX_Size 

func (m *ReadResponse) XXX_Size() int

func (*ReadResponse) XXX_Unmarshal 

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

type RemoteClient 

type RemoteClient interface {
	Command(ctx context.Context, in *CommandRequest, opts ...grpc.CallOption) (*CommandResponse, error)
	ReadFile(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error)
	WriteFile(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error)
	Template(ctx context.Context, in *TemplateRequest, opts ...grpc.CallOption) (*TemplateResponse, error)
	CopyFile(ctx context.Context, in *CopyRequest, opts ...grpc.CallOption) (*CopyResponse, error)
	WaitHost(ctx context.Context, in *WaitHostRequest, opts ...grpc.CallOption) (*Empty, error)
	GetFileInfo(ctx context.Context, in *PathRequest, opts ...grpc.CallOption) (*GetFileInfoResponse, error)
	Mkdir(ctx context.Context, in *PathRequest, opts ...grpc.CallOption) (*OSResponse, error)
	Chmod(ctx context.Context, in *ChmodRequest, opts ...grpc.CallOption) (*OSResponse, error)
	Chown(ctx context.Context, in *ChownRequest, opts ...grpc.CallOption) (*OSResponse, error)
	Ensure(ctx context.Context, in *EnsureRequest, opts ...grpc.CallOption) (*EnsureResponse, error)
}

RemoteClient is the client API for Remote service.

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

func NewRemoteClient 

func NewRemoteClient(cc *grpc.ClientConn) RemoteClient

type RemoteServer 

type RemoteServer interface {
	Command(context.Context, *CommandRequest) (*CommandResponse, error)
	ReadFile(context.Context, *ReadRequest) (*ReadResponse, error)
	WriteFile(context.Context, *WriteRequest) (*WriteResponse, error)
	Template(context.Context, *TemplateRequest) (*TemplateResponse, error)
	CopyFile(context.Context, *CopyRequest) (*CopyResponse, error)
	WaitHost(context.Context, *WaitHostRequest) (*Empty, error)
	GetFileInfo(context.Context, *PathRequest) (*GetFileInfoResponse, error)
	Mkdir(context.Context, *PathRequest) (*OSResponse, error)
	Chmod(context.Context, *ChmodRequest) (*OSResponse, error)
	Chown(context.Context, *ChownRequest) (*OSResponse, error)
	Ensure(context.Context, *EnsureRequest) (*EnsureResponse, error)
}

RemoteServer is the server API for Remote service.

type Request 

type Request struct {
	// The current session ID
	Session string `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	// The function to call in the module
	FuncName string `protobuf:"bytes,2,opt,name=funcName,proto3" json:"funcName,omitempty"`
	// A JSON document describing the parameters to the function. The structure
	// of the JSON document depends on the function.
	Data                 []byte   `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request is a request sent to a function implemented by a module.

func (*Request) Descriptor 

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

func (*Request) GetData 

func (m *Request) GetData() []byte

func (*Request) GetFuncName 

func (m *Request) GetFuncName() string

func (*Request) GetSession 

func (m *Request) GetSession() string

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) String 

func (m *Request) String() string

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

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

func (*Request) XXX_Merge 

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

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

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

type RequestProcessorClient 

type RequestProcessorClient interface {
	Process(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
}

RequestProcessorClient is the client API for RequestProcessor service.

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

func NewRequestProcessorClient 

func NewRequestProcessorClient(cc *grpc.ClientConn) RequestProcessorClient

type RequestProcessorServer 

type RequestProcessorServer interface {
	Process(context.Context, *Request) (*Response, error)
}

RequestProcessorServer is the server API for RequestProcessor service.

type Response 

type Response struct {
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	FuncName             string   `protobuf:"bytes,2,opt,name=funcName,proto3" json:"funcName,omitempty"`
	ErrorMsg             string   `protobuf:"bytes,3,opt,name=errorMsg,proto3" json:"errorMsg,omitempty"`
	Modified             bool     `protobuf:"varint,4,opt,name=modified,proto3" json:"modified,omitempty"`
	Data                 []byte   `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response is returned from a module function. If the module function executes but the result is an error, then the errorMsg field contains that error, but the call returns success. If somehow the module function cannot be called, or if the module function encounters an error that prevents execution, that is returned as error from the function

func (*Response) Descriptor 

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

func (*Response) GetData 

func (m *Response) GetData() []byte

func (*Response) GetErrorMsg 

func (m *Response) GetErrorMsg() string

func (*Response) GetFuncName 

func (m *Response) GetFuncName() string

func (*Response) GetModified 

func (m *Response) GetModified() bool

func (*Response) GetSuccess 

func (m *Response) GetSuccess() bool

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) String 

func (m *Response) String() string

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

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

func (*Response) XXX_Merge 

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

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

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

type Selector 

type Selector struct {
	// Types that are valid to be assigned to Select:
	//	*Selector_HasAllLabels
	//	*Selector_HasAnyLabel
	//	*Selector_HasNoneLabels
	//	*Selector_ByID
	//	*Selector_HasAnyProperty
	//	*Selector_HasAllProperty
	Select               isSelector_Select `protobuf_oneof:"select"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Selector contains one of the host selection methods

func (*Selector) Descriptor 

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

func (*Selector) GetByID 

func (m *Selector) GetByID() *HostIdSet

func (*Selector) GetHasAllLabels 

func (m *Selector) GetHasAllLabels() *LabelSet

func (*Selector) GetHasAllProperty 

func (m *Selector) GetHasAllProperty() *PropertySet

func (*Selector) GetHasAnyLabel 

func (m *Selector) GetHasAnyLabel() *LabelSet

func (*Selector) GetHasAnyProperty 

func (m *Selector) GetHasAnyProperty() *PropertySet

func (*Selector) GetHasNoneLabels 

func (m *Selector) GetHasNoneLabels() *LabelSet

func (*Selector) GetSelect 

func (m *Selector) GetSelect() isSelector_Select

func (*Selector) ProtoMessage 

func (*Selector) ProtoMessage()

func (*Selector) Reset 

func (m *Selector) Reset()

func (*Selector) String 

func (m *Selector) String() string

func (*Selector) XXX_DiscardUnknown 

func (m *Selector) XXX_DiscardUnknown()

func (*Selector) XXX_Marshal 

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

func (*Selector) XXX_Merge 

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

func (*Selector) XXX_OneofFuncs 

func (*Selector) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Selector) XXX_Size 

func (m *Selector) XXX_Size() int

func (*Selector) XXX_Unmarshal 

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

type Selector_ByID 

type Selector_ByID struct {
	ByID *HostIdSet `protobuf:"bytes,4,opt,name=ByID,proto3,oneof"`
}

type Selector_HasAllLabels 

type Selector_HasAllLabels struct {
	HasAllLabels *LabelSet `protobuf:"bytes,1,opt,name=HasAllLabels,proto3,oneof"`
}

type Selector_HasAllProperty 

type Selector_HasAllProperty struct {
	HasAllProperty *PropertySet `protobuf:"bytes,7,opt,name=HasAllProperty,proto3,oneof"`
}

type Selector_HasAnyLabel 

type Selector_HasAnyLabel struct {
	HasAnyLabel *LabelSet `protobuf:"bytes,2,opt,name=HasAnyLabel,proto3,oneof"`
}

type Selector_HasAnyProperty 

type Selector_HasAnyProperty struct {
	HasAnyProperty *PropertySet `protobuf:"bytes,6,opt,name=HasAnyProperty,proto3,oneof"`
}

type Selector_HasNoneLabels 

type Selector_HasNoneLabels struct {
	HasNoneLabels *LabelSet `protobuf:"bytes,3,opt,name=HasNoneLabels,proto3,oneof"`
}

type Session 

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

func (*Session) Descriptor 

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

func (*Session) GetSession 

func (m *Session) GetSession() string

func (*Session) ProtoMessage 

func (*Session) ProtoMessage()

func (*Session) Reset 

func (m *Session) Reset()

func (*Session) String 

func (m *Session) String() string

func (*Session) XXX_DiscardUnknown 

func (m *Session) XXX_DiscardUnknown()

func (*Session) XXX_Marshal 

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

func (*Session) XXX_Merge 

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

func (*Session) XXX_Size 

func (m *Session) XXX_Size() int

func (*Session) XXX_Unmarshal 

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

type TemplateRequest 

type TemplateRequest struct {
	Template             string   `protobuf:"bytes,2,opt,name=template,proto3" json:"template,omitempty"`
	Data                 []byte   `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TemplateRequest) Descriptor 

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

func (*TemplateRequest) GetData 

func (m *TemplateRequest) GetData() []byte

func (*TemplateRequest) GetTemplate 

func (m *TemplateRequest) GetTemplate() string

func (*TemplateRequest) ProtoMessage 

func (*TemplateRequest) ProtoMessage()

func (*TemplateRequest) Reset 

func (m *TemplateRequest) Reset()

func (*TemplateRequest) String 

func (m *TemplateRequest) String() string

func (*TemplateRequest) XXX_DiscardUnknown 

func (m *TemplateRequest) XXX_DiscardUnknown()

func (*TemplateRequest) XXX_Marshal 

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

func (*TemplateRequest) XXX_Merge 

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

func (*TemplateRequest) XXX_Size 

func (m *TemplateRequest) XXX_Size() int

func (*TemplateRequest) XXX_Unmarshal 

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

type TemplateResponse 

type TemplateResponse struct {
	Out                  string        `protobuf:"bytes,1,opt,name=out,proto3" json:"out,omitempty"`
	Error                *CommandError `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*TemplateResponse) Descriptor 

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

func (*TemplateResponse) GetError 

func (m *TemplateResponse) GetError() *CommandError

func (*TemplateResponse) GetOut 

func (m *TemplateResponse) GetOut() string

func (*TemplateResponse) ProtoMessage 

func (*TemplateResponse) ProtoMessage()

func (*TemplateResponse) Reset 

func (m *TemplateResponse) Reset()

func (*TemplateResponse) String 

func (m *TemplateResponse) String() string

func (*TemplateResponse) XXX_DiscardUnknown 

func (m *TemplateResponse) XXX_DiscardUnknown()

func (*TemplateResponse) XXX_Marshal 

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

func (*TemplateResponse) XXX_Merge 

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

func (*TemplateResponse) XXX_Size 

func (m *TemplateResponse) XXX_Size() int

func (*TemplateResponse) XXX_Unmarshal 

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

type WaitHostRequest 

type WaitHostRequest struct {
	Session              string   `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	HostId               string   `protobuf:"bytes,2,opt,name=hostId,proto3" json:"hostId,omitempty"`
	Timeout              int64    `protobuf:"varint,3,opt,name=timeout,proto3" json:"timeout,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

WaitHostRequest is used to wait until host becomes available.

func (*WaitHostRequest) Descriptor 

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

func (*WaitHostRequest) GetHostId 

func (m *WaitHostRequest) GetHostId() string

func (*WaitHostRequest) GetSession 

func (m *WaitHostRequest) GetSession() string

func (*WaitHostRequest) GetTimeout 

func (m *WaitHostRequest) GetTimeout() int64

func (*WaitHostRequest) ProtoMessage 

func (*WaitHostRequest) ProtoMessage()

func (*WaitHostRequest) Reset 

func (m *WaitHostRequest) Reset()

func (*WaitHostRequest) String 

func (m *WaitHostRequest) String() string

func (*WaitHostRequest) XXX_DiscardUnknown 

func (m *WaitHostRequest) XXX_DiscardUnknown()

func (*WaitHostRequest) XXX_Marshal 

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

func (*WaitHostRequest) XXX_Merge 

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

func (*WaitHostRequest) XXX_Size 

func (m *WaitHostRequest) XXX_Size() int

func (*WaitHostRequest) XXX_Unmarshal 

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

type WriteRequest 

type WriteRequest struct {
	Session         string `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	HostId          string `protobuf:"bytes,2,opt,name=hostId,proto3" json:"hostId,omitempty"`
	Perms           int64  `protobuf:"varint,4,opt,name=perms,proto3" json:"perms,omitempty"`
	Name            string `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`
	OnlyIfDifferent bool   `protobuf:"varint,7,opt,name=onlyIfDifferent,proto3" json:"onlyIfDifferent,omitempty"`
	// Types that are valid to be assigned to Source:
	//	*WriteRequest_Data
	//	*WriteRequest_Template
	Source               isWriteRequest_Source `protobuf_oneof:"source"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

WriteRequest

func (*WriteRequest) Descriptor 

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

func (*WriteRequest) GetData 

func (m *WriteRequest) GetData() []byte

func (*WriteRequest) GetHostId 

func (m *WriteRequest) GetHostId() string

func (*WriteRequest) GetName 

func (m *WriteRequest) GetName() string

func (*WriteRequest) GetOnlyIfDifferent 

func (m *WriteRequest) GetOnlyIfDifferent() bool

func (*WriteRequest) GetPerms 

func (m *WriteRequest) GetPerms() int64

func (*WriteRequest) GetSession 

func (m *WriteRequest) GetSession() string

func (*WriteRequest) GetSource 

func (m *WriteRequest) GetSource() isWriteRequest_Source

func (*WriteRequest) GetTemplate 

func (m *WriteRequest) GetTemplate() *TemplateRequest

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) Reset 

func (m *WriteRequest) Reset()

func (*WriteRequest) String 

func (m *WriteRequest) String() string

func (*WriteRequest) XXX_DiscardUnknown 

func (m *WriteRequest) XXX_DiscardUnknown()

func (*WriteRequest) XXX_Marshal 

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

func (*WriteRequest) XXX_Merge 

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

func (*WriteRequest) XXX_OneofFuncs 

func (*WriteRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*WriteRequest) XXX_Size 

func (m *WriteRequest) XXX_Size() int

func (*WriteRequest) XXX_Unmarshal 

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

type WriteRequest_Data 

type WriteRequest_Data struct {
	Data []byte `protobuf:"bytes,8,opt,name=data,proto3,oneof"`
}

type WriteRequest_Template 

type WriteRequest_Template struct {
	Template *TemplateRequest `protobuf:"bytes,9,opt,name=template,proto3,oneof"`
}

type WriteResponse 

type WriteResponse struct {
	Modified             bool          `protobuf:"varint,1,opt,name=modified,proto3" json:"modified,omitempty"`
	Error                *CommandError `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*WriteResponse) Descriptor 

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

func (*WriteResponse) GetError 

func (m *WriteResponse) GetError() *CommandError

func (*WriteResponse) GetModified 

func (m *WriteResponse) GetModified() bool

func (*WriteResponse) ProtoMessage 

func (*WriteResponse) ProtoMessage()

func (*WriteResponse) Reset 

func (m *WriteResponse) Reset()

func (*WriteResponse) String 

func (m *WriteResponse) String() string

func (*WriteResponse) XXX_DiscardUnknown 

func (m *WriteResponse) XXX_DiscardUnknown()

func (*WriteResponse) XXX_Marshal 

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

func (*WriteResponse) XXX_Merge 

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

func (*WriteResponse) XXX_Size 

func (m *WriteResponse) XXX_Size() int

func (*WriteResponse) XXX_Unmarshal 

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

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.