Documentation
¶
Index ¶
- type Cleanup
- type MaxObjectSizeSource
- type NewServiceParams
- type Server
- type Service
- func (s *Service) DeleteTransitedObject(ctx context.Context, req *transitV2.DeleteTransitedObjectRequest) (*transitV2.DeleteTransitedObjectResponse, error)
- func (s *Service) ListModules(ctx context.Context, req *transitV2.ListModulesRequest) (*transitV2.ListModulesResponse, error)
- func (s *Service) ModuleAPIClientCache() *client.ModuleAPIClientCache
- func (s *Service) RestoreObject(ctx context.Context, req *transitV2.RestoreObjectRequest) (*transitV2.RestoreObjectResponse, error)
- func (s *Service) TransitObject(ctx context.Context, req *transitV2.TransitObjectRequest) (*transitV2.TransitObjectResponse, error)
- type StatusCleaner
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Cleanup ¶ added in v0.49.0
type Cleanup struct {
// contains filtered or unexported fields
}
func NewCleanup ¶ added in v0.49.0
func NewCleanup( getSvc *getsvc.Service, deleteSvc *deletesvc.Service, moduleCache *client.ModuleAPIClientCache, morphClient StatusCleaner, ) *Cleanup
func (*Cleanup) CleanupTransitionedObject ¶ added in v0.49.0
type MaxObjectSizeSource ¶ added in v0.49.0
type NewServiceParams ¶
type NewServiceParams struct {
Logger *logger.Logger
ContainerSource containercore.Source
TranisitionModulesNetAddrs []network.Address
NodePublicKey []byte
GetService *getsvc.Service
PutService *putsvc.Service
DeleteService *deletesvc.Service
RestoreStatusProvider restore.RestoreStatusProvider
NetmapState netmapcore.State
DialerSource *net.DialerSource
ModuleAPIClientCacheConfig client.ClientCacheConfig
StreamMessageObjectChunkSize int
MaxObjectSizeSource MaxObjectSizeSource
LockSource objectcore.LockSource
}
type Server ¶
type Server interface {
TransitObject(context.Context, *transitV2.TransitObjectRequest) (*transitV2.TransitObjectResponse, error)
RestoreObject(context.Context, *transitV2.RestoreObjectRequest) (*transitV2.RestoreObjectResponse, error)
DeleteTransitedObject(context.Context, *transitV2.DeleteTransitedObjectRequest) (*transitV2.DeleteTransitedObjectResponse, error)
ListModules(context.Context, *transitV2.ListModulesRequest) (*transitV2.ListModulesResponse, error)
}
func NewAuditService ¶
func NewSignService ¶
func NewSignService(key *ecdsa.PrivateKey, next Server) Server
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func NewService ¶
func NewService(ctx context.Context, params NewServiceParams) (*Service, error)
func (*Service) DeleteTransitedObject ¶
func (s *Service) DeleteTransitedObject(ctx context.Context, req *transitV2.DeleteTransitedObjectRequest) (*transitV2.DeleteTransitedObjectResponse, error)
func (*Service) ListModules ¶
func (s *Service) ListModules(ctx context.Context, req *transitV2.ListModulesRequest) (*transitV2.ListModulesResponse, error)
func (*Service) ModuleAPIClientCache ¶ added in v0.49.0
func (s *Service) ModuleAPIClientCache() *client.ModuleAPIClientCache
func (*Service) RestoreObject ¶
func (s *Service) RestoreObject(ctx context.Context, req *transitV2.RestoreObjectRequest) (*transitV2.RestoreObjectResponse, error)
func (*Service) TransitObject ¶
func (s *Service) TransitObject(ctx context.Context, req *transitV2.TransitObjectRequest) (*transitV2.TransitObjectResponse, error)
Source Files
¶
Click to show internal directories.
Click to hide internal directories.