communicationmanager

package
v0.0.0-...-54d5584 Latest Latest
Warning

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

 Go to latest Published: Dec 30, 2024 License: Apache-2.0 Imports: 10 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	UpdateState_name = map[int32]string{
		0: "NO_UPDATE",
		1: "DOWNLOADING",
		2: "READY_TO_UPDATE",
		3: "UPDATING",
	}
	UpdateState_value = map[string]int32{
		"NO_UPDATE":       0,
		"DOWNLOADING":     1,
		"READY_TO_UPDATE": 2,
		"UPDATING":        3,
	}
)

Enum value maps for UpdateState.

View Source 
var File_communicationmanager_v3_updatescheduler_proto protoreflect.FileDescriptor
View Source 
var UpdateSchedulerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "communicationmanager.v3.UpdateSchedulerService",
	HandlerType: (*UpdateSchedulerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "StartFOTAUpdate",
			Handler:    _UpdateSchedulerService_StartFOTAUpdate_Handler,
		},
		{
			MethodName: "StartSOTAUpdate",
			Handler:    _UpdateSchedulerService_StartSOTAUpdate_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SubscribeNotifications",
			Handler:       _UpdateSchedulerService_SubscribeNotifications_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "communicationmanager/v3/updatescheduler.proto",
}

UpdateSchedulerService_ServiceDesc is the grpc.ServiceDesc for UpdateSchedulerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterUpdateSchedulerServiceServer 

func RegisterUpdateSchedulerServiceServer(s grpc.ServiceRegistrar, srv UpdateSchedulerServiceServer)

Types

type ComponentInfo 

type ComponentInfo struct {
	ComponentId   string `protobuf:"bytes,1,opt,name=component_id,json=componentId,proto3" json:"component_id,omitempty"`
	ComponentType string `protobuf:"bytes,2,opt,name=component_type,json=componentType,proto3" json:"component_type,omitempty"`
	Version       string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*ComponentInfo) Descriptor deprecated 

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

Deprecated: Use ComponentInfo.ProtoReflect.Descriptor instead.

func (*ComponentInfo) GetComponentId 

func (x *ComponentInfo) GetComponentId() string

func (*ComponentInfo) GetComponentType 

func (x *ComponentInfo) GetComponentType() string

func (*ComponentInfo) GetVersion 

func (x *ComponentInfo) GetVersion() string

func (*ComponentInfo) ProtoMessage 

func (*ComponentInfo) ProtoMessage()

func (*ComponentInfo) ProtoReflect 

func (x *ComponentInfo) ProtoReflect() protoreflect.Message

func (*ComponentInfo) Reset 

func (x *ComponentInfo) Reset()

func (*ComponentInfo) String 

func (x *ComponentInfo) String() string

type LayerInfo 

type LayerInfo struct {
	LayerId string `protobuf:"bytes,1,opt,name=layer_id,json=layerId,proto3" json:"layer_id,omitempty"`
	Digest  string `protobuf:"bytes,2,opt,name=digest,proto3" json:"digest,omitempty"`
	Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*LayerInfo) Descriptor deprecated 

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

Deprecated: Use LayerInfo.ProtoReflect.Descriptor instead.

func (*LayerInfo) GetDigest 

func (x *LayerInfo) GetDigest() string

func (*LayerInfo) GetLayerId 

func (x *LayerInfo) GetLayerId() string

func (*LayerInfo) GetVersion 

func (x *LayerInfo) GetVersion() string

func (*LayerInfo) ProtoMessage 

func (*LayerInfo) ProtoMessage()

func (*LayerInfo) ProtoReflect 

func (x *LayerInfo) ProtoReflect() protoreflect.Message

func (*LayerInfo) Reset 

func (x *LayerInfo) Reset()

func (*LayerInfo) String 

func (x *LayerInfo) String() string

type SchedulerNotifications 

type SchedulerNotifications struct {

	// Types that are assignable to SchedulerNotification:
	//
	//	*SchedulerNotifications_SotaStatus
	//	*SchedulerNotifications_FotaStatus
	SchedulerNotification isSchedulerNotifications_SchedulerNotification `protobuf_oneof:"SchedulerNotification"`
	// contains filtered or unexported fields
}

func (*SchedulerNotifications) Descriptor deprecated 

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

Deprecated: Use SchedulerNotifications.ProtoReflect.Descriptor instead.

func (*SchedulerNotifications) GetFotaStatus 

func (x *SchedulerNotifications) GetFotaStatus() *UpdateFOTAStatus

func (*SchedulerNotifications) GetSchedulerNotification 

func (m *SchedulerNotifications) GetSchedulerNotification() isSchedulerNotifications_SchedulerNotification

func (*SchedulerNotifications) GetSotaStatus 

func (x *SchedulerNotifications) GetSotaStatus() *UpdateSOTAStatus

func (*SchedulerNotifications) ProtoMessage 

func (*SchedulerNotifications) ProtoMessage()

func (*SchedulerNotifications) ProtoReflect 

