rpc

package
Version: v1.0.0 Latest Latest
Warning

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

Go to latest
Published: Dec 22, 2016 License: Apache-2.0 Imports: 7 Imported by: 21

Documentation

Overview

Package rpc is a generated protocol buffer package.

It is generated from these files:

fleet.proto

It has these top-level messages:

HealthCheckRequest
HealthCheckResponse
MachineProperties
UpdatedState
UnitStateFilter
UnitFilter
ScheduleUnitRequest
UnscheduleUnitRequest
SaveUnitStateRequest
Heartbeat
GenericReply
Units
UnitStates
UnitState
ScheduledUnits
ScheduledUnit
UnitName
Unit
MaybeScheduledUnit
MaybeUnit
NotFound
UnitFile
UnitOption

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthFleet = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowFleet   = fmt.Errorf("proto: integer overflow")
)
View Source
var HealthCheckResponse_ServingStatus_name = map[int32]string{
	0: "UNKNOWN",
	1: "SERVING",
	2: "NOT_SERVING",
}
View Source
var HealthCheckResponse_ServingStatus_value = map[string]int32{
	"UNKNOWN":     0,
	"SERVING":     1,
	"NOT_SERVING": 2,
}
View Source
var TargetState_name = map[int32]string{
	0: "INACTIVE",
	1: "LOADED",
	2: "LAUNCHED",
}
View Source
var TargetState_value = map[string]int32{
	"INACTIVE": 0,
	"LOADED":   1,
	"LAUNCHED": 2,
}

Functions

func RegisterRegistryServer

func RegisterRegistryServer(s *grpc.Server, srv RegistryServer)

Types

type GenericReply

type GenericReply struct {
}

func (*GenericReply) Descriptor

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

func (*GenericReply) Marshal

func (m *GenericReply) Marshal() (dAtA []byte, err error)

func (*GenericReply) MarshalTo

func (m *GenericReply) MarshalTo(dAtA []byte) (int, error)

func (*GenericReply) ProtoMessage

func (*GenericReply) ProtoMessage()

func (*GenericReply) Reset

func (m *GenericReply) Reset()

func (*GenericReply) Size

func (m *GenericReply) Size() (n int)

func (*GenericReply) String

func (m *GenericReply) String() string

func (*GenericReply) Unmarshal

func (m *GenericReply) Unmarshal(dAtA []byte) error

type HealthCheckRequest

type HealthCheckRequest struct {
	Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
}

func (*HealthCheckRequest) Descriptor

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

func (*HealthCheckRequest) Marshal

func (m *HealthCheckRequest) Marshal() (dAtA []byte, err error)

func (*HealthCheckRequest) MarshalTo

func (m *HealthCheckRequest) MarshalTo(dAtA []byte) (int, error)

func (*HealthCheckRequest) ProtoMessage

func (*HealthCheckRequest) ProtoMessage()

func (*HealthCheckRequest) Reset

func (m *HealthCheckRequest) Reset()

func (*HealthCheckRequest) Size

func (m *HealthCheckRequest) Size() (n int)

func (*HealthCheckRequest) String

func (m *HealthCheckRequest) String() string

func (*HealthCheckRequest) Unmarshal

func (m *HealthCheckRequest) Unmarshal(dAtA []byte) error

type HealthCheckResponse

type HealthCheckResponse struct {
	Status HealthCheckResponse_ServingStatus `protobuf:"varint,1,opt,name=status,proto3,enum=rpc.HealthCheckResponse_ServingStatus" json:"status,omitempty"`
}

func (*HealthCheckResponse) Descriptor

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

func (*HealthCheckResponse) Marshal

func (m *HealthCheckResponse) Marshal() (dAtA []byte, err error)

func (*HealthCheckResponse) MarshalTo

func (m *HealthCheckResponse) MarshalTo(dAtA []byte) (int, error)

func (*HealthCheckResponse) ProtoMessage

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) Reset

func (m *HealthCheckResponse) Reset()

func (*HealthCheckResponse) Size

func (m *HealthCheckResponse) Size() (n int)

