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 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

Jump to

Keyboard shortcuts

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