rpc

package
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: 0

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 

func (x HealthCheckResponse_ServingStatus) String() 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

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.