func (x *SchedulerNotifications) ProtoReflect() protoreflect.Message

func (*SchedulerNotifications) Reset 

func (x *SchedulerNotifications) Reset()

func (*SchedulerNotifications) String 

func (x *SchedulerNotifications) String() string

type SchedulerNotifications_FotaStatus 

type SchedulerNotifications_FotaStatus struct {
	FotaStatus *UpdateFOTAStatus `protobuf:"bytes,2,opt,name=fota_status,json=fotaStatus,proto3,oneof"`
}

type SchedulerNotifications_SotaStatus 

type SchedulerNotifications_SotaStatus struct {
	SotaStatus *UpdateSOTAStatus `protobuf:"bytes,1,opt,name=sota_status,json=sotaStatus,proto3,oneof"`
}

type ServiceInfo 

type ServiceInfo struct {
	ServiceId string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	Version   string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceInfo) Descriptor deprecated 

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

Deprecated: Use ServiceInfo.ProtoReflect.Descriptor instead.

func (*ServiceInfo) GetServiceId 

func (x *ServiceInfo) GetServiceId() string

func (*ServiceInfo) GetVersion 

func (x *ServiceInfo) GetVersion() string

func (*ServiceInfo) ProtoMessage 

func (*ServiceInfo) ProtoMessage()

func (*ServiceInfo) ProtoReflect 

func (x *ServiceInfo) ProtoReflect() protoreflect.Message

func (*ServiceInfo) Reset 

func (x *ServiceInfo) Reset()

func (*ServiceInfo) String 

func (x *ServiceInfo) String() string

type UnimplementedUpdateSchedulerServiceServer 

type UnimplementedUpdateSchedulerServiceServer struct {
}

UnimplementedUpdateSchedulerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedUpdateSchedulerServiceServer) StartFOTAUpdate 

func (UnimplementedUpdateSchedulerServiceServer) StartFOTAUpdate(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedUpdateSchedulerServiceServer) StartSOTAUpdate 

func (UnimplementedUpdateSchedulerServiceServer) StartSOTAUpdate(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedUpdateSchedulerServiceServer) SubscribeNotifications 

func (UnimplementedUpdateSchedulerServiceServer) SubscribeNotifications(*emptypb.Empty, UpdateSchedulerService_SubscribeNotificationsServer) error

type UnitConfigInfo 

type UnitConfigInfo struct {
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*UnitConfigInfo) Descriptor deprecated 

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

Deprecated: Use UnitConfigInfo.ProtoReflect.Descriptor instead.

func (*UnitConfigInfo) GetVersion 

func (x *UnitConfigInfo) GetVersion() string

func (*UnitConfigInfo) ProtoMessage 

func (*UnitConfigInfo) ProtoMessage()

func (*UnitConfigInfo) ProtoReflect 

func (x *UnitConfigInfo) ProtoReflect() protoreflect.Message

func (*UnitConfigInfo) Reset 

func (x *UnitConfigInfo) Reset()

func (*UnitConfigInfo) String 

func (x *UnitConfigInfo) String() string

type UnsafeUpdateSchedulerServiceServer 

type UnsafeUpdateSchedulerServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeUpdateSchedulerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to UpdateSchedulerServiceServer will result in compilation errors.

type UpdateFOTAStatus 

