servers

Documentation

Index

• type AdminServer
  • func NewAdminServer(r *repository.Service, m *manifest.Service, d *device.Service, ...) *AdminServer
  • func (a *AdminServer) AddNamespace(ctx context.Context, req *pb.AddNamespaceRequest) (*pb.Namespace, error)
  • func (a *AdminServer) AddRepository(ctx context.Context, req *pb.AddRepositoryRequest) (*pb.AddRepositoryResponse, error)
  • func (a *AdminServer) AddSet(ctx context.Context, req *pb.AddSetRequest) (*common.Set, error)
  • func (a *AdminServer) DeleteNamespace(ctx context.Context, req *pb.IdRequest) (*pb.Namespace, error)
  • func (a *AdminServer) DeleteSet(ctx context.Context, in *pb.IdRequest) (*common.Set, error)
  • func (a *AdminServer) GetDevice(ctx context.Context, req *pb.IdRequest) (*common.Device, error)
  • func (a *AdminServer) GetDevices(ctx context.Context, req *pb.DevicesListRequest) (*pb.DevicesListResponse, error)
  • func (a *AdminServer) GetManifest(ctx context.Context, req *pb.IdRequest) (*pb.Manifest, error)
  • func (a *AdminServer) GetManifests(ctx context.Context, req *pb.ListRequest) (*pb.ManifestListResponse, error)
  • func (a *AdminServer) GetNamespaces(ctx context.Context, req *pb.ListRequest) (*pb.NamespaceListResponse, error)
  • func (a *AdminServer) GetRepositories(ctx context.Context, req *pb.ListRequest) (*pb.RepositoryListResponse, error)
  • func (a *AdminServer) GetSet(ctx context.Context, req *pb.IdRequest) (*common.Set, error)
  • func (a *AdminServer) GetSets(ctx context.Context, req *pb.ListRequest) (*pb.SetsListResponse, error)
  • func (a *AdminServer) UpdateDevice(ctx context.Context, req *pb.UpdateDeviceRequest) (*common.Device, error)
  • func (a *AdminServer) UpdateNamespace(ctx context.Context, req *pb.UpdateNamespaceRequest) (*pb.Namespace, error)
  • func (a *AdminServer) UpdateSet(ctx context.Context, in *pb.UpdateSetRequest) (*common.Set, error)
• type EdgeServer
  • func NewEdgeServer(edgeService *edge.Service) *EdgeServer
  • func (e *EdgeServer) Enrol(ctx context.Context, req *pb.EnrolRequest) (*pb.EnrolResponse, error)
  • func (e *EdgeServer) GetConfiguration(ctx context.Context, req *pb.ConfigurationRequest) (*pb.ConfigurationResponse, error)
  • func (e *EdgeServer) Heartbeat(ctx context.Context, req *common.HeartbeatInfo) (*common.Empty, error)
  • func (e *EdgeServer) Register(ctx context.Context, req *pb.RegistrationRequest) (*pb.RegistrationResponse, error)

Types

type AdminServer

type AdminServer struct {
	pb.UnsafeAdminServiceServer
	// contains filtered or unexported fields
}

func NewAdminServer

func NewAdminServer(r *repository.Service, m *manifest.Service, d *device.Service, c *configuration.Service) *AdminServer

func (*AdminServer) AddNamespace

func (a *AdminServer) AddNamespace(ctx context.Context, req *pb.AddNamespaceRequest) (*pb.Namespace, error)

func (*AdminServer) AddRepository

func (a *AdminServer) AddRepository(ctx context.Context, req *pb.AddRepositoryRequest) (*pb.AddRepositoryResponse, error)

AddRepository add a repository

func (*AdminServer) AddSet

func (a *AdminServer) AddSet(ctx context.Context, req *pb.AddSetRequest) (*common.Set, error)

func (*AdminServer) DeleteNamespace

func (a *AdminServer) DeleteNamespace(ctx context.Context, req *pb.IdRequest) (*pb.Namespace, error)

func (*AdminServer) DeleteSet

func (a *AdminServer) DeleteSet(ctx context.Context, in *pb.IdRequest) (*common.Set, error)

func (*AdminServer) GetDevice

func (a *AdminServer) GetDevice(ctx context.Context, req *pb.IdRequest) (*common.Device, error)

func (*AdminServer) GetDevices

func (a *AdminServer) GetDevices(ctx context.Context, req *pb.DevicesListRequest) (*pb.DevicesListResponse, error)

func (*AdminServer) GetManifest

func (a *AdminServer) GetManifest(ctx context.Context, req *pb.IdRequest) (*pb.Manifest, error)

GetWorkload return a workload

func (*AdminServer) GetManifests

func (a *AdminServer) GetManifests(ctx context.Context, req *pb.ListRequest) (*pb.ManifestListResponse, error)

GetWorkloads return a list of workloads

func (*AdminServer) GetNamespaces

func (a *AdminServer) GetNamespaces(ctx context.Context, req *pb.ListRequest) (*pb.NamespaceListResponse, error)

func (*AdminServer) GetRepositories

func (a *AdminServer) GetRepositories(ctx context.Context, req *pb.ListRequest) (*pb.RepositoryListResponse, error)

GetRepositories return a list of repositories

func (*AdminServer) GetSet

func (a *AdminServer) GetSet(ctx context.Context, req *pb.IdRequest) (*common.Set, error)

GetDeviceSet returns a device set.

func (*AdminServer) GetSets

func (a *AdminServer) GetSets(ctx context.Context, req *pb.ListRequest) (*pb.SetsListResponse, error)

GetDeviceSets returns a list of device sets.

func (*AdminServer) UpdateDevice

func (a *AdminServer) UpdateDevice(ctx context.Context, req *pb.UpdateDeviceRequest) (*common.Device, error)

func (*AdminServer) UpdateNamespace

func (a *AdminServer) UpdateNamespace(ctx context.Context, req *pb.UpdateNamespaceRequest) (*pb.Namespace, error)

func (*AdminServer) UpdateSet

func (a *AdminServer) UpdateSet(ctx context.Context, in *pb.UpdateSetRequest) (*common.Set, error)

type EdgeServer

type EdgeServer struct {
	pb.UnimplementedEdgeServiceServer
	// contains filtered or unexported fields
}

func NewEdgeServer

func NewEdgeServer(edgeService *edge.Service) *EdgeServer

func (*EdgeServer) Enrol

func (e *EdgeServer) Enrol(ctx context.Context, req *pb.EnrolRequest) (*pb.EnrolResponse, error)

func (*EdgeServer) GetConfiguration

func (e *EdgeServer) GetConfiguration(ctx context.Context, req *pb.ConfigurationRequest) (*pb.ConfigurationResponse, error)

func (*EdgeServer) Heartbeat

func (e *EdgeServer) Heartbeat(ctx context.Context, req *common.HeartbeatInfo) (*common.Empty, error)

func (*EdgeServer) Register

func (e *EdgeServer) Register(ctx context.Context, req *pb.RegistrationRequest) (*pb.RegistrationResponse, error)