datasource

Documentation

Index

• Constants
• func NewRouter(service *Service) *mux.Router
• func NewServer(parentCtx context.Context, ...) error
• type Service
  • func LaunchService(ctx context.Context, cancel context.CancelFunc, ...) (*Service, error)
  • func (s *Service) Get(writer http.ResponseWriter, request *http.Request)
  • func (s *Service) Transfer(writer http.ResponseWriter, request *http.Request)
  • func (s *Service) Upload(writer http.ResponseWriter, request *http.Request)

Constants

const (
	RetryInterval = time.Second
	RetryCount    = 60

	TimeoutBeginErrorMessage = "timeout waiting for the datasource file processing begin"
)

Functions

func NewRouter

func NewRouter(service *Service) *mux.Router

NewRouter creates and configures a mux router

func NewServer

func NewServer(parentCtx context.Context, listenAddr, syncListenAddr, checksum, sourceType, biName, biUUID, diskPathInContainer string, parameters map[string]string, credential map[string]string, handler sync.Handler) error

Types

type Service

type Service struct {
	// contains filtered or unexported fields
}

func LaunchService

func LaunchService(ctx context.Context, cancel context.CancelFunc,
	syncListenAddr, checksum, sourceType, name, uuid, diskPathInContainer string,
	parameters map[string]string, credential map[string]string) (*Service, error)

func (*Service) Get

func (s *Service) Get(writer http.ResponseWriter, request *http.Request)

func (*Service) Transfer

func (s *Service) Transfer(writer http.ResponseWriter, request *http.Request)

func (*Service) Upload

func (s *Service) Upload(writer http.ResponseWriter, request *http.Request)