func (*HealthCheckResponse) String

func (m *HealthCheckResponse) String() string

func (*HealthCheckResponse) Unmarshal

func (m *HealthCheckResponse) Unmarshal(dAtA []byte) error

type HealthCheckResponse_ServingStatus

type HealthCheckResponse_ServingStatus int32
const (
	HealthCheckResponse_UNKNOWN     HealthCheckResponse_ServingStatus = 0
	HealthCheckResponse_SERVING     HealthCheckResponse_ServingStatus = 1
	HealthCheckResponse_NOT_SERVING HealthCheckResponse_ServingStatus = 2
)

func (HealthCheckResponse_ServingStatus) EnumDescriptor

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

func (HealthCheckResponse_ServingStatus) String

type Heartbeat

type Heartbeat struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	MachineID string `protobuf:"bytes,2,opt,name=machine_id,json=machineId,proto3" json:"machine_id,omitempty"`
	TTL       int32  `protobuf:"varint,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
}

func (*Heartbeat) Descriptor

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

func (*Heartbeat) Marshal

func (m *Heartbeat) Marshal() (dAtA []byte, err error)

func (*Heartbeat) MarshalTo

func (m *Heartbeat) MarshalTo(dAtA []byte) (int, error)

func (*Heartbeat) ProtoMessage

func (*Heartbeat) ProtoMessage()

func (*Heartbeat) Reset

func (m *Heartbeat) Reset()

func (*Heartbeat) Size

func (m *Heartbeat) Size() (n int)

func (*Heartbeat) String

func (m *Heartbeat) String() string

func (*Heartbeat) Unmarshal

func (m *Heartbeat) Unmarshal(dAtA []byte) error

type MachineProperties

type MachineProperties struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}

func (*MachineProperties) Descriptor

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

func (*MachineProperties) Marshal

func (m *MachineProperties) Marshal() (dAtA []byte, err error)

func (*MachineProperties) MarshalTo

func (m *MachineProperties) MarshalTo(dAtA []byte) (int, error)

func (*MachineProperties) ProtoMessage

func (*MachineProperties) ProtoMessage()

func (*MachineProperties) Reset

func (m *MachineProperties) Reset()

func (*MachineProperties) Size

func (m *MachineProperties) Size() (n int)

func (*MachineProperties) String

func (m *MachineProperties) String() string

func (*MachineProperties) Unmarshal

func (m *MachineProperties) Unmarshal(dAtA []byte) error

type MaybeScheduledUnit

type MaybeScheduledUnit struct {
	// Types that are valid to be assigned to IsScheduled:
	//	*MaybeScheduledUnit_Unit
	//	*MaybeScheduledUnit_Notfound
	IsScheduled isMaybeScheduledUnit_IsScheduled `protobuf_oneof:"is_scheduled"`
}

func (*MaybeScheduledUnit) Descriptor

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

func (*MaybeScheduledUnit) GetIsScheduled

func (m *MaybeScheduledUnit) GetIsScheduled() isMaybeScheduledUnit_IsScheduled

func (*MaybeScheduledUnit) GetNotfound

func (m *MaybeScheduledUnit) GetNotfound() *NotFound

func (*MaybeScheduledUnit) GetUnit

func (m *MaybeScheduledUnit) GetUnit() *ScheduledUnit

func (*MaybeScheduledUnit) Marshal

func (m *MaybeScheduledUnit) Marshal() (dAtA []byte, err error)

func (*MaybeScheduledUnit) MarshalTo

func (m *MaybeScheduledUnit) MarshalTo(dAtA []byte) (int, error)

func (*MaybeScheduledUnit) ProtoMessage

func (*MaybeScheduledUnit) ProtoMessage()

func (*MaybeScheduledUnit) Reset

func (m *MaybeScheduledUnit) Reset()

func (*MaybeScheduledUnit) Size

func (m *MaybeScheduledUnit) Size() (n int)

func (*MaybeScheduledUnit) String

func (m *MaybeScheduledUnit) String() string

func (*MaybeScheduledUnit) Unmarshal

func (m *MaybeScheduledUnit) Unmarshal(dAtA []byte) error

func (*MaybeScheduledUnit) XXX_OneofFuncs

func (*MaybeScheduledUnit) 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.

type MaybeScheduledUnit_Notfound

type MaybeScheduledUnit_Notfound struct {
	Notfound *NotFound `protobuf:"bytes,2,opt,name=notfound,oneof"`
}

func (*MaybeScheduledUnit_Notfound) MarshalTo

func (m *MaybeScheduledUnit_Notfound) MarshalTo(dAtA []byte) (int, error)

func (*MaybeScheduledUnit_Notfound) Size

func (m *MaybeScheduledUnit_Notfound) Size() (n int)

type MaybeScheduledUnit_Unit

type MaybeScheduledUnit_Unit struct {
	Unit *ScheduledUnit `protobuf:"bytes,1,opt,name=unit,oneof"`
}

func (*MaybeScheduledUnit_Unit) MarshalTo

func (m *MaybeScheduledUnit_Unit) MarshalTo(dAtA []byte) (int, error)

func (*MaybeScheduledUnit_Unit) Size

func (m *MaybeScheduledUnit_Unit) Size() (n int)

type MaybeUnit

type MaybeUnit struct {
	// Types that are valid to be assigned to HasUnit:
	//	*MaybeUnit_Unit
	//	*MaybeUnit_Notfound
	HasUnit isMaybeUnit_HasUnit `protobuf_oneof:"has_unit"`
}

func (*MaybeUnit) Descriptor

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

func (*MaybeUnit) GetHasUnit

func (m *MaybeUnit) GetHasUnit() isMaybeUnit_HasUnit

func (*MaybeUnit) GetNotfound

func (m *MaybeUnit) GetNotfound() *NotFound

func (*MaybeUnit) GetUnit

func (m *MaybeUnit) GetUnit() *Unit

func (*MaybeUnit) Marshal

func (m *MaybeUnit) Marshal() (dAtA []byte, err error)

func (*MaybeUnit) MarshalTo

func (m *MaybeUnit) MarshalTo(dAtA []byte) (int, error)

func (*MaybeUnit) ProtoMessage

func (*MaybeUnit) ProtoMessage()

func (*MaybeUnit) Reset

func (m *MaybeUnit) Reset()

func (*MaybeUnit) Size

func (m *MaybeUnit) Size() (n int)

func (*MaybeUnit) String

func (m *MaybeUnit) String() string

func (*MaybeUnit) Unmarshal

func (m *MaybeUnit) Unmarshal(dAtA []byte) error

func (*MaybeUnit) XXX_OneofFuncs

func (*MaybeUnit) 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.

type MaybeUnit_Notfound

type MaybeUnit_Notfound struct {
	Notfound *NotFound `protobuf:"bytes,2,opt,name=notfound,oneof"`
}

func (*MaybeUnit_Notfound) MarshalTo

func (m *MaybeUnit_Notfound) MarshalTo(dAtA []byte) (int, error)

func (*MaybeUnit_Notfound) Size

func (m *MaybeUnit_Notfound) Size() (n int)

type MaybeUnit_Unit

type MaybeUnit_Unit struct {
	Unit *Unit `protobuf:"bytes,1,opt,name=unit,oneof"`
}

func (*MaybeUnit_Unit) MarshalTo

func (m *MaybeUnit_Unit) MarshalTo(dAtA []byte) (int, error)

func (*MaybeUnit_Unit) Size

func (m *MaybeUnit_Unit) Size() (n int)

type NotFound

type NotFound struct {
}

func (*NotFound) Descriptor

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

func (*NotFound) Marshal

func (m *NotFound) Marshal() (dAtA []byte, err error)

func (*NotFound) MarshalTo

func (m *NotFound) MarshalTo(dAtA []byte) (int, error)

func (*NotFound) ProtoMessage

func (*NotFound) ProtoMessage()

func (*NotFound) Reset

func (m *NotFound) Reset()

func (*NotFound) Size

func (m *NotFound) Size() (n int)

func (*NotFound) String

func (m *NotFound) String() string

func (*NotFound) Unmarshal

func (m *NotFound) Unmarshal(dAtA []byte) error

type RegistryClient

type RegistryClient interface {
	// agents should request only the locally scheduled jobs
	GetScheduledUnits(ctx context.Context, in *UnitFilter, opts ...grpc.CallOption) (*ScheduledUnits, error)
	// should _never_ be used? fleetctl only ?
	GetScheduledUnit(ctx context.Context, in *UnitName, opts ...grpc.CallOption) (*MaybeScheduledUnit, error)
	// should _never_ be used ?
	GetUnit(ctx context.Context, in *UnitName, opts ...grpc.CallOption) (*MaybeUnit, error)
	GetUnits(ctx context.Context, in *UnitFilter, opts ...grpc.CallOption) (*Units, error)
	// global status <= pretty much like list-unit-files
	GetUnitState(ctx context.Context, in *UnitName, opts ...grpc.CallOption) (*UnitState, error)
	GetUnitStates(ctx context.Context, in *UnitStateFilter, opts ...grpc.CallOption) (*UnitStates, error)
	ClearUnitHeartbeat(ctx context.Context, in *UnitName, opts ...grpc.CallOption) (*GenericReply, error)
	CreateUnit(ctx context.Context, in *Unit, opts ...grpc.CallOption) (*GenericReply, error)
	DestroyUnit(ctx context.Context, in *UnitName, opts ...grpc.CallOption) (*GenericReply, error)
	UnitHeartbeat(ctx context.Context, in *Heartbeat, opts ...grpc.CallOption) (*GenericReply, error)
	// mix heartbeat with *ttl”
	RemoveUnitState(ctx context.Context, in *UnitName, opts ...grpc.CallOption) (*GenericReply, error)
	SaveUnitState(ctx context.Context, in *SaveUnitStateRequest, opts ...grpc.CallOption) (*GenericReply, error)
	ScheduleUnit(ctx context.Context, in *ScheduleUnitRequest, opts ...grpc.CallOption) (*GenericReply, error)
	SetUnitTargetState(ctx context.Context, in *ScheduledUnit, opts ...grpc.CallOption) (*GenericReply, error)
	UnscheduleUnit(ctx context.Context, in *UnscheduleUnitRequest, opts ...grpc.CallOption) (*GenericReply, error)
	AgentEvents(ctx context.Context, in *MachineProperties, opts ...grpc.CallOption) (Registry_AgentEventsClient, error)
	// Health check
	Status(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
}

func NewRegistryClient

func NewRegistryClient(cc *grpc.ClientConn) RegistryClient

type RegistryServer

type RegistryServer interface {
	// agents should request only the locally scheduled jobs
	GetScheduledUnits(context.Context, *UnitFilter) (*ScheduledUnits, error)
	// should _never_ be used? fleetctl only ?
	GetScheduledUnit(context.Context, *UnitName) (*MaybeScheduledUnit, error)
	// should _never_ be used ?
	GetUnit(context.Context, *UnitName) (*MaybeUnit, error)
	GetUnits(context.Context, *UnitFilter) (*Units, error)
	// global status <= pretty much like list-unit-files
	GetUnitState(context.Context, *UnitName) (*UnitState, error)
	GetUnitStates(context.Context, *UnitStateFilter) (*UnitStates, error)
	ClearUnitHeartbeat(context.Context, *UnitName) (*GenericReply, error)
	CreateUnit(context.Context, *Unit) (*GenericReply, error)
	DestroyUnit(context.Context, *UnitName) (*GenericReply, error)
	UnitHeartbeat(context.Context, *Heartbeat) (*GenericReply, error)
	// mix heartbeat with *ttl”
	RemoveUnitState(context.Context, *UnitName) (*GenericReply, error)
	SaveUnitState(context.Context, *SaveUnitStateRequest) (*GenericReply, error)
	ScheduleUnit(context.Context, *ScheduleUnitRequest) (*GenericReply, error)
	SetUnitTargetState(context.Context, *ScheduledUnit) (*GenericReply, error)
	UnscheduleUnit(context.Context, *UnscheduleUnitRequest) (*GenericReply, error)
	AgentEvents(*MachineProperties, Registry_AgentEventsServer) error
	// Health check
	Status(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
}

type Registry_AgentEventsClient

type Registry_AgentEventsClient interface {
	Recv() (*UpdatedState, error)
	grpc.ClientStream
}

type Registry_AgentEventsServer

type Registry_AgentEventsServer interface {
	Send(*UpdatedState) error
	grpc.ServerStream
}

type SaveUnitStateRequest

type SaveUnitStateRequest struct {
	Name  string     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	State *UnitState `protobuf:"bytes,2,opt,name=state" json:"state,omitempty"`
	TTL   int32      `protobuf:"varint,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
}

