tms

Documentation

Index

• type AuthToken
• type CommunicationInstance
  • func NewCommunicationInstance(httpClient piperHttp.Uploader, tmsUrl, uaaUrl, clientId, clientSecret string, ...) (*CommunicationInstance, error)
  • func (communicationInstance *CommunicationInstance) GetMtaExtDescriptor(nodeId int64, mtaId, mtaVersion string) (MtaExtDescriptor, error)
  • func (communicationInstance *CommunicationInstance) GetNodes() ([]Node, error)
  • func (communicationInstance *CommunicationInstance) UpdateMtaExtDescriptor(nodeId, idOfMtaExtDescriptor int64, ...) (MtaExtDescriptor, error)
  • func (communicationInstance *CommunicationInstance) UploadFile(file, namedUser string) (FileInfo, error)
  • func (communicationInstance *CommunicationInstance) UploadFileToNode(nodeName, fileId, description, namedUser string) (NodeUploadResponseEntity, error)
  • func (communicationInstance *CommunicationInstance) UploadMtaExtDescriptorToNode(nodeId int64, file, mtaVersion, description, namedUser string) (MtaExtDescriptor, error)
• type CommunicationInterface
• type Entry
• type FileInfo
• type MtaExtDescriptor
• type Node
• type NodeUploadRequestEntity
• type NodeUploadResponseEntity
• type QueueEntry

Types

type AuthToken

type AuthToken struct {
	TokenType   string `json:"token_type"`
	AccessToken string `json:"access_token"`
	ExpiresIn   int    `json:"expires_in"`
}

type CommunicationInstance

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

func NewCommunicationInstance

func NewCommunicationInstance(httpClient piperHttp.Uploader, tmsUrl, uaaUrl, clientId, clientSecret string, isVerbose bool) (*CommunicationInstance, error)

NewCommunicationInstance returns CommunicationInstance structure with http client prepared for communication with TMS backend

func (*CommunicationInstance) GetMtaExtDescriptor

func (communicationInstance *CommunicationInstance) GetMtaExtDescriptor(nodeId int64, mtaId, mtaVersion string) (MtaExtDescriptor, error)

func (*CommunicationInstance) GetNodes

func (communicationInstance *CommunicationInstance) GetNodes() ([]Node, error)

func (*CommunicationInstance) UpdateMtaExtDescriptor

func (communicationInstance *CommunicationInstance) UpdateMtaExtDescriptor(nodeId, idOfMtaExtDescriptor int64, file, mtaVersion, description, namedUser string) (MtaExtDescriptor, error)

func (*CommunicationInstance) UploadFile

func (communicationInstance *CommunicationInstance) UploadFile(file, namedUser string) (FileInfo, error)

func (*CommunicationInstance) UploadFileToNode

func (communicationInstance *CommunicationInstance) UploadFileToNode(nodeName, fileId, description, namedUser string) (NodeUploadResponseEntity, error)

func (*CommunicationInstance) UploadMtaExtDescriptorToNode

func (communicationInstance *CommunicationInstance) UploadMtaExtDescriptorToNode(nodeId int64, file, mtaVersion, description, namedUser string) (MtaExtDescriptor, error)

type CommunicationInterface

type CommunicationInterface interface {
	GetNodes() ([]Node, error)
	GetMtaExtDescriptor(nodeId int64, mtaId, mtaVersion string) (MtaExtDescriptor, error)
	UpdateMtaExtDescriptor(nodeId, idOfMtaExtDescriptor int64, file, mtaVersion, description, namedUser string) (MtaExtDescriptor, error)
	UploadMtaExtDescriptorToNode(nodeId int64, file, mtaVersion, description, namedUser string) (MtaExtDescriptor, error)
	UploadFile(file, namedUser string) (FileInfo, error)
	UploadFileToNode(nodeName, fileId, description, namedUser string) (NodeUploadResponseEntity, error)
}

type Entry

type Entry struct {
	Uri string `json:"uri"`
}

type FileInfo

type FileInfo struct {
	Id   int64  `json:"fileId"`
	Name string `json:"fileName"`
}

type MtaExtDescriptor

type MtaExtDescriptor struct {
	Id            int64  `json:"id"`
	Description   string `json:"description"`
	MtaId         string `json:"mtaId"`
	MtaExtId      string `json:"mtaExtId"`
	MtaVersion    string `json:"mtaVersion"`
	LastChangedAt string `json:"lastChangedAt"`
}

type Node

type Node struct {
	Id   int64  `json:"id"`
	Name string `json:"name"`
}

type NodeUploadRequestEntity

type NodeUploadRequestEntity struct {
	ContentType string  `json:"contentType"`
	StorageType string  `json:"storageType"`
	NodeName    string  `json:"nodeName"`
	Description string  `json:"description"`
	NamedUser   string  `json:"namedUser"`
	Entries     []Entry `json:"entries"`
}

type NodeUploadResponseEntity

type NodeUploadResponseEntity struct {
	TransportRequestId          int64        `json:"transportRequestId"`
	TransportRequestDescription string       `json:"transportRequestDescription"`
	QueueEntries                []QueueEntry `json:"queueEntries"`
}

type QueueEntry

type QueueEntry struct {
	Id       int64  `json:"queueId"`
	NodeId   int64  `json:"nodeId"`
	NodeName string `json:"nodeName"`
}