type UpdateFOTAStatus struct {
	State      UpdateState       `protobuf:"varint,1,opt,name=state,proto3,enum=communicationmanager.v3.UpdateState" json:"state,omitempty"`
	Components []*ComponentInfo  `protobuf:"bytes,2,rep,name=components,proto3" json:"components,omitempty"`
	Error      *common.ErrorInfo `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateFOTAStatus) Descriptor deprecated 

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

Deprecated: Use UpdateFOTAStatus.ProtoReflect.Descriptor instead.

func (*UpdateFOTAStatus) GetComponents 

func (x *UpdateFOTAStatus) GetComponents() []*ComponentInfo

func (*UpdateFOTAStatus) GetError 

func (x *UpdateFOTAStatus) GetError() *common.ErrorInfo

func (*UpdateFOTAStatus) GetState 

func (x *UpdateFOTAStatus) GetState() UpdateState

func (*UpdateFOTAStatus) ProtoMessage 

func (*UpdateFOTAStatus) ProtoMessage()

func (*UpdateFOTAStatus) ProtoReflect 

func (x *UpdateFOTAStatus) ProtoReflect() protoreflect.Message

func (*UpdateFOTAStatus) Reset 

func (x *UpdateFOTAStatus) Reset()

func (*UpdateFOTAStatus) String 

func (x *UpdateFOTAStatus) String() string

type UpdateSOTAStatus 

type UpdateSOTAStatus struct {
	State            UpdateState       `protobuf:"varint,1,opt,name=state,proto3,enum=communicationmanager.v3.UpdateState" json:"state,omitempty"`
	UnitConfig       *UnitConfigInfo   `protobuf:"bytes,2,opt,name=unit_config,json=unitConfig,proto3" json:"unit_config,omitempty"`
	InstallServices  []*ServiceInfo    `protobuf:"bytes,3,rep,name=install_services,json=installServices,proto3" json:"install_services,omitempty"`
	RemoveServices   []*ServiceInfo    `protobuf:"bytes,4,rep,name=remove_services,json=removeServices,proto3" json:"remove_services,omitempty"`
	InstallLayers    []*LayerInfo      `protobuf:"bytes,5,rep,name=install_layers,json=installLayers,proto3" json:"install_layers,omitempty"`
	RemoveLayers     []*LayerInfo      `protobuf:"bytes,6,rep,name=remove_layers,json=removeLayers,proto3" json:"remove_layers,omitempty"`
	RebalanceRequest bool              `protobuf:"varint,7,opt,name=rebalance_request,json=rebalanceRequest,proto3" json:"rebalance_request,omitempty"`
	Error            *common.ErrorInfo `protobuf:"bytes,8,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSOTAStatus) Descriptor deprecated 

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

Deprecated: Use UpdateSOTAStatus.ProtoReflect.Descriptor instead.

func (*UpdateSOTAStatus) GetError 

func (x *UpdateSOTAStatus) GetError() *common.ErrorInfo

func (*UpdateSOTAStatus) GetInstallLayers 

func (x *UpdateSOTAStatus) GetInstallLayers() []*LayerInfo

func (*UpdateSOTAStatus) GetInstallServices 

func (x *UpdateSOTAStatus) GetInstallServices() []*ServiceInfo

func (*UpdateSOTAStatus) GetRebalanceRequest 

func (x *UpdateSOTAStatus) GetRebalanceRequest() bool

func (*UpdateSOTAStatus) GetRemoveLayers 

func (x *UpdateSOTAStatus) GetRemoveLayers() []*LayerInfo

func (*UpdateSOTAStatus) GetRemoveServices 

func (x *UpdateSOTAStatus) GetRemoveServices() []*ServiceInfo

func (*UpdateSOTAStatus) GetState 

func (x *UpdateSOTAStatus) GetState() UpdateState

func (*UpdateSOTAStatus) GetUnitConfig 

func (x *UpdateSOTAStatus) GetUnitConfig() *UnitConfigInfo

func (*UpdateSOTAStatus) ProtoMessage 

func (*UpdateSOTAStatus) ProtoMessage()

func (*UpdateSOTAStatus) ProtoReflect 

func (x *UpdateSOTAStatus) ProtoReflect() protoreflect.Message

func (*UpdateSOTAStatus) Reset 

func (x *UpdateSOTAStatus) Reset()

func (*UpdateSOTAStatus) String 

func (x *UpdateSOTAStatus) String() string

type UpdateSchedulerServiceClient 

type UpdateSchedulerServiceClient interface {
	StartFOTAUpdate(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	StartSOTAUpdate(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	SubscribeNotifications(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (UpdateSchedulerService_SubscribeNotificationsClient, error)
}

UpdateSchedulerServiceClient is the client API for UpdateSchedulerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewUpdateSchedulerServiceClient 

func NewUpdateSchedulerServiceClient(cc grpc.ClientConnInterface) UpdateSchedulerServiceClient

type UpdateSchedulerServiceServer 

type UpdateSchedulerServiceServer interface {
	StartFOTAUpdate(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	StartSOTAUpdate(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	SubscribeNotifications(*emptypb.Empty, UpdateSchedulerService_SubscribeNotificationsServer) error
	// contains filtered or unexported methods
}

UpdateSchedulerServiceServer is the server API for UpdateSchedulerService service. All implementations must embed UnimplementedUpdateSchedulerServiceServer for forward compatibility

type UpdateSchedulerService_SubscribeNotificationsClient 

type UpdateSchedulerService_SubscribeNotificationsClient interface {
	Recv() (*SchedulerNotifications, error)
	grpc.ClientStream
}

type UpdateSchedulerService_SubscribeNotificationsServer 

type UpdateSchedulerService_SubscribeNotificationsServer interface {
	Send(*SchedulerNotifications) error
	grpc.ServerStream
}

type UpdateState 

type UpdateState int32
const (
	UpdateState_NO_UPDATE       UpdateState = 0
	UpdateState_DOWNLOADING     UpdateState = 1
	UpdateState_READY_TO_UPDATE UpdateState = 2
	UpdateState_UPDATING        UpdateState = 3
)

func (UpdateState) Descriptor 

func (UpdateState) Descriptor() protoreflect.EnumDescriptor

func (UpdateState) Enum 

func (x UpdateState) Enum() *UpdateState

func (UpdateState) EnumDescriptor deprecated 

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

Deprecated: Use UpdateState.Descriptor instead.

func (UpdateState) Number 

func (x UpdateState) Number() protoreflect.EnumNumber

func (UpdateState) String 

func (x UpdateState) String() string

func (UpdateState) Type 

func (UpdateState) Type() protoreflect.EnumType

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.