func (*SaveUnitStateRequest) Descriptor

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

func (*SaveUnitStateRequest) GetState

func (m *SaveUnitStateRequest) GetState() *UnitState

func (*SaveUnitStateRequest) Marshal

func (m *SaveUnitStateRequest) Marshal() (dAtA []byte, err error)

func (*SaveUnitStateRequest) MarshalTo

func (m *SaveUnitStateRequest) MarshalTo(dAtA []byte) (int, error)

func (*SaveUnitStateRequest) ProtoMessage

func (*SaveUnitStateRequest) ProtoMessage()

func (*SaveUnitStateRequest) Reset

func (m *SaveUnitStateRequest) Reset()

func (*SaveUnitStateRequest) Size

func (m *SaveUnitStateRequest) Size() (n int)

func (*SaveUnitStateRequest) String

func (m *SaveUnitStateRequest) String() string

func (*SaveUnitStateRequest) Unmarshal

func (m *SaveUnitStateRequest) Unmarshal(dAtA []byte) error

type ScheduleUnitRequest

type ScheduleUnitRequest struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	MachineID string `protobuf:"bytes,2,opt,name=machine_id,json=machineId,proto3" json:"machine_id,omitempty"`
}

func (*ScheduleUnitRequest) Descriptor

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

func (*ScheduleUnitRequest) Marshal

