Versions in this module Expand all Collapse all v1 v1.0.0 Dec 22, 2016 Changes in this version + var ErrIntOverflowFleet = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthFleet = fmt.Errorf("proto: negative length found during unmarshaling") + var HealthCheckResponse_ServingStatus_name = map[int32]string + var HealthCheckResponse_ServingStatus_value = map[string]int32 + var TargetState_name = map[int32]string + var TargetState_value = map[string]int32 + func RegisterRegistryServer(s *grpc.Server, srv RegistryServer) + type GenericReply struct + func (*GenericReply) Descriptor() ([]byte, []int) + func (*GenericReply) ProtoMessage() + func (m *GenericReply) Marshal() (dAtA []byte, err error) + func (m *GenericReply) MarshalTo(dAtA []byte) (int, error) + func (m *GenericReply) Reset() + func (m *GenericReply) Size() (n int) + func (m *GenericReply) String() string + func (m *GenericReply) Unmarshal(dAtA []byte) error + type HealthCheckRequest struct + Service string + func (*HealthCheckRequest) Descriptor() ([]byte, []int) + func (*HealthCheckRequest) ProtoMessage() + func (m *HealthCheckRequest) Marshal() (dAtA []byte, err error) + func (m *HealthCheckRequest) MarshalTo(dAtA []byte) (int, error) + func (m *HealthCheckRequest) Reset() + func (m *HealthCheckRequest) Size() (n int) + func (m *HealthCheckRequest) String() string + func (m *HealthCheckRequest) Unmarshal(dAtA []byte) error + type HealthCheckResponse struct + Status HealthCheckResponse_ServingStatus + func (*HealthCheckResponse) Descriptor() ([]byte, []int) + func (*HealthCheckResponse) ProtoMessage() + func (m *HealthCheckResponse) Marshal() (dAtA []byte, err error) + func (m *HealthCheckResponse) MarshalTo(dAtA []byte) (int, error) + func (m *HealthCheckResponse) Reset() + func (m *HealthCheckResponse) Size() (n int) + func (m *HealthCheckResponse) String() string + func (m *HealthCheckResponse) Unmarshal(dAtA []byte) error + type HealthCheckResponse_ServingStatus int32 + const HealthCheckResponse_NOT_SERVING + const HealthCheckResponse_SERVING + const HealthCheckResponse_UNKNOWN + func (HealthCheckResponse_ServingStatus) EnumDescriptor() ([]byte, []int) + func (x HealthCheckResponse_ServingStatus) String() string + type Heartbeat struct + MachineID string + Name string + TTL int32 + func (*Heartbeat) Descriptor() ([]byte, []int) + func (*Heartbeat) ProtoMessage() + func (m *Heartbeat) Marshal() (dAtA []byte, err error) + func (m *Heartbeat) MarshalTo(dAtA []byte) (int, error) + func (m *Heartbeat) Reset() + func (m *Heartbeat) Size() (n int) + func (m *Heartbeat) String() string + func (m *Heartbeat) Unmarshal(dAtA []byte) error + type MachineProperties struct + Id string + func (*MachineProperties) Descriptor() ([]byte, []int) + func (*MachineProperties) ProtoMessage() + func (m *MachineProperties) Marshal() (dAtA []byte, err error) + func (m *MachineProperties) MarshalTo(dAtA []byte) (int, error) + func (m *MachineProperties) Reset() + func (m *MachineProperties) Size() (n int) + func (m *MachineProperties) String() string + func (m *MachineProperties) Unmarshal(dAtA []byte) error + type MaybeScheduledUnit struct + IsScheduled isMaybeScheduledUnit_IsScheduled + func (*MaybeScheduledUnit) Descriptor() ([]byte, []int) + func (*MaybeScheduledUnit) ProtoMessage() + func (*MaybeScheduledUnit) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *MaybeScheduledUnit) GetIsScheduled() isMaybeScheduledUnit_IsScheduled + func (m *MaybeScheduledUnit) GetNotfound() *NotFound + func (m *MaybeScheduledUnit) GetUnit() *ScheduledUnit + func (m *MaybeScheduledUnit) Marshal() (dAtA []byte, err error) + func (m *MaybeScheduledUnit) MarshalTo(dAtA []byte) (int, error) + func (m *MaybeScheduledUnit) Reset() + func (m *MaybeScheduledUnit) Size() (n int) + func (m *MaybeScheduledUnit) String() string + func (m *MaybeScheduledUnit) Unmarshal(dAtA []byte) error + type MaybeScheduledUnit_Notfound struct + Notfound *NotFound + func (m *MaybeScheduledUnit_Notfound) MarshalTo(dAtA []byte) (int, error) + func (m *MaybeScheduledUnit_Notfound) Size() (n int) + type MaybeScheduledUnit_Unit struct + Unit *ScheduledUnit + func (m *MaybeScheduledUnit_Unit) MarshalTo(dAtA []byte) (int, error) + func (m *MaybeScheduledUnit_Unit) Size() (n int) + type MaybeUnit struct + HasUnit isMaybeUnit_HasUnit + func (*MaybeUnit) Descriptor() ([]byte, []int) + func (*MaybeUnit) ProtoMessage() + func (*MaybeUnit) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *MaybeUnit) GetHasUnit() isMaybeUnit_HasUnit + func (m *MaybeUnit) GetNotfound() *NotFound + func (m *MaybeUnit) GetUnit() *Unit + func (m *MaybeUnit) Marshal() (dAtA []byte, err error) + func (m *MaybeUnit) MarshalTo(dAtA []byte) (int, error) + func (m *MaybeUnit) Reset() + func (m *MaybeUnit) Size() (n int) + func (m *MaybeUnit) String() string + func (m *MaybeUnit) Unmarshal(dAtA []byte) error + type MaybeUnit_Notfound struct + Notfound *NotFound + func (m *MaybeUnit_Notfound) MarshalTo(dAtA []byte) (int, error) + func (m *MaybeUnit_Notfound) Size() (n int) + type MaybeUnit_Unit struct + Unit *Unit + func (m *MaybeUnit_Unit) MarshalTo(dAtA []byte) (int, error) + func (m *MaybeUnit_Unit) Size() (n int) + type NotFound struct + func (*NotFound) Descriptor() ([]byte, []int) + func (*NotFound) ProtoMessage() + func (m *NotFound) Marshal() (dAtA []byte, err error) + func (m *NotFound) MarshalTo(dAtA []byte) (int, error) + func (m *NotFound) Reset() + func (m *NotFound) Size() (n int) + func (m *NotFound) String() string + func (m *NotFound) Unmarshal(dAtA []byte) error + type RegistryClient interface + AgentEvents func(ctx context.Context, in *MachineProperties, opts ...grpc.CallOption) (Registry_AgentEventsClient, error) + ClearUnitHeartbeat func(ctx context.Context, in *UnitName, opts ...grpc.CallOption) (*GenericReply, error) + CreateUnit func(ctx context.Context, in *Unit, opts ...grpc.CallOption) (*GenericReply, error) + DestroyUnit func(ctx context.Context, in *UnitName, opts ...grpc.CallOption) (*GenericReply, error) + GetScheduledUnit func(ctx context.Context, in *UnitName, opts ...grpc.CallOption) (*MaybeScheduledUnit, error) + GetScheduledUnits func(ctx context.Context, in *UnitFilter, opts ...grpc.CallOption) (*ScheduledUnits, error) + GetUnit func(ctx context.Context, in *UnitName, opts ...grpc.CallOption) (*MaybeUnit, error) + GetUnitState func(ctx context.Context, in *UnitName, opts ...grpc.CallOption) (*UnitState, error) + GetUnitStates func(ctx context.Context, in *UnitStateFilter, opts ...grpc.CallOption) (*UnitStates, error) + GetUnits func(ctx context.Context, in *UnitFilter, opts ...grpc.CallOption) (*Units, error) + RemoveUnitState func(ctx context.Context, in *UnitName, opts ...grpc.CallOption) (*GenericReply, error) + SaveUnitState func(ctx context.Context, in *SaveUnitStateRequest, opts ...grpc.CallOption) (*GenericReply, error) + ScheduleUnit func(ctx context.Context, in *ScheduleUnitRequest, opts ...grpc.CallOption) (*GenericReply, error) + SetUnitTargetState func(ctx context.Context, in *ScheduledUnit, opts ...grpc.CallOption) (*GenericReply, error) + Status func(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error) + UnitHeartbeat func(ctx context.Context, in *Heartbeat, opts ...grpc.CallOption) (*GenericReply, error) + UnscheduleUnit func(ctx context.Context, in *UnscheduleUnitRequest, opts ...grpc.CallOption) (*GenericReply, error) + func NewRegistryClient(cc *grpc.ClientConn) RegistryClient + type RegistryServer interface + AgentEvents func(*MachineProperties, Registry_AgentEventsServer) error + ClearUnitHeartbeat func(context.Context, *UnitName) (*GenericReply, error) + CreateUnit func(context.Context, *Unit) (*GenericReply, error) + DestroyUnit func(context.Context, *UnitName) (*GenericReply, error) + GetScheduledUnit func(context.Context, *UnitName) (*MaybeScheduledUnit, error) + GetScheduledUnits func(context.Context, *UnitFilter) (*ScheduledUnits, error) + GetUnit func(context.Context, *UnitName) (*MaybeUnit, error) + GetUnitState func(context.Context, *UnitName) (*UnitState, error) + GetUnitStates func(context.Context, *UnitStateFilter) (*UnitStates, error) + GetUnits func(context.Context, *UnitFilter) (*Units, error) + RemoveUnitState func(context.Context, *UnitName) (*GenericReply, error) + SaveUnitState func(context.Context, *SaveUnitStateRequest) (*GenericReply, error) + ScheduleUnit func(context.Context, *ScheduleUnitRequest) (*GenericReply, error) + SetUnitTargetState func(context.Context, *ScheduledUnit) (*GenericReply, error) + Status func(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error) + UnitHeartbeat func(context.Context, *Heartbeat) (*GenericReply, error) + UnscheduleUnit func(context.Context, *UnscheduleUnitRequest) (*GenericReply, error) + type Registry_AgentEventsClient interface + Recv func() (*UpdatedState, error) + type Registry_AgentEventsServer interface + Send func(*UpdatedState) error + type SaveUnitStateRequest struct + Name string + State *UnitState + TTL int32 + func (*SaveUnitStateRequest) Descriptor() ([]byte, []int) + func (*SaveUnitStateRequest) ProtoMessage() + func (m *SaveUnitStateRequest) GetState() *UnitState + func (m *SaveUnitStateRequest) Marshal() (dAtA []byte, err error) + func (m *SaveUnitStateRequest) MarshalTo(dAtA []byte) (int, error) + func (m *SaveUnitStateRequest) Reset() + func (m *SaveUnitStateRequest) Size() (n int) + func (m *SaveUnitStateRequest) String() string + func (m *SaveUnitStateRequest) Unmarshal(dAtA []byte) error + type ScheduleUnitRequest struct + MachineID string + Name string + func (*ScheduleUnitRequest) Descriptor() ([]byte, []int) + func (*ScheduleUnitRequest) ProtoMessage() + func (m *ScheduleUnitRequest) Marshal() (dAtA []byte, err error) + func (m *ScheduleUnitRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ScheduleUnitRequest) Reset() + func (m *ScheduleUnitRequest) Size() (n int) + func (m *ScheduleUnitRequest) String() string + func (m *ScheduleUnitRequest) Unmarshal(dAtA []byte) error + type ScheduledUnit struct + CurrentState TargetState + MachineID string + Name string + func (*ScheduledUnit) Descriptor() ([]byte, []int) + func (*ScheduledUnit) ProtoMessage() + func (m *ScheduledUnit) Marshal() (dAtA []byte, err error) + func (m *ScheduledUnit) MarshalTo(dAtA []byte) (int, error) + func (m *ScheduledUnit) Reset() + func (m *ScheduledUnit) Size() (n int) + func (m *ScheduledUnit) String() string + func (m *ScheduledUnit) Unmarshal(dAtA []byte) error + type ScheduledUnits struct + Units []ScheduledUnit + func (*ScheduledUnits) Descriptor() ([]byte, []int) + func (*ScheduledUnits) ProtoMessage() + func (m *ScheduledUnits) GetUnits() []ScheduledUnit + func (m *ScheduledUnits) Marshal() (dAtA []byte, err error) + func (m *ScheduledUnits) MarshalTo(dAtA []byte) (int, error) + func (m *ScheduledUnits) Reset() + func (m *ScheduledUnits) Size() (n int) + func (m *ScheduledUnits) String() string + func (m *ScheduledUnits) Unmarshal(dAtA []byte) error + type TargetState int32 + const TargetState_INACTIVE + const TargetState_LAUNCHED + const TargetState_LOADED + func (TargetState) EnumDescriptor() ([]byte, []int) + func (x TargetState) String() string + type Unit struct + DesiredState TargetState + Name string + Unit UnitFile + func (*Unit) Descriptor() ([]byte, []int) + func (*Unit) ProtoMessage() + func (m *Unit) GetUnit() UnitFile + func (m *Unit) Marshal() (dAtA []byte, err error) + func (m *Unit) MarshalTo(dAtA []byte) (int, error) + func (m *Unit) Reset() + func (m *Unit) Size() (n int) + func (m *Unit) String() string + func (m *Unit) Unmarshal(dAtA []byte) error + type UnitFile struct + UnitOptions []UnitOption + func (*UnitFile) Descriptor() ([]byte, []int) + func (*UnitFile) ProtoMessage() + func (m *UnitFile) GetUnitOptions() []UnitOption + func (m *UnitFile) Marshal() (dAtA []byte, err error) + func (m *UnitFile) MarshalTo(dAtA []byte) (int, error) + func (m *UnitFile) Reset() + func (m *UnitFile) Size() (n int) + func (m *UnitFile) String() string + func (m *UnitFile) Unmarshal(dAtA []byte) error + type UnitFilter struct + MachineID string + func (*UnitFilter) Descriptor() ([]byte, []int) + func (*UnitFilter) ProtoMessage() + func (m *UnitFilter) Marshal() (dAtA []byte, err error) + func (m *UnitFilter) MarshalTo(dAtA []byte) (int, error) + func (m *UnitFilter) Reset() + func (m *UnitFilter) Size() (n int) + func (m *UnitFilter) String() string + func (m *UnitFilter) Unmarshal(dAtA []byte) error + type UnitName struct + Name string + func (*UnitName) Descriptor() ([]byte, []int) + func (*UnitName) ProtoMessage() + func (m *UnitName) Marshal() (dAtA []byte, err error) + func (m *UnitName) MarshalTo(dAtA []byte) (int, error) + func (m *UnitName) Reset() + func (m *UnitName) Size() (n int) + func (m *UnitName) String() string + func (m *UnitName) Unmarshal(dAtA []byte) error + type UnitOption struct + Name string + Section string + Value string + func (*UnitOption) Descriptor() ([]byte, []int) + func (*UnitOption) ProtoMessage() + func (m *UnitOption) Marshal() (dAtA []byte, err error) + func (m *UnitOption) MarshalTo(dAtA []byte) (int, error) + func (m *UnitOption) Reset() + func (m *UnitOption) Size() (n int) + func (m *UnitOption) String() string + func (m *UnitOption) Unmarshal(dAtA []byte) error + type UnitState struct + ActiveState string + Hash string + LoadState string + MachineID string + Name string + SubState string + func (*UnitState) Descriptor() ([]byte, []int) + func (*UnitState) ProtoMessage() + func (m *UnitState) Marshal() (dAtA []byte, err error) + func (m *UnitState) MarshalTo(dAtA []byte) (int, error) + func (m *UnitState) Reset() + func (m *UnitState) Size() (n int) + func (m *UnitState) String() string + func (m *UnitState) Unmarshal(dAtA []byte) error + type UnitStateFilter struct + ActiveState string + Hash string + LoadState string + MachineID string + Name string + SubState string + func (*UnitStateFilter) Descriptor() ([]byte, []int) + func (*UnitStateFilter) ProtoMessage() + func (m *UnitStateFilter) Marshal() (dAtA []byte, err error) + func (m *UnitStateFilter) MarshalTo(dAtA []byte) (int, error) + func (m *UnitStateFilter) Reset() + func (m *UnitStateFilter) Size() (n int) + func (m *UnitStateFilter) String() string + func (m *UnitStateFilter) Unmarshal(dAtA []byte) error + type UnitStates struct + UnitStates []*UnitState + func (*UnitStates) Descriptor() ([]byte, []int) + func (*UnitStates) ProtoMessage() + func (m *UnitStates) GetUnitStates() []*UnitState + func (m *UnitStates) Marshal() (dAtA []byte, err error) + func (m *UnitStates) MarshalTo(dAtA []byte) (int, error) + func (m *UnitStates) Reset() + func (m *UnitStates) Size() (n int) + func (m *UnitStates) String() string + func (m *UnitStates) Unmarshal(dAtA []byte) error + type Units struct + Units []Unit + func (*Units) Descriptor() ([]byte, []int) + func (*Units) ProtoMessage() + func (m *Units) GetUnits() []Unit + func (m *Units) Marshal() (dAtA []byte, err error) + func (m *Units) MarshalTo(dAtA []byte) (int, error) + func (m *Units) Reset() + func (m *Units) Size() (n int) + func (m *Units) String() string + func (m *Units) Unmarshal(dAtA []byte) error + type UnscheduleUnitRequest struct + MachineID string + Name string + func (*UnscheduleUnitRequest) Descriptor() ([]byte, []int) + func (*UnscheduleUnitRequest) ProtoMessage() + func (m *UnscheduleUnitRequest) Marshal() (dAtA []byte, err error) + func (m *UnscheduleUnitRequest) MarshalTo(dAtA []byte) (int, error) + func (m *UnscheduleUnitRequest) Reset() + func (m *UnscheduleUnitRequest) Size() (n int) + func (m *UnscheduleUnitRequest) String() string + func (m *UnscheduleUnitRequest) Unmarshal(dAtA []byte) error + type UpdatedState struct + UnitIds []string + func (*UpdatedState) Descriptor() ([]byte, []int) + func (*UpdatedState) ProtoMessage() + func (m *UpdatedState) Marshal() (dAtA []byte, err error) + func (m *UpdatedState) MarshalTo(dAtA []byte) (int, error) + func (m *UpdatedState) Reset() + func (m *UpdatedState) Size() (n int) + func (m *UpdatedState) String() string + func (m *UpdatedState) Unmarshal(dAtA []byte) error
Go to main page