func (m *ScheduleUnitRequest) Marshal() (dAtA []byte, err error)

func (*ScheduleUnitRequest) MarshalTo

func (m *ScheduleUnitRequest) MarshalTo(dAtA []byte) (int, error)

func (*ScheduleUnitRequest) ProtoMessage

func (*ScheduleUnitRequest) ProtoMessage()

func (*ScheduleUnitRequest) Reset

func (m *ScheduleUnitRequest) Reset()

func (*ScheduleUnitRequest) Size

func (m *ScheduleUnitRequest) Size() (n int)

func (*ScheduleUnitRequest) String

func (m *ScheduleUnitRequest) String() string

func (*ScheduleUnitRequest) Unmarshal

func (m *ScheduleUnitRequest) Unmarshal(dAtA []byte) error

type ScheduledUnit

type ScheduledUnit struct {
	Name         string      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	CurrentState TargetState `protobuf:"varint,2,opt,name=current_state,json=currentState,proto3,enum=rpc.TargetState" json:"current_state,omitempty"`
	MachineID    string      `protobuf:"bytes,3,opt,name=machine_id,json=machineId,proto3" json:"machine_id,omitempty"`
}

func (*ScheduledUnit) Descriptor

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

func (*ScheduledUnit) Marshal

func (m *ScheduledUnit) Marshal() (dAtA []byte, err error)

func (*ScheduledUnit) MarshalTo

func (m *ScheduledUnit) MarshalTo(dAtA []byte) (int, error)

func (*ScheduledUnit) ProtoMessage

func (*ScheduledUnit) ProtoMessage()

func (*ScheduledUnit) Reset

func (m *ScheduledUnit) Reset()

func (*ScheduledUnit) Size

func (m *ScheduledUnit) Size() (n int)

func (*ScheduledUnit) String

func (m *ScheduledUnit) String() string

func (*ScheduledUnit) Unmarshal

func (m *ScheduledUnit) Unmarshal(dAtA []byte) error

type ScheduledUnits

type ScheduledUnits struct {
	Units []ScheduledUnit `protobuf:"bytes,1,rep,name=units" json:"units"`
}

func (*ScheduledUnits) Descriptor

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

func (*ScheduledUnits) GetUnits

func (m *ScheduledUnits) GetUnits() []ScheduledUnit

func (*ScheduledUnits) Marshal

func (m *ScheduledUnits) Marshal() (dAtA []byte, err error)

func (*ScheduledUnits) MarshalTo

func (m *ScheduledUnits) MarshalTo(dAtA []byte) (int, error)

func (*ScheduledUnits) ProtoMessage

func (*ScheduledUnits) ProtoMessage()

func (*ScheduledUnits) Reset

func (m *ScheduledUnits) Reset()

func (*ScheduledUnits) Size

func (m *ScheduledUnits) Size() (n int)

func (*ScheduledUnits) String

func (m *ScheduledUnits) String() string

func (*ScheduledUnits) Unmarshal

func (m *ScheduledUnits) Unmarshal(dAtA []byte) error

type TargetState

type TargetState int32
const (
	TargetState_INACTIVE TargetState = 0
	TargetState_LOADED   TargetState = 1
	TargetState_LAUNCHED TargetState = 2
)

func (TargetState) EnumDescriptor

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

func (TargetState) String

func (x TargetState) String() string

type Unit

type Unit struct {
	Name         string      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Unit         UnitFile    `protobuf:"bytes,2,opt,name=unit" json:"unit"`
	DesiredState TargetState `protobuf:"varint,3,opt,name=desired_state,json=desiredState,proto3,enum=rpc.TargetState" json:"desired_state,omitempty"`
}

func (*Unit) Descriptor

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

func (*Unit) GetUnit

func (m *Unit) GetUnit() UnitFile

func (*Unit) Marshal

func (m *Unit) Marshal() (dAtA []byte, err error)

func (*Unit) MarshalTo

func (m *Unit) MarshalTo(dAtA []byte) (int, error)

func (*Unit) ProtoMessage

func (*Unit) ProtoMessage()

func (*Unit) Reset

func (m *Unit) Reset()

func (*Unit) Size

func (m *Unit) Size() (n int)

func (*Unit) String

func (m *Unit) String() string

func (*Unit) Unmarshal

func (m *Unit) Unmarshal(dAtA []byte) error

type UnitFile

type UnitFile struct {
	UnitOptions []UnitOption `protobuf:"bytes,1,rep,name=unit_options,json=unitOptions" json:"unit_options"`
}

func (*UnitFile) Descriptor

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

func (*UnitFile) GetUnitOptions

func (m *UnitFile) GetUnitOptions() []UnitOption

func (*UnitFile) Marshal

func (m *UnitFile) Marshal() (dAtA []byte, err error)

func (*UnitFile) MarshalTo

func (m *UnitFile) MarshalTo(dAtA []byte) (int, error)

func (*UnitFile) ProtoMessage

func (*UnitFile) ProtoMessage()

func (*UnitFile) Reset

func (m *UnitFile) Reset()

func (*UnitFile) Size

func (m *UnitFile) Size() (n int)

func (*UnitFile) String

func (m *UnitFile) String() string

func (*UnitFile) Unmarshal

func (m *UnitFile) Unmarshal(dAtA []byte) error

type UnitFilter

type UnitFilter struct {
	MachineID string `protobuf:"bytes,1,opt,name=machine_id,json=machineId,proto3" json:"machine_id,omitempty"`
}

func (*UnitFilter) Descriptor

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

func (*UnitFilter) Marshal

func (m *UnitFilter) Marshal() (dAtA []byte, err error)

func (*UnitFilter) MarshalTo

func (m *UnitFilter) MarshalTo(dAtA []byte) (int, error)

func (*UnitFilter) ProtoMessage

func (*UnitFilter) ProtoMessage()

func (*UnitFilter) Reset

func (m *UnitFilter) Reset()

func (*UnitFilter) Size

func (m *UnitFilter) Size() (n int)

func (*UnitFilter) String

func (m *UnitFilter) String() string

func (*UnitFilter) Unmarshal

func (m *UnitFilter) Unmarshal(dAtA []byte) error

type UnitName

type UnitName struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

func (*UnitName) Descriptor

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

func (*UnitName) Marshal

func (m *UnitName) Marshal() (dAtA []byte, err error)

func (*UnitName) MarshalTo

func (m *UnitName) MarshalTo(dAtA []byte) (int, error)

func (*UnitName) ProtoMessage

func (*UnitName) ProtoMessage()

func (*UnitName) Reset

func (m *UnitName) Reset()

func (*UnitName) Size

func (m *UnitName) Size() (n int)

func (*UnitName) String

func (m *UnitName) String() string

func (*UnitName) Unmarshal

func (m *UnitName) Unmarshal(dAtA []byte) error

type UnitOption

type UnitOption struct {
	Section string `protobuf:"bytes,1,opt,name=section,proto3" json:"section,omitempty"`
	Name    string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Value   string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
}

func (*UnitOption) Descriptor

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

func (*UnitOption) Marshal

func (m *UnitOption) Marshal() (dAtA []byte, err error)

func (*UnitOption) MarshalTo

func (m *UnitOption) MarshalTo(dAtA []byte) (int, error)

func (*UnitOption) ProtoMessage

func (*UnitOption) ProtoMessage()

func (*UnitOption) Reset

func (m *UnitOption) Reset()

func (*UnitOption) Size

func (m *UnitOption) Size() (n int)

func (*UnitOption) String

func (m *UnitOption) String() string

func (*UnitOption) Unmarshal

func (m *UnitOption) Unmarshal(dAtA []byte) error

type UnitState

type UnitState struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Hash        string `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	LoadState   string `protobuf:"bytes,3,opt,name=load_state,json=loadState,proto3" json:"load_state,omitempty"`
	ActiveState string `protobuf:"bytes,4,opt,name=active_state,json=activeState,proto3" json:"active_state,omitempty"`
	SubState    string `protobuf:"bytes,5,opt,name=sub_state,json=subState,proto3" json:"sub_state,omitempty"`
	MachineID   string `protobuf:"bytes,6,opt,name=machine_id,json=machineId,proto3" json:"machine_id,omitempty"`
}

func (*UnitState) Descriptor

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

func (*UnitState) Marshal

func (m *UnitState) Marshal() (dAtA []byte, err error)

func (*UnitState) MarshalTo

func (m *UnitState) MarshalTo(dAtA []byte) (int, error)

func (*UnitState) ProtoMessage

func (*UnitState) ProtoMessage()

func (*UnitState) Reset

func (m *UnitState) Reset()

func (*UnitState) Size

func (m *UnitState) Size() (n int)

func (*UnitState) String

func (m *UnitState) String() string

func (*UnitState) Unmarshal

func (m *UnitState) Unmarshal(dAtA []byte) error

type UnitStateFilter

type UnitStateFilter struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Hash        string `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	LoadState   string `protobuf:"bytes,3,opt,name=load_state,json=loadState,proto3" json:"load_state,omitempty"`
	ActiveState string `protobuf:"bytes,4,opt,name=active_state,json=activeState,proto3" json:"active_state,omitempty"`
	SubState    string `protobuf:"bytes,5,opt,name=sub_state,json=subState,proto3" json:"sub_state,omitempty"`
	MachineID   string `protobuf:"bytes,6,opt,name=machine_id,json=machineId,proto3" json:"machine_id,omitempty"`
}

func (*UnitStateFilter) Descriptor

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

func (*UnitStateFilter) Marshal

func (m *UnitStateFilter) Marshal() (dAtA []byte, err error)

func (*UnitStateFilter) MarshalTo

func (m *UnitStateFilter) MarshalTo(dAtA []byte) (int, error)

func (*UnitStateFilter) ProtoMessage

func (*UnitStateFilter) ProtoMessage()

func (*UnitStateFilter) Reset

func (m *UnitStateFilter) Reset()

func (*UnitStateFilter) Size

func (m *UnitStateFilter) Size() (n int)

func (*UnitStateFilter) String

func (m *UnitStateFilter) String() string

func (*UnitStateFilter) Unmarshal

func (m *UnitStateFilter) Unmarshal(dAtA []byte) error

type UnitStates

type UnitStates struct {
	UnitStates []*UnitState `protobuf:"bytes,1,rep,name=unit_states,json=unitStates" json:"unit_states,omitempty"`
}

func (*UnitStates) Descriptor

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

func (*UnitStates) GetUnitStates

func (m *UnitStates) GetUnitStates() []*UnitState

func (*UnitStates) Marshal

func (m *UnitStates) Marshal() (dAtA []byte, err error)

func (*UnitStates) MarshalTo

func (m *UnitStates) MarshalTo(dAtA []byte) (int, error)

func (*UnitStates) ProtoMessage

func (*UnitStates) ProtoMessage()

func (*UnitStates) Reset

func (m *UnitStates) Reset()

func (*UnitStates) Size

func (m *UnitStates) Size() (n int)

func (*UnitStates) String

func (m *UnitStates) String() string

func (*UnitStates) Unmarshal

func (m *UnitStates) Unmarshal(dAtA []byte) error

type Units

type Units struct {
	Units []Unit `protobuf:"bytes,1,rep,name=units" json:"units"`
}

func (*Units) Descriptor

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

func (*Units) GetUnits

func (m *Units) GetUnits() []Unit

func (*Units) Marshal

func (m *Units) Marshal() (dAtA []byte, err error)

func (*Units) MarshalTo

func (m *Units) MarshalTo(dAtA []byte) (int, error)

func (*Units) ProtoMessage

func (*Units) ProtoMessage()

func (*Units) Reset

func (m *Units) Reset()

func (*Units) Size

func (m *Units) Size() (n int)

func (*Units) String

func (m *Units) String() string

func (*Units) Unmarshal

func (m *Units) Unmarshal(dAtA []byte) error

type UnscheduleUnitRequest

type UnscheduleUnitRequest struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	MachineID string `protobuf:"bytes,2,opt,name=machine_id,json=machineId,proto3" json:"machine_id,omitempty"`
}

func (*UnscheduleUnitRequest) Descriptor

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

func (*UnscheduleUnitRequest) Marshal

func (m *UnscheduleUnitRequest) Marshal() (dAtA []byte, err error)

func (*UnscheduleUnitRequest) MarshalTo

func (m *UnscheduleUnitRequest) MarshalTo(dAtA []byte) (int, error)

func (*UnscheduleUnitRequest) ProtoMessage

func (*UnscheduleUnitRequest) ProtoMessage()

func (*UnscheduleUnitRequest) Reset

func (m *UnscheduleUnitRequest) Reset()

func (*UnscheduleUnitRequest) Size

func (m *UnscheduleUnitRequest) Size() (n int)

func (*UnscheduleUnitRequest) String

func (m *UnscheduleUnitRequest) String() string

func (*UnscheduleUnitRequest) Unmarshal

func (m *UnscheduleUnitRequest) Unmarshal(dAtA []byte) error

type UpdatedState

type UpdatedState struct {
	UnitIds []string `protobuf:"bytes,1,rep,name=unit_ids,json=unitIds" json:"unit_ids,omitempty"`
}

func (*UpdatedState) Descriptor

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

func (*UpdatedState) Marshal

func (m *UpdatedState) Marshal() (dAtA []byte, err error)

func (*UpdatedState) MarshalTo

func (m *UpdatedState) MarshalTo(dAtA []byte) (int, error)

func (*UpdatedState) ProtoMessage

func (*UpdatedState) ProtoMessage()

func (*UpdatedState) Reset

func (m *UpdatedState) Reset()

func (*UpdatedState) Size

func (m *UpdatedState) Size() (n int)

func (*UpdatedState) String

func (m *UpdatedState) String() string

func (*UpdatedState) Unmarshal

func (m *UpdatedState) Unmarshal(dAtA []byte) error

Source Files

Jump to

Keyboard shortcuts

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