common

package
v0.0.0-...-f839e32 Latest Latest
Warning

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

 Go to latest Published: Aug 3, 2023 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// AddressReserved specifies reserved value due to first enum value has to be zero in proto3
	AddressReserved int32 = 0
	// AddressS3 specifies S3 and MinIO address
	AddressS3 int32 = 100
	// AddressKafka specifies Kafka address
	AddressKafka int32 = 200
	// AddressDigest specifies digest-based address
	AddressDigest int32 = 300
	// AddressUUID specifies UUID-based address
	AddressUUID int32 = 400
	// AddressUserID specifies UserID-based address. Used to specify any related user (owner, sender, etc)
	AddressUserID int32 = 500
	// AddressDirname specifies dirname/path-based address
	AddressDirname int32 = 600
	// AddressFilename specifies filename/filepath-based address
	AddressFilename int32 = 700
	// AddressURL specifies URL address
	AddressURL int32 = 800
	// AddressDomain specifies Domain address
	AddressDomain int32 = 900
	// AddressMachineID specifies MachineID-based address
	AddressMachineID int32 = 1000
	// AddressEmail specifies Email address
	AddressEmail int32 = 1100
	// AddressCustom specifies Custom string
	AddressCustom int32 = 1200
)

AddressType represents all types of domain-specific addresses in the system

View Source 
const (
	CompressionTypeNone = 0
	CompressionTypeLZMA = 100
)
View Source 
const (
	// DataChunkTypeReserved is a reserved data chunk type. Due to first enum value has to be zero in proto3.
	DataChunkTypeReserved int32 = 0
	// DataChunkTypeUnspecified is an unspecified data chunk type. Unspecified means data chunk type is unknown.
	DataChunkTypeUnspecified int32 = 100
	// DataChunkTypeData is a custom data Data chunk.
	DataChunkTypeData int32 = 200
)
View Source 
const (
	ModeReserved    int32 = 0
	ModeUnspecified int32 = 100
	ModeAll         int32 = 200
	ModeAny         int32 = 300
)

Mode represents all types of modes in the system

View Source 
const (
	ReportTypeReserved    = 0
	ReportTypeUnspecified = 100
)
View Source 
const (
	// Due to first enum value has to be zero in proto3
	StatusCodeReserved int32 = 0
	// Unspecified means we do not know its type
	StatusCodeUnspecified int32 = 100
	// Object found
	StatusCodeOK int32 = 200
	// Object created
	StatusCodeCreated int32 = 201
	// Object accepted
	StatusCodeAccepted int32 = 202
	// Not all parts/objects requested were found
	StatusCodePartial int32 = 206
	// All objects found
	StatusCodeFoundAll int32 = 220
	// Object is in progress of something
	StatusCodeInProgress int32 = 230
	// Object moved to other location
	StatusCodeMovedPermanently int32 = 301
	// Object not found
	StatusCodeNotFound int32 = 404
	// Object not ready
	StatusCodeNotReady int32 = 405
	// Object has failed due to internal error
	StatusCodeInternalError int32 = 500
	// Object failed somehow
	StatusCodeFailed int32 = 550
)

StatusCode represents all codes of statuses

View Source 
const (
	// Due to first enum value has to be zero in proto3
	TaskReserved int32 = 0
	// Unspecified
	TaskUnspecified int32 = 100
	// Echo request expects echo reply as an answer
	TaskEchoRequest int32 = 200
	// Echo reply is an answer to echo request
	TaskEchoReply int32 = 300
	// Request for configuration from the other party
	TaskConfigRequest int32 = 400
	// Configuration
	TaskConfig int32 = 500
	// Metrics schedule sends schedule by which metrics should be sent.
	TaskMetricsSchedule int32 = 600
	// Metrics request is an explicit request for metrics to be sent
	TaskMetricsRequest int32 = 700
	// One-time metrics
	TaskMetrics int32 = 800
	// Schedule to send data
	TaskDataSchedule int32 = 900
	// Explicit data request
	TaskDataRequest int32 = 1000
	// Data are coming
	TaskData int32 = 1100
	// Address is coming
	TaskAddress            int32 = 1200
	TaskExtract            int32 = 1300
	TaskExtractExecutables int32 = 1400
)

Variables

View Source 
var (
	DigestType_name = map[int32]string{
		0:   "DIGEST_RESERVED",
		100: "DIGEST_UNSPECIFIED",
		200: "DIGEST_MD5",
		300: "DIGEST_SHA256",
	}
	DigestType_value = map[string]int32{
		"DIGEST_RESERVED":    0,
		"DIGEST_UNSPECIFIED": 100,
		"DIGEST_MD5":         200,
		"DIGEST_SHA256":      300,
	}
)

Enum value maps for DigestType.

View Source 
var (
	// DomainThis specifies generic domain [general purpose domain]
	DomainThis = NewDomain("this")
	// DomainSrc specifies abstract source [general purpose domain]
	DomainSrc = NewDomain("src")
	// DomainDst specifies abstract destination [general purpose domain]
	DomainDst = NewDomain("dst")
	// DomainReference specifies abstract reference [general purpose domain]
	DomainReference = NewDomain("reference")
	// DomainContext specifies abstract context [general purpose domain]
	DomainContext = NewDomain("context")
	// DomainTask specifies abstract task [general purpose domain]
	DomainTask = NewDomain("task")
	// DomainTaskResult specifies abstract task result [general purpose domain]
	DomainTaskResult = NewDomain("task_result")
	// DomainFile specifies abstract file [general purpose domain]
	DomainFile = NewDomain("file")
	// DomainStatus specifies abstract status [general purpose domain]
	DomainStatus = NewDomain("status")
	// DomainParent specifies abstract parent [general purpose domain]
	DomainParent = NewDomain("parent")
	// DomainReport specifies abstract report [general purpose domain]
	DomainReport = NewDomain("report")
	// DomainResult specifies abstract result [general purpose domain]
	DomainResult = NewDomain("result")
	// DomainInterim specifies abstract interim entities [general purpose domain]
	DomainInterim = NewDomain("interim")
	// DomainAddress specifies abstract address [general purpose domain]
	DomainAddress = NewDomain("address")
	// DomainUser specifies abstract user address [general purpose domain]
	DomainUser = NewDomain("user")
	// DomainProject specifies abstract project address [general purpose domain]
	DomainProject = NewDomain("project")
	// DomainAsset specifies abstract asset address [general purpose domain]
	DomainAsset = NewDomain("asset")

	// DomainS3 specifies S3 domain [predefined address domain]
	DomainS3 = NewDomain("s3")
	// DomainKafka specifies Kafka domain [predefined address domain]
	DomainKafka = NewDomain("kafka")
	// DomainDigest specifies digest (hash, etc.) [predefined address domain]
	DomainDigest = NewDomain("digest")
	// DomainUUID specifies UUID [predefined address domain]
	DomainUUID = NewDomain("uuid")
	// DomainUserID specifies user ID [predefined address domain]
	DomainUserID = NewDomain("user_id")
	// DomainDirname specifies name of the directory [predefined address domain]
	DomainDirname = NewDomain("dirname")
	// DomainFilename specifies file name [predefined address domain]
	DomainFilename = NewDomain("filename")
	// DomainURL specifies URL [predefined address domain]
	DomainURL = NewDomain("url")
	// DomainDomain specifies domain [predefined address domain]
	DomainDomain = NewDomain("domain")
	// DomainMachineID specifies machine ID [predefined address domain]
	DomainMachineID = NewDomain("machine_id")
	// DomainAssetID specifies asset ID [predefined address domain]
	DomainAssetID = NewDomain("asset_id")
	// DomainTaskID specifies task ID [predefined address domain]
	DomainTaskID = NewDomain("task_id")
	// DomainProjectID specifies project ID [predefined address domain]
	DomainProjectID = NewDomain("project_id")
	// DomainEmail specifies email [predefined address domain]
	DomainEmail = NewDomain("email")
	// DomainCustom specifies custom domain [predefined address domain]
	DomainCustom = NewDomain("custom")

	// Domains specifies list of all registered domains
	Domains = []*Domain{

		DomainThis,
		DomainSrc,
		DomainDst,
		DomainReference,
		DomainContext,
		DomainTask,
		DomainTaskResult,
		DomainFile,
		DomainStatus,
		DomainParent,
		DomainReport,
		DomainResult,
		DomainInterim,
		DomainAddress,
		DomainUser,
		DomainProject,
		DomainAsset,

		DomainS3,
		DomainKafka,
		DomainDigest,
		DomainUUID,
		DomainUserID,
		DomainDirname,
		DomainFilename,
		DomainURL,
		DomainDomain,
		DomainMachineID,
		DomainAssetID,
		DomainTaskID,
		DomainProjectID,
		DomainEmail,
		DomainCustom,
	}
)
View Source 
var (
	ServingStatus_name = map[int32]string{
		0: "UNKNOWN",
		1: "SERVING",
		2: "NOT_SERVING",
	}
	ServingStatus_value = map[string]int32{
		"UNKNOWN":     0,
		"SERVING":     1,
		"NOT_SERVING": 2,
	}
)

Enum value maps for ServingStatus.

View Source 
var (
	MetricType_name = map[int32]string{
		0:   "METRIC_TYPE_RESERVED",
		100: "METRIC_TYPE_UNSPECIFIED",
		200: "METRIC_TYPE_CPU",
		300: "METRIC_TYPE_RAM",
	}
	MetricType_value = map[string]int32{
		"METRIC_TYPE_RESERVED":    0,
		"METRIC_TYPE_UNSPECIFIED": 100,
		"METRIC_TYPE_CPU":         200,
		"METRIC_TYPE_RAM":         300,
	}
)

Enum value maps for MetricType.

View Source 
var (
	MetricsType_name = map[int32]string{
		0:   "METRICS_TYPE_RESERVED",
		100: "METRICS_TYPE_UNSPECIFIED",
		200: "METRICS_TYPE_RESOURCE_UTILIZATION",
	}
	MetricsType_value = map[string]int32{
		"METRICS_TYPE_RESERVED":             0,
		"METRICS_TYPE_UNSPECIFIED":          100,
		"METRICS_TYPE_RESOURCE_UTILIZATION": 200,
	}
)

Enum value maps for MetricsType.

View Source 
var (
	StatusReserved         = NewStatus(StatusCodeReserved)
	StatusUnspecified      = NewStatus(StatusCodeUnspecified)
	StatusOK               = NewStatus(StatusCodeOK)
	StatusCreated          = NewStatus(StatusCodeCreated)
	StatusAccepted         = NewStatus(StatusCodeAccepted)
	StatusPartial          = NewStatus(StatusCodePartial)
	StatusFoundAll         = NewStatus(StatusCodeFoundAll)
	StatusInProgress       = NewStatus(StatusCodeInProgress)
	StatusMovedPermanently = NewStatus(StatusCodeMovedPermanently)
	StatusNotFound         = NewStatus(StatusCodeNotFound)
	StatusNotReady         = NewStatus(StatusCodeNotReady)
	StatusInternalError    = NewStatus(StatusCodeInternalError)
	StatusFailed           = NewStatus(StatusCodeFailed)

	Statuses = []*Status{
		StatusReserved,
		StatusUnspecified,
		StatusOK,
		StatusCreated,
		StatusAccepted,
		StatusPartial,
		StatusFoundAll,
		StatusInProgress,
		StatusMovedPermanently,
		StatusNotFound,
		StatusNotReady,
		StatusInternalError,
		StatusFailed,
	}
)
View Source 
var AddressTypeEnum = NewEnum()
View Source 
var CompressionTypeEnum = NewEnum()
View Source 
var DataChunkTypeEnum = NewEnum()

DataChunkTypeEnum is an enum of available data chunk types.

View Source 
var File_api_common_address_list_proto protoreflect.FileDescriptor
View Source 
var File_api_common_address_map_proto protoreflect.FileDescriptor
View Source 
var File_api_common_address_proto protoreflect.FileDescriptor
View Source 
var File_api_common_compression_proto protoreflect.FileDescriptor
View Source 
var File_api_common_data_chunk_properties_proto protoreflect.FileDescriptor
View Source 
var File_api_common_data_chunk_proto protoreflect.FileDescriptor
View Source 
var File_api_common_data_packet_proto protoreflect.FileDescriptor
View Source 
var File_api_common_diff_task_proto protoreflect.FileDescriptor
View Source 
var File_api_common_digest_proto protoreflect.FileDescriptor
View Source 
var File_api_common_dirname_proto protoreflect.FileDescriptor
View Source 
var File_api_common_domain_proto protoreflect.FileDescriptor
View Source 
var File_api_common_email_proto protoreflect.FileDescriptor
View Source 
var File_api_common_encoding_proto protoreflect.FileDescriptor
View Source 
var File_api_common_error_proto protoreflect.FileDescriptor
View Source 
var File_api_common_file_proto protoreflect.FileDescriptor
View Source 
var File_api_common_filename_proto protoreflect.FileDescriptor
View Source 
var File_api_common_health_proto protoreflect.FileDescriptor
View Source 
var File_api_common_kafka_address_proto protoreflect.FileDescriptor
View Source 
var File_api_common_kafka_endpoint_proto protoreflect.FileDescriptor
View Source 
var File_api_common_machine_id_proto protoreflect.FileDescriptor
View Source 
var File_api_common_metadata_proto protoreflect.FileDescriptor
View Source 
var File_api_common_metric_proto protoreflect.FileDescriptor
View Source 
var File_api_common_metrics_proto protoreflect.FileDescriptor
View Source 
var File_api_common_object_request_proto protoreflect.FileDescriptor
View Source 
var File_api_common_object_status_proto protoreflect.FileDescriptor
View Source 
var File_api_common_objects_list_proto protoreflect.FileDescriptor
View Source 
var File_api_common_objects_request_proto protoreflect.FileDescriptor
View Source 
var File_api_common_presentation_options_proto protoreflect.FileDescriptor
View Source 
var File_api_common_report_proto protoreflect.FileDescriptor
View Source 
var File_api_common_response_header_proto protoreflect.FileDescriptor
View Source 
var File_api_common_s3_address_proto protoreflect.FileDescriptor
View Source 
var File_api_common_slice_int32_proto protoreflect.FileDescriptor
View Source 
var File_api_common_status_proto protoreflect.FileDescriptor
View Source 
var File_api_common_task_proto protoreflect.FileDescriptor
View Source 
var File_api_common_trace_proto protoreflect.FileDescriptor
View Source 
var File_api_common_url_proto protoreflect.FileDescriptor
View Source 
var File_api_common_user_id_proto protoreflect.FileDescriptor
View Source 
var File_api_common_uuid_proto protoreflect.FileDescriptor
View Source 
var ModeEnum = NewEnum()
View Source 
var ReportTypeEnum = NewEnum()
View Source 
var StatusCodeEnum = NewEnum()
View Source 
var TaskTypeEnum = NewEnum()

Functions

func MustRegisterDomain 

func MustRegisterDomain(domain *Domain)

MustRegisterDomain the same as RegisterDomain but with panic

func MustRegisterStatus 

func MustRegisterStatus(status *Status)

MustRegisterStatus the same as RegisterStatus but with panic

Types

type Address 

type Address struct {

	// ExplicitDomain specifies explicitly domain, where address is specified
	ExplicitDomain *Domain `protobuf:"bytes,10,opt,name=explicit_domain,json=explicitDomain,proto3,oneof" json:"explicit_domain,omitempty"`
	// Types that are assignable to Address:
	//	*Address_S3
	//	*Address_Kafka
	//	*Address_Digest
	//	*Address_Uuid
	//	*Address_UserId
	//	*Address_Dirname
	//	*Address_Filename
	//	*Address_Url
	//	*Address_Domain
	//	*Address_MachineId
	//	*Address_Email
	//	*Address_Custom
	Address isAddress_Address `protobuf_oneof:"address"`
	// contains filtered or unexported fields
}

Address describes general address

func NewAddress 

func NewAddress(entities ...interface{}) *Address

NewAddress creates new Address with specified domain Call example: NewAddress(domain, address)

func NewAddressEmailFromString 

func NewAddressEmailFromString(str string, domain ...interface{}) *Address

NewAddressEmailFromString creates new Address with specified Domain with Email fetched from string

func NewAddressFromString 

func NewAddressFromString(str string) *Address

NewAddressFromString creates new address from string by parsing this string according to address's stringify rules.

func NewAddressUserIDFromString 

func NewAddressUserIDFromString(str string, domain ...interface{}) *Address

NewAddressUserIDFromString creates new Address with specified Domain with UUID fetched from string

func NewAddressUuidFromString 

func NewAddressUuidFromString(str string, domain ...interface{}) *Address

NewAddressUuidFromString creates new Address with specified Domain with UUID fetched from string

func NewAddressUuidRandom 

func NewAddressUuidRandom(domain ...interface{}) *Address

NewAddressUuidRandom creates new Address with specified Domain with random UUID

func (*Address) Descriptor deprecated 

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

Deprecated: Use Address.ProtoReflect.Descriptor instead.

func (*Address) Domain 

func (x *Address) Domain() *Domain

Domain gets domain of an address - either explicitly specified or from the value

func (*Address) Ensure 

func (x *Address) Ensure() *Address

Ensure returns new or existing Address

func (*Address) FullString 

func (x *Address) FullString() string

FullString returns string address with domain prefix

func (*Address) GetAddress 

func (m *Address) GetAddress() isAddress_Address

func (*Address) GetCustom 

func (x *Address) GetCustom() string

func (*Address) GetDigest 

func (x *Address) GetDigest() *Digest

func (*Address) GetDirname 

func (x *Address) GetDirname() *Dirname

func (*Address) GetDomain 

func (x *Address) GetDomain() *Domain

func (*Address) GetEmail 

func (x *Address) GetEmail() *Email

func (*Address) GetExplicitDomain 

func (x *Address) GetExplicitDomain() *Domain

func (*Address) GetFilename 

func (x *Address) GetFilename() *Filename

func (*Address) GetKafka 

func (x *Address) GetKafka() *KafkaAddress

func (*Address) GetMachineId 

func (x *Address) GetMachineId() *MachineID

func (*Address) GetS3 

func (x *Address) GetS3() *S3Address

func (*Address) GetUrl 

func (x *Address) GetUrl() *URL

func (*Address) GetUserId 

func (x *Address) GetUserId() *UserID

func (*Address) GetUuid 

func (x *Address) GetUuid() *UUID

func (*Address) ProtoMessage 

func (*Address) ProtoMessage()

func (*Address) ProtoReflect 

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

func (*Address) Reset 

func (x *Address) Reset()

func (*Address) Set 

func (x *Address) Set(address interface{}) *Address

Set sets value of the Address

func (*Address) SetExplicitDomain 

func (x *Address) SetExplicitDomain(domain *Domain) *Address

SetExplicitDomain is a setter

func (*Address) String 

func (x *Address) String() string

String return string address w/o domain prefix

type AddressList 

type AddressList struct {

	// Domain where addresses are specified. [Optional]
	Domain *Domain `protobuf:"bytes,100,opt,name=domain,proto3,oneof" json:"domain,omitempty"`
	// Addresses list.
	Addresses []*Address `protobuf:"bytes,200,rep,name=addresses,proto3" json:"addresses,omitempty"`
	// contains filtered or unexported fields
}

AddressList describes list of general address

func NewAddressList 

func NewAddressList() *AddressList

NewAddressList creates new AddressList

func NewAddressListFromString 

func NewAddressListFromString(str string) *AddressList

NewAddressListFromString creates new AddressList from string

func (*AddressList) All 

func (x *AddressList) All(domains ...*Domain) []*Address

All wraps GetAddresses and Select and returns all Addresses in specified domains May return nil

func (*AddressList) Append 

func (x *AddressList) Append(addresses ...*Address) *AddressList

Append appends addresses to the AddressList

func (*AddressList) Delete 

func (x *AddressList) Delete(domains ...*Domain) *AddressList

Delete deletes from the AddressList all addresses with specified domains

func (*AddressList) Descriptor deprecated 

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

Deprecated: Use AddressList.ProtoReflect.Descriptor instead.

func (*AddressList) Ensure 

func (x *AddressList) Ensure() *AddressList

Ensure returns new or existing AddressList

func (*AddressList) Exclude 

func (x *AddressList) Exclude(domains ...*Domain) *AddressList

Exclude selects all addresses without specified domains into new AddressList May return nil in case result is empty

func (*AddressList) First 

func (x *AddressList) First(domain ...*Domain) *Address

First returns the first address in the list of specified nested domain May return nil

func (*AddressList) FirstOf 

func (x *AddressList) FirstOf(domains ...*Domain) *Address

FirstOf gets the first address of specified domains

func (*AddressList) FullString 

func (x *AddressList) FullString() string

FullString stringifies address list writing addresses with domains

func (*AddressList) GetAddresses 

func (x *AddressList) GetAddresses() []*Address

func (*AddressList) GetDomain 

func (x *AddressList) GetDomain() *Domain

func (*AddressList) Has 

func (x *AddressList) Has(domain ...*Domain) bool

Has checks whether AddressList has something (in case do domain specified) or specified nested domain exists

func (*AddressList) HasDomain 

func (x *AddressList) HasDomain(domain *Domain) bool

HasDomain checks whether specified domain exists

func (*AddressList) Last 

func (x *AddressList) Last(domain ...*Domain) *Address

Last returns the last address in the list of specified nested domain

func (*AddressList) LastOf 

func (x *AddressList) LastOf(domains ...*Domain) *Address

LastOf gets the last address of specified domains

func (*AddressList) Len 

func (x *AddressList) Len(domain ...*Domain) int

Len returns either how many addresses of specified Domain are in the list or len of the whole AddressList in case no domain specified

func (*AddressList) LenOf 

func (x *AddressList) LenOf(domain *Domain) int

LenOf returns how many addresses of specified Domain are in the list

func (*AddressList) ProtoMessage 

func (*AddressList) ProtoMessage()

func (*AddressList) ProtoReflect 

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

func (*AddressList) Replace 

func (x *AddressList) Replace(addresses ...*Address) *AddressList

Replace replaces existing list with provided list of addresses

func (*AddressList) Reset 

func (x *AddressList) Reset()

func (*AddressList) Select 

func (x *AddressList) Select(domains ...*Domain) *AddressList

Select selects all addresses with specified domains into new AddressList. May return nil in case nothing is selected.

func (*AddressList) Slice 

func (x *AddressList) Slice(a, b int) []*Address

Slice returns slice of addresses May return nil

func (*AddressList) String 

func (x *AddressList) String() string

String stringifies address list writing addresses w/o domains

type AddressMap 

type AddressMap struct {

	// Domain where addresses are specified. [Optional]
	Domain *Domain `protobuf:"bytes,100,opt,name=domain,proto3,oneof" json:"domain,omitempty"`
	// Map contains named lists of addresses
	Map map[string]*AddressList `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

AddressMap describes map of address lists

func NewAddressMap 

func NewAddressMap() *AddressMap

NewAddressMap creates new AddressMap

func (*AddressMap) All 

func (m *AddressMap) All(domains ...*Domain) []*Address

All wraps AddressList.All

func (*AddressMap) Append 

func (m *AddressMap) Append(entities ...interface{}) *AddressMap

Append wraps AddressList.Append Call example: Append([domain,] address0, [address1,...])

func (*AddressMap) Collapse 

func (x *AddressMap) Collapse() *AddressList

Collapse collapses all lists from this map into one list

func (*AddressMap) Descriptor deprecated 

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

Deprecated: Use AddressMap.ProtoReflect.Descriptor instead.

func (*AddressMap) Ensure 

func (x *AddressMap) Ensure() *AddressMap

Ensure returns new or existing AddressMap

func (*AddressMap) EnsureList 

func (x *AddressMap) EnsureList(domain *Domain) *AddressList

EnsureList makes sure AddressList of specified domain exists. It uses already existing domain AddressList or creates new if none found

func (*AddressMap) First 

func (m *AddressMap) First(domains ...*Domain) *Address

First wraps AddressList.First

func (*AddressMap) GetDomain 

func (x *AddressMap) GetDomain() *Domain

func (*AddressMap) GetList 

func (x *AddressMap) GetList(domain *Domain) *AddressList

GetList gets specified AddressList of specified domain

func (*AddressMap) GetLists 

func (x *AddressMap) GetLists() []*AddressList

GetLists gets all AddressList from the AddressMap

func (*AddressMap) GetMap 

func (x *AddressMap) GetMap() map[string]*AddressList

func (*AddressMap) Has 

func (m *AddressMap) Has(domains ...*Domain) bool

Has checks whether specified domain exists

func (*AddressMap) Len 

func (m *AddressMap) Len(domains ...*Domain) int

Len returns len of specified domain

func (*AddressMap) NewList 

func (x *AddressMap) NewList(domain *Domain) *AddressList

NewList creates new AddressList of specified domain. Existing one will be overwritten.

func (*AddressMap) ProtoMessage 

func (*AddressMap) ProtoMessage()

func (*AddressMap) ProtoReflect 

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

func (*AddressMap) Replace 

func (m *AddressMap) Replace(entities ...interface{}) *AddressMap

Replace wraps ReplaceList and ReplaceAddresses Call example: Replace([domain0, {domain1, domain2,... nested domains to be replaced with provided addresses}] address0[, address1,...])

func (*AddressMap) ReplaceAddresses 

func (m *AddressMap) ReplaceAddresses(domain *Domain, deleteDomains []*Domain, addresses ...*Address) *AddressMap

ReplaceAddresses replaces specified deleteDomains within domain with provided addresses

func (*AddressMap) ReplaceList 

func (m *AddressMap) ReplaceList(domain *Domain, addresses ...*Address) *AddressMap

ReplaceList replaces whole AddressList with specified addresses

func (*AddressMap) Reset 

func (x *AddressMap) Reset()

func (*AddressMap) Set 

func (m *AddressMap) Set(entities ...interface{}) *AddressMap

Set wraps Replace

func (*AddressMap) SetList 

func (x *AddressMap) SetList(domain *Domain, list *AddressList) *AddressMap

SetList sets AddressList of specified domain. Existing one will be overwritten.

func (*AddressMap) String 

func (x *AddressMap) String() string

String stringifies AddressMap

type Address_Custom 

type Address_Custom struct {
	// Custom string address.
	Custom string `protobuf:"bytes,1200,opt,name=custom,proto3,oneof"`
}

type Address_Digest 

type Address_Digest struct {
	// Digest - based address
	Digest *Digest `protobuf:"bytes,300,opt,name=digest,proto3,oneof"`
}

type Address_Dirname 

type Address_Dirname struct {
	// Dirname or path - based address.
	Dirname *Dirname `protobuf:"bytes,600,opt,name=dirname,proto3,oneof"`
}

type Address_Domain 

type Address_Domain struct {
	// Domain address.
	Domain *Domain `protobuf:"bytes,900,opt,name=domain,proto3,oneof"`
}

type Address_Email 

type Address_Email struct {
	// Email address.
	Email *Email `protobuf:"bytes,1100,opt,name=email,proto3,oneof"`
}

type Address_Filename 

type Address_Filename struct {
	// Filename or filepath - based address.
	Filename *Filename `protobuf:"bytes,700,opt,name=filename,proto3,oneof"`
}

type Address_Kafka 

type Address_Kafka struct {
	// Kafka address
	Kafka *KafkaAddress `protobuf:"bytes,200,opt,name=kafka,proto3,oneof"`
}

type Address_MachineId 

type Address_MachineId struct {
	// MachineID address.
	MachineId *MachineID `protobuf:"bytes,1000,opt,name=machine_id,json=machineId,proto3,oneof"`
}

type Address_S3 

type Address_S3 struct {
	// S3 address
	S3 *S3Address `protobuf:"bytes,100,opt,name=s3,proto3,oneof"`
}

type Address_Url 

type Address_Url struct {
	// Url address.
	Url *URL `protobuf:"bytes,800,opt,name=url,proto3,oneof"`
}

type Address_UserId 

type Address_UserId struct {
	// UserID - based address. Used to specify any related user (owner, sender, etc)
	UserId *UserID `protobuf:"bytes,500,opt,name=user_id,json=userId,proto3,oneof"`
}

type Address_Uuid 

type Address_Uuid struct {
	// UUID - based address
	Uuid *UUID `protobuf:"bytes,400,opt,name=uuid,proto3,oneof"`
}

type Compression 

type Compression struct {

	// Type specifies type of compression
	Type int32 `protobuf:"varint,100,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

Compression describes compression of the object 

var (
	CompressionNone *Compression = nil
	CompressionLZMA *Compression = NewCompression(CompressionTypeLZMA)
)

func NewCompression 

func NewCompression(_type int32) *Compression

NewCompression

func (*Compression) Descriptor deprecated 

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

Deprecated: Use Compression.ProtoReflect.Descriptor instead.

func (*Compression) Ensure 

func (x *Compression) Ensure(_type int32) *Compression

Ensure returns new or existing Compression

func (*Compression) GetName 

func (x *Compression) GetName() string

GetName

func (*Compression) GetType 

func (x *Compression) GetType() int32

func (*Compression) ProtoMessage 

func (*Compression) ProtoMessage()

func (*Compression) ProtoReflect 

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

func (*Compression) Reset 

func (x *Compression) Reset()

func (*Compression) String 

func (x *Compression) String() string

String

type Compressor 

type Compressor struct {
	ReadCompression  *Compression
	LZMAReader       *lzma.Reader
	WriteCompression *Compression
	LZMAWriter       *lzma.Writer
}

Compressor is a compression descriptor

func NewCompressor 

func NewCompressor(
	readCompression *Compression,
	reader io.Reader,
	writeCompression *Compression,
	writer io.Writer,
) (*Compressor, error)

NewCompressor creates new compressor(s) for provided io.Reader and io.Writer When data are read from compressor by calling Read() of the compressor, compressor reads compressed data from `reader`, inflates it and returns as the result of its (compressor's) Read() When data are written into compressor by calling Write() of the compressor, compressor deflates data and writes compressed data into `writer`

func (*Compressor) Close 

func (c *Compressor) Close() error

Close is an io.Closer interface function

func (*Compressor) Read 

func (c *Compressor) Read(p []byte) (n int, err error)

Read is an io.Reader function

func (*Compressor) ReadEnabled 

func (c *Compressor) ReadEnabled() bool

ReadEnabled checks whether read is enabled

func (*Compressor) Write 

func (c *Compressor) Write(p []byte) (n int, err error)

Write is an io.Writer function

func (*Compressor) WriteEnabled 

func (c *Compressor) WriteEnabled() bool

WriteEnabled checks whether write is enabled

type DataChunk 

type DataChunk struct {

	// Data is the purpose of the whole data chunk type.
	// May contain any arbitrary sequence of bytes no longer than 2^32.
	Data []byte `protobuf:"bytes,100,opt,name=data,proto3" json:"data,omitempty"`
	// Properties is an optional transport-level information, describing each data chunk,
	// such as: len, offset, size, etc... [Optional].
	Properties *DataChunkProperties `protobuf:"bytes,200,opt,name=properties,proto3,oneof" json:"properties,omitempty"`
	// contains filtered or unexported fields
}

DataChunk represents one chunk (call it block or single piece). It is expected to be transferred as a single piece. It is expected to be a part of bigger data, transferred by smaller chunks. DataChunk can be used as a base for more complex data transfer structures, which can relay additional information, along with binary data.

func NewDataChunk 

func NewDataChunk() *DataChunk

func (*DataChunk) Descriptor deprecated 

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

Deprecated: Use DataChunk.ProtoReflect.Descriptor instead.

func (*DataChunk) EnsureProperties 

func (x *DataChunk) EnsureProperties() *DataChunkProperties

EnsureProperties is a getter with guaranteed result

func (*DataChunk) GetData 

func (x *DataChunk) GetData() []byte

func (*DataChunk) GetDataLen 

func (x *DataChunk) GetDataLen() int

GetDataLen is an IDataChunk interface function

func (*DataChunk) GetLast 

func (x *DataChunk) GetLast() bool

GetLast is an IDataChunk interface function

func (*DataChunk) GetOffset 

func (x *DataChunk) GetOffset() int64

GetOffset is an DataChunk interface function

func (*DataChunk) GetProperties 

func (x *DataChunk) GetProperties() *DataChunkProperties

func (*DataChunk) ProtoMessage 

func (*DataChunk) ProtoMessage()

func (*DataChunk) ProtoReflect 

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

func (*DataChunk) Reset 

func (x *DataChunk) Reset()

func (*DataChunk) SetData 

func (x *DataChunk) SetData(data []byte)

SetData is an IDataChunk interface function

func (*DataChunk) SetLast 

func (x *DataChunk) SetLast(last bool)

SetLast is an DataChunk interface function

func (*DataChunk) SetOffset 

func (x *DataChunk) SetOffset(offset int64)

SetOffset is an DataChunk interface function

func (*DataChunk) SetProperties 

func (x *DataChunk) SetProperties(props *DataChunkProperties)

SetProperties is a setter

func (*DataChunk) String 

func (x *DataChunk) String() string

String is a stringifier

type DataChunkFile 

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

DataChunkFile is a generic (abstract) file (set) of IDataChunk(s) Inspired by os.File handler and is expected to be used in the same context. Implements the following interfaces:

  • io.Writer
  • io.WriterTo
  • io.Reader
  • io.ReaderFrom
  • io.Closer

and thus can be used in any functions, which operate these interfaces, such as io.Copy() It is a base for creating handlers for data files (sets, streams)

func OpenDataChunkFile 

func OpenDataChunkFile(transport IDataChunkTransport) (*DataChunkFile, error)

OpenDataChunkFile opens DataChunk(s) file Inspired by os.OpenFile()

func (*DataChunkFile) Close 

func (f *DataChunkFile) Close() error

Close implements io.Closer

io.Closer is the interface that wraps the basic Close method.

The behavior of Close after the first call is undefined. Specific implementations may document their own behavior.

func (*DataChunkFile) GetOffset 

func (f *DataChunkFile) GetOffset() int64

GetOffset current offset

func (*DataChunkFile) Read 

func (f *DataChunkFile) Read(p []byte) (n int, err error)

Read implements io.Reader

Read reads up to len(p) bytes into p. It returns the number of bytes read (0 <= n <= len(p)) and any error encountered. Even if Read returns n < len(p), it may use all of p as scratch space during the call. If some data is available but not len(p) bytes, Read conventionally returns what is available instead of waiting for more.

When Read encounters an error or end-of-file condition after successfully reading n > 0 bytes, it returns the number of bytes read. It may return the (non-nil) error from the same call or return the error (and n == 0) from a subsequent call. An instance of this general case is that a Reader returning a non-zero number of bytes at the end of the input stream may return either err == EOF or err == nil. The next Read should return 0, EOF.

Callers should always process the n > 0 bytes returned before considering the error err. Doing so correctly handles I/O errors that happen after reading some bytes and also both of the allowed EOF behaviors.

Implementations of Read are discouraged from returning a zero byte count with a nil error, except when len(p) == 0. Callers should treat a return of 0 and nil as indicating that nothing happened; in particular it does not indicate EOF.

Implementations must not retain p.

func (*DataChunkFile) ReadFrom 

func (f *DataChunkFile) ReadFrom(src io.Reader) (n int64, err error)

ReadFrom implements io.ReaderFrom

io.ReaderFrom is the interface that wraps the ReadFrom method.

ReadFrom reads data from src until EOF or error. The return value n is the number of bytes read. Any error except io.EOF encountered during the read is also returned.

The Copy function uses ReaderFrom if available.

func (*DataChunkFile) Write 

func (f *DataChunkFile) Write(p []byte) (n int, err error)

Write implements io.Writer

Write writes len(p) bytes from p to the underlying data stream. It returns the number of bytes written from p (0 <= n <= len(p)) and any error encountered that caused the write process to stop early. Write must return a non-nil error if it returns n < len(p). Write must not modify the data slice, even temporarily.

Implementations must not retain p.

func (*DataChunkFile) WriteTo 

func (f *DataChunkFile) WriteTo(dst io.Writer) (n int64, err error)

WriteTo implements io.WriterTo

io.WriterTo is the interface that wraps the WriteTo method.

WriteTo writes data to dst until there's no more data to write or when an error occurs. The return value n is the number of bytes written. Any error encountered during the write is also returned.

The Copy function uses WriterTo if available.

type DataChunkProperties 

type DataChunkProperties struct {

	// Digest represents digest of the object. [Optional]
	Digest *Digest `protobuf:"bytes,100,opt,name=digest,proto3,oneof" json:"digest,omitempty"`
	// Offset represents offset of the object within the stream. [Optional]
	Offset *int64 `protobuf:"varint,200,opt,name=offset,proto3,oneof" json:"offset,omitempty"`
	// Len represents length of the object. [Optional]
	Len *int64 `protobuf:"varint,300,opt,name=len,proto3,oneof" json:"len,omitempty"`
	// Total represents total length of the object. [Optional]
	Total *int64 `protobuf:"varint,400,opt,name=total,proto3,oneof" json:"total,omitempty"`
	// Last identifies last object within the stream. Optional
	Last *bool `protobuf:"varint,500,opt,name=last,proto3,oneof" json:"last,omitempty"`
	// contains filtered or unexported fields
}

DataChunkProperties specifies properties of a DataChunk

func NewDataChunkProperties 

func NewDataChunkProperties() *DataChunkProperties

NewDataChunkProperties

func (*DataChunkProperties) Descriptor deprecated 

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

Deprecated: Use DataChunkProperties.ProtoReflect.Descriptor instead.

func (*DataChunkProperties) GetDigest 

func (x *DataChunkProperties) GetDigest() *Digest

func (*DataChunkProperties) GetLast 

func (x *DataChunkProperties) GetLast() bool

func (*DataChunkProperties) GetLen 

func (x *DataChunkProperties) GetLen() int64

func (*DataChunkProperties) GetOffset 

func (x *DataChunkProperties) GetOffset() int64

func (*DataChunkProperties) GetTotal 

func (x *DataChunkProperties) GetTotal() int64

func (*DataChunkProperties) HasDigest 

func (x *DataChunkProperties) HasDigest() bool

HasDigest

func (*DataChunkProperties) HasLast 

func (x *DataChunkProperties) HasLast() bool

HasLast

func (*DataChunkProperties) HasLen 

func (x *DataChunkProperties) HasLen() bool

HasLen

func (*DataChunkProperties) HasOffset 

func (x *DataChunkProperties) HasOffset() bool

HasOffset

func (*DataChunkProperties) HasTotal 

func (x *DataChunkProperties) HasTotal() bool

HasTotal

func (*DataChunkProperties) ProtoMessage 

func (*DataChunkProperties) ProtoMessage()

func (*DataChunkProperties) ProtoReflect 

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

func (*DataChunkProperties) Reset 

func (x *DataChunkProperties) Reset()

func (*DataChunkProperties) SetDigest 

func (x *DataChunkProperties) SetDigest(digest *Digest) *DataChunkProperties

SetDigest

func (*DataChunkProperties) SetLast 

func (x *DataChunkProperties) SetLast(last bool) *DataChunkProperties

SetLast

func (*DataChunkProperties) SetLen 

func (x *DataChunkProperties) SetLen(len int64) *DataChunkProperties

SetLen

func (*DataChunkProperties) SetOffset 

func (x *DataChunkProperties) SetOffset(offset int64) *DataChunkProperties

SetOffset

func (*DataChunkProperties) SetTotal 

func (x *DataChunkProperties) SetTotal(total int64) *DataChunkProperties

SetTotal

func (*DataChunkProperties) String 

func (x *DataChunkProperties) String() string

String

type DataPacket 

type DataPacket struct {

	// DataChunk is the purpose of the whole packet type.
	DataChunk *DataChunk `protobuf:"bytes,100,opt,name=data_chunk,json=dataChunk,proto3" json:"data_chunk,omitempty"`
	// StreamOptions is an optional transport-level information, describing whole data chunk stream,
	// such as: encoding, compression, etc... [Optional].
	StreamOptions *PresentationOptions `protobuf:"bytes,300,opt,name=stream_options,json=streamOptions,proto3,oneof" json:"stream_options,omitempty"`
	// PayloadMetadata provides additional metadata, which describes payload. [Optional].
	PayloadMetadata *Metadata `protobuf:"bytes,400,opt,name=payload_metadata,json=payloadMetadata,proto3,oneof" json:"payload_metadata,omitempty"`
	// contains filtered or unexported fields
}

DataPacket is a chunk of data transferred with additional data. Can be part of bigger data, transferred by smaller chunks. Main difference with DataChunk is that Packet has additional data.

func NewDataPacket 

func NewDataPacket() *DataPacket

NewDataPacket creates new DataPacket.

func (*DataPacket) Descriptor deprecated 

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

Deprecated: Use DataPacket.ProtoReflect.Descriptor instead.

func (*DataPacket) EnsureDataChunk 

func (x *DataPacket) EnsureDataChunk() *DataChunk

EnsureDataChunk is a setter with guaranteed result

func (*DataPacket) EnsureIDataChunk 

func (x *DataPacket) EnsureIDataChunk() IDataChunk

EnsureIDataChunk is an IDataChunkEnvelope interface function

func (*DataPacket) EnsureStreamOptions 

func (x *DataPacket) EnsureStreamOptions() *PresentationOptions

EnsureStreamOptions is a getter with guaranteed result

func (*DataPacket) GetData 

func (x *DataPacket) GetData() []byte

GetData is an IDataChunk interface function

func (*DataPacket) GetDataChunk 

func (x *DataPacket) GetDataChunk() *DataChunk

func (*DataPacket) GetDataLen 

func (x *DataPacket) GetDataLen() int

GetDataLen is an IDataChunk interface function

func (*DataPacket) GetIDataChunk 

func (x *DataPacket) GetIDataChunk() IDataChunk

GetIDataChunk is an IDataChunkEnvelope interface function

func (*DataPacket) GetLast 

func (x *DataPacket) GetLast() bool

GetLast is an IDataChunk interface function

func (*DataPacket) GetOffset 

func (x *DataPacket) GetOffset() int64

GetOffset is an IDataChunk interface function

func (*DataPacket) GetPayloadMetadata 

func (x *DataPacket) GetPayloadMetadata() *Metadata

func (*DataPacket) GetStreamOptions 

func (x *DataPacket) GetStreamOptions() *PresentationOptions

func (*DataPacket) ProtoMessage 

func (*DataPacket) ProtoMessage()

func (*DataPacket) ProtoReflect 

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

func (*DataPacket) Reset 

func (x *DataPacket) Reset()

func (*DataPacket) SetData 

func (x *DataPacket) SetData(data []byte)

SetData is an IDataChunk interface function

func (*DataPacket) SetDataChunk 

func (x *DataPacket) SetDataChunk(chunk *DataChunk)

SetDataChunk is a setter

func (*DataPacket) SetLast 

func (x *DataPacket) SetLast(last bool)

SetLast is an IDataChunk interface function

func (*DataPacket) SetOffset 

func (x *DataPacket) SetOffset(offset int64)

SetOffset is an IDataChunk interface function

func (*DataPacket) SetPayloadMetadata 

func (x *DataPacket) SetPayloadMetadata(m *Metadata)

SetPayloadMetadata is a setter

func (*DataPacket) SetStreamOptions 

func (x *DataPacket) SetStreamOptions(o *PresentationOptions)

SetStreamOptions is a setter

func (*DataPacket) String 

func (x *DataPacket) String() string

String make string representation.

type DataPacketFile 

type DataPacketFile struct {
	*DataChunkFile
	// contains filtered or unexported fields
}

DataPacketFile is a handler to set of DataChunk(s)

func OpenDataPacketFile 

func OpenDataPacketFile(writer DataPacketWriter, reader DataPacketReader) (f *DataPacketFile, err error)

OpenDataPacketFile opens set of DataChunk(s) Inspired by os.OpenFile()

func (*DataPacketFile) EnsurePayloadMetadata 

func (f *DataPacketFile) EnsurePayloadMetadata() *Metadata

EnsurePayloadMetadata is an aux function

func (*DataPacketFile) EnsureStreamOptions 

func (f *DataPacketFile) EnsureStreamOptions() *PresentationOptions

EnsureStreamOptions is an aux function

func (*DataPacketFile) GetFilename 

func (f *DataPacketFile) GetFilename() string

GetFilename returns filename. Shortcut to get filename from metadata

func (*DataPacketFile) GetPayloadMetadata 

func (f *DataPacketFile) GetPayloadMetadata() *Metadata

GetPayloadMetadata is an aux function

func (*DataPacketFile) GetStreamOptions 

func (f *DataPacketFile) GetStreamOptions() *PresentationOptions

GetStreamOptions is an aux function

func (*DataPacketFile) Name 

func (f *DataPacketFile) Name() string

Name is a wrapper for GetFilename() Main purpose is to have the same Name() function as os.File does (to be used as interface function)

func (*DataPacketFile) NewIDataChunk 

func (f *DataPacketFile) NewIDataChunk(offsetter GetOffsetter) IDataChunk

NewIDataChunk is an IDataChunkTransport interface function and create abstracted IDataChunk

func (*DataPacketFile) Recv 

func (f *DataPacketFile) Recv() (IDataChunk, error)

Recv is an IDataChunkTransport interface function

func (*DataPacketFile) Send 

func (f *DataPacketFile) Send(iDataChunk IDataChunk) error

Send is an IDataChunkTransport interface function

func (*DataPacketFile) SetFilename 

func (f *DataPacketFile) SetFilename(filename string) *DataPacketFile

SetFilename sets filename. Shortcut to set filename from metadata

func (*DataPacketFile) SetPayloadMetadata 

func (f *DataPacketFile) SetPayloadMetadata(payload *Metadata)

SetPayloadMetadata is an aux function

func (*DataPacketFile) SetStreamOptions 

func (f *DataPacketFile) SetStreamOptions(opts *PresentationOptions)

SetStreamOptions is an aux function

type DataPacketFileOptions 

type DataPacketFileOptions struct {
	Header   *Metadata
	Metadata *Metadata

	// Compress outgoing data
	Compress bool

	// Decompress incoming data
	Decompress bool
}

DataPacketFileOptions describes metadata a.k.a options for data file

func NewDataPacketFileOptions 

func NewDataPacketFileOptions() *DataPacketFileOptions

NewDataPacketFileOptions creates new DataChunkFileOptions

func (*DataPacketFileOptions) GetCompress 

func (opts *DataPacketFileOptions) GetCompress() bool

GetCompress is a getter

func (*DataPacketFileOptions) GetDecompress 

func (opts *DataPacketFileOptions) GetDecompress() bool

GetDecompress is a getter

func (*DataPacketFileOptions) GetHeader 

func (opts *DataPacketFileOptions) GetHeader() *Metadata

GetHeader is a getter

func (*DataPacketFileOptions) GetMetadata 

func (opts *DataPacketFileOptions) GetMetadata() *Metadata

GetMetadata is a getter

func (*DataPacketFileOptions) SetCompress 

func (opts *DataPacketFileOptions) SetCompress(compress bool) *DataPacketFileOptions

SetCompress is a setter

func (*DataPacketFileOptions) SetDecompress 

func (opts *DataPacketFileOptions) SetDecompress(decompress bool) *DataPacketFileOptions

SetDecompress is a setter

func (*DataPacketFileOptions) SetHeader 

func (opts *DataPacketFileOptions) SetHeader(header *Metadata) *DataPacketFileOptions

SetHeader is a setter

func (*DataPacketFileOptions) SetMetadata 

func (opts *DataPacketFileOptions) SetMetadata(meta *Metadata) *DataPacketFileOptions

SetMetadata is a setter

type DataPacketFileWithOptions 

type DataPacketFileWithOptions struct {
	*DataPacketFile
	Compressor *Compressor
}

DataPacketFileWithOptions Inspired by os.File handler and is expected to be used in the same context.

func OpenDataPacketFileWOptions 

func OpenDataPacketFileWOptions(
	writer DataPacketWriter,
	reader DataPacketReader,
	options *DataPacketFileOptions,
) (*DataPacketFileWithOptions, error)

OpenDataPacketFileWOptions opens file with options `writer` specifies entity where this file will write data into. Optional, in case the file is read-only `reader` specifies entity where this file will read data from. Optional, in case the file is write-only

func OpenDataPacketFileWOptionsForRead 

func OpenDataPacketFileWOptionsForRead(
	reader DataPacketReader,
	decompress bool,
) (*DataPacketFileWithOptions, error)

func OpenDataPacketFileWOptionsForWrite 

func OpenDataPacketFileWOptionsForWrite(
	writer DataPacketWriter,
	compress bool,
	filename ...string,
) (*DataPacketFileWithOptions, error)

func (*DataPacketFileWithOptions) Close 

func (f *DataPacketFileWithOptions) Close() error

Close is an io.Closer interface function

func (*DataPacketFileWithOptions) GetDataPacketFile 

func (f *DataPacketFileWithOptions) GetDataPacketFile() *DataPacketFile

GetDataPacketFile is a getter

func (*DataPacketFileWithOptions) Read 

func (f *DataPacketFileWithOptions) Read(p []byte) (n int, err error)

Read is an io.Reader interface function

func (*DataPacketFileWithOptions) ReadFrom 

func (f *DataPacketFileWithOptions) ReadFrom(src io.Reader) (int64, error)

ReadFrom is an io.ReaderFrom interface function

func (*DataPacketFileWithOptions) Write 

func (f *DataPacketFileWithOptions) Write(p []byte) (n int, err error)

Write is an io.Writer interface function

func (*DataPacketFileWithOptions) WriteTo 

func (f *DataPacketFileWithOptions) WriteTo(dst io.Writer) (int64, error)

WriteTo is an io.WriterTo interface function

func (*DataPacketFileWithOptions) WriteToBuf 

func (f *DataPacketFileWithOptions) WriteToBuf() (int64, *bytes.Buffer, error)

WriteToBuf writes data to newly created buffer

type DataPacketReader 

type DataPacketReader interface {
	Recv() (*DataPacket, error)
}

DataPacketReader represents receiver of the data chunk stream

type DataPacketWriter 

type DataPacketWriter interface {
	Send(*DataPacket) error
}

DataPacketWriter represents sender of the data chunk stream

type DiffTask 

type DiffTask struct {

	// "A" party for diff
	A *Address `protobuf:"bytes,100,opt,name=a,proto3" json:"a,omitempty"`
	// "B" party for diff
	B *Address `protobuf:"bytes,200,opt,name=b,proto3" json:"b,omitempty"`
	// TODO
	Meta *Address `protobuf:"bytes,300,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

DiffTask represents request for diff between two objects.

func NewDiffTask 

func NewDiffTask() *DiffTask

NewDiffTask

func (*DiffTask) Descriptor deprecated 

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

Deprecated: Use DiffTask.ProtoReflect.Descriptor instead.

func (*DiffTask) GetA 

func (x *DiffTask) GetA() *Address

func (*DiffTask) GetB 

func (x *DiffTask) GetB() *Address

func (*DiffTask) GetMeta 

func (x *DiffTask) GetMeta() *Address

func (*DiffTask) ProtoMessage 

func (*DiffTask) ProtoMessage()

func (*DiffTask) ProtoReflect 

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

func (*DiffTask) Reset 

func (x *DiffTask) Reset()

func (*DiffTask) String 

func (x *DiffTask) String() string

String

type Digest 

type Digest struct {

	// Type of the digest. MD5 or SHA256 or something else
	Type DigestType `protobuf:"varint,100,opt,name=type,proto3,enum=api.common.DigestType" json:"type,omitempty"`
	// Data. Any arbitrary sequence of bytes no longer than 2^32
	Data []byte `protobuf:"bytes,200,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

Digest represents abstract digest.

func NewDigest 

func NewDigest() *Digest

NewDigest creates bew digest

func (*Digest) Descriptor deprecated 

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

Deprecated: Use Digest.ProtoReflect.Descriptor instead.

func (*Digest) GetData 

func (x *Digest) GetData() []byte

func (*Digest) GetType 

func (x *Digest) GetType() DigestType

func (*Digest) ProtoMessage 

func (*Digest) ProtoMessage()

func (*Digest) ProtoReflect 

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

func (*Digest) Reset 

func (x *Digest) Reset()

func (*Digest) SetData 

func (x *Digest) SetData(data []byte) *Digest

SetData sets data directly

func (*Digest) SetDataFromString 

func (x *Digest) SetDataFromString(data string) *Digest

SetDataFromString sets data from string value

func (*Digest) SetType 

func (x *Digest) SetType(_type DigestType) *Digest

SetType sets digest type

func (*Digest) String 

func (x *Digest) String() string

String

type DigestType 

type DigestType int32

DigestType represents all types of digests in the system. 

const (
	// Due to first enum value has to be zero in proto3
	DigestType_DIGEST_RESERVED DigestType = 0
	// Unspecified means we do not know its type
	DigestType_DIGEST_UNSPECIFIED DigestType = 100
	// MD5 digest
	DigestType_DIGEST_MD5 DigestType = 200
	// SHA256 digest
	DigestType_DIGEST_SHA256 DigestType = 300
)

func (DigestType) Descriptor 

func (DigestType) Descriptor() protoreflect.EnumDescriptor

func (DigestType) Enum 

func (x DigestType) Enum() *DigestType

func (DigestType) EnumDescriptor deprecated 

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

Deprecated: Use DigestType.Descriptor instead.

func (DigestType) Number 

func (x DigestType) Number() protoreflect.EnumNumber

func (DigestType) Type 

func (DigestType) Type() protoreflect.EnumType

type Dirname 

type Dirname struct {

	// Dirname specifies directory name
	Dirname string `protobuf:"bytes,100,opt,name=dirname,proto3" json:"dirname,omitempty"`
	// contains filtered or unexported fields
}

Dirname represents abstract directory name.

func NewDirname 

func NewDirname(dirname ...string) *Dirname

NewDirname

func (*Dirname) Descriptor deprecated 

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

Deprecated: Use Dirname.ProtoReflect.Descriptor instead.

func (*Dirname) Equals 

func (x *Dirname) Equals(dirname *Dirname) bool

Equals

func (*Dirname) GetDirname 

func (x *Dirname) GetDirname() string

func (*Dirname) ProtoMessage 

func (*Dirname) ProtoMessage()

func (*Dirname) ProtoReflect 

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

func (*Dirname) Reset 

func (x *Dirname) Reset()

func (*Dirname) Set 

func (x *Dirname) Set(dirname string) *Dirname

Set

func (*Dirname) String 

func (x *Dirname) String() string

String

type Domain 

type Domain struct {

	// Domain name
	Name string `protobuf:"bytes,100,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Domain represents abstract domain.

func DomainFromString 

func DomainFromString(str string) *Domain

DomainFromString tries to find registered domain with specified string value

func FindDomain 

func FindDomain(domain *Domain) *Domain

FindDomain returns registered domain with the same string value as provided

func NewDomain 

func NewDomain(name ...string) *Domain

NewDomain creates new Domain

func NormalizeDomain 

func NormalizeDomain(domain *Domain) *Domain

NormalizeDomain returns either registered domain with the same string value as provided domain or provided domain.

func RegisterDomain 

func RegisterDomain(domain *Domain) *Domain

RegisterDomain tries to register specified Domain. Domain must be non-equal to all registered domains. Returns nil in case Domain can not be registered, say it is equal to previously registered domain

func (*Domain) Descriptor deprecated 

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

Deprecated: Use Domain.ProtoReflect.Descriptor instead.

func (*Domain) Ensure 

func (x *Domain) Ensure() *Domain

Ensure returns new or existing Domain

func (*Domain) Equals 

func (x *Domain) Equals(domain *Domain) bool

Equals checks whether Domains are equal internally

func (*Domain) GetName 

func (x *Domain) GetName() string

func (*Domain) ProtoMessage 

func (*Domain) ProtoMessage()

func (*Domain) ProtoReflect 

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

func (*Domain) Reset 

func (x *Domain) Reset()

func (*Domain) SetName 

func (x *Domain) SetName(name string) *Domain

SetName sets Domain name

func (*Domain) String 

func (x *Domain) String() string

String returns string representation of a Domain

type Email 

type Email struct {

	// Data specifies email
	Data string `protobuf:"bytes,100,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

Email specifies email.

func NewEmail 

func NewEmail() *Email

NewEmail

func NewEmailFromString 

func NewEmailFromString(str string) *Email

NewEmailFromString

func (*Email) Descriptor deprecated 

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

Deprecated: Use Email.ProtoReflect.Descriptor instead.

func (*Email) GetData 

func (x *Email) GetData() string

func (*Email) ProtoMessage 

func (*Email) ProtoMessage()

func (*Email) ProtoReflect 

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

func (*Email) Reset 

func (x *Email) Reset()

func (*Email) SetString 

func (x *Email) SetString(str string) *Email

SetString

func (*Email) String 

func (x *Email) String() string

String

type Encoding 

type Encoding struct {

	// Method specifies encoding method
	Method string `protobuf:"bytes,100,opt,name=method,proto3" json:"method,omitempty"`
	// contains filtered or unexported fields
}

Encoding describes encoding of the object

func NewEncoding 

func NewEncoding(method ...string) *Encoding

NewEncoding

func (*Encoding) Descriptor deprecated 

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

Deprecated: Use Encoding.ProtoReflect.Descriptor instead.

func (*Encoding) Equals 

func (x *Encoding) Equals(encoding *Encoding) bool

Equals

func (*Encoding) GetMethod 

func (x *Encoding) GetMethod() string

func (*Encoding) ProtoMessage 

func (*Encoding) ProtoMessage()

func (*Encoding) ProtoReflect 

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

func (*Encoding) Reset 

func (x *Encoding) Reset()

func (*Encoding) Set 

func (x *Encoding) Set(method string) *Encoding

Set

func (*Encoding) String 

func (x *Encoding) String() string

String

type Enum 

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

Enum

func NewEnum 

func NewEnum() *Enum

NewEnum

func (*Enum) CastRegister 

func (e *Enum) CastRegister(name string, value interface{}) bool

CastRegister

func (*Enum) GetName 

func (e *Enum) GetName(what interface{}) string

GetName

func (*Enum) GetValue 

func (e *Enum) GetValue(what interface{}) int32

GetValue

func (*Enum) GetValues 

func (e *Enum) GetValues(whats ...interface{}) (res []int32)

GetValues

func (*Enum) Has 

func (e *Enum) Has(what interface{}) bool

Has

func (*Enum) HasLower 

func (e *Enum) HasLower(name string) bool

HasLower

func (*Enum) HasUpper 

func (e *Enum) HasUpper(name string) bool

HasUpper

func (*Enum) Lower 

func (e *Enum) Lower(name string) (int32, bool)

Lower

func (*Enum) MustCastRegister 

func (e *Enum) MustCastRegister(name string, value interface{}) bool

MustCastRegister

func (*Enum) MustGetLower 

func (e *Enum) MustGetLower(name string) int32

MustGetLower

func (*Enum) MustGetLowers 

func (e *Enum) MustGetLowers(names ...string) []int32

MustGetLowers

func (*Enum) MustGetName 

func (e *Enum) MustGetName(what interface{}) string

MustGetName

func (*Enum) MustGetUpper 

func (e *Enum) MustGetUpper(name string) int32

MustGetUpper

func (*Enum) MustGetUppers 

func (e *Enum) MustGetUppers(names ...string) []int32

MustGetUppers

func (*Enum) MustGetValue 

func (e *Enum) MustGetValue(what interface{}) int32

MustGetValue

func (*Enum) MustGetValues 

func (e *Enum) MustGetValues(whats ...interface{}) (res []int32)

MustGetValues

func (*Enum) MustRegister 

func (e *Enum) MustRegister(name string, value int32) bool

MustRegister

func (*Enum) Name 

func (e *Enum) Name(what interface{}) (string, bool)

Name

func (*Enum) Names 

func (e *Enum) Names() []string

Names

func (*Enum) Register 

func (e *Enum) Register(name string, value int32) bool

Register

func (*Enum) RegisterLower 

func (e *Enum) RegisterLower(name string, value int32) bool

RegisterLower

func (*Enum) RegisterUpper 

func (e *Enum) RegisterUpper(name string, value int32) bool

RegisterUpper

func (*Enum) Upper 

func (e *Enum) Upper(name string) (int32, bool)

Upper

func (*Enum) Value 

func (e *Enum) Value(what interface{}) (int32, bool)

Value

func (*Enum) Values 

func (e *Enum) Values() []int32

Values

type Error 

type Error struct {

	// Code specifies error code
	Code int64 `protobuf:"varint,100,opt,name=code,proto3" json:"code,omitempty"`
	// Msg specifies error message
	Msg string `protobuf:"bytes,200,opt,name=msg,proto3" json:"msg,omitempty"`
	// Details specifies multiple error details of the error
	Details []*ErrorDetail `protobuf:"bytes,300,rep,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

Error specifies general error

func (*Error) Descriptor deprecated 

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetCode 

func (x *Error) GetCode() int64

func (*Error) GetDetails 

func (x *Error) GetDetails() []*ErrorDetail

func (*Error) GetMsg 

func (x *Error) GetMsg() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect 

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

func (*Error) Reset 

func (x *Error) Reset()

type ErrorDetail 

type ErrorDetail struct {

	// Name specifies error details name
	Name *string `protobuf:"bytes,100,opt,name=name,proto3,oneof" json:"name,omitempty"`
	// Text specifies error details text
	Text *string `protobuf:"bytes,200,opt,name=text,proto3,oneof" json:"text,omitempty"`
	// contains filtered or unexported fields
}

ErrorDetail specifies optional error details

func (*ErrorDetail) Descriptor deprecated 

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

Deprecated: Use ErrorDetail.ProtoReflect.Descriptor instead.

func (*ErrorDetail) GetName 

func (x *ErrorDetail) GetName() string

func (*ErrorDetail) GetText 

func (x *ErrorDetail) GetText() string

func (*ErrorDetail) ProtoMessage 

func (*ErrorDetail) ProtoMessage()

func (*ErrorDetail) ProtoReflect 

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

func (*ErrorDetail) Reset 

func (x *ErrorDetail) Reset()

type File 

type File struct {

	// Filename specifies name of a file
	Filename *Filename `protobuf:"bytes,100,opt,name=filename,proto3" json:"filename,omitempty"`
	// Data specifies data of a file
	Data []byte `protobuf:"bytes,200,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

File represents abstract file.

func NewFile 

func NewFile() *File

NewFile

func (*File) Descriptor deprecated 

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

Deprecated: Use File.ProtoReflect.Descriptor instead.

func (*File) GetData 

func (x *File) GetData() []byte

func (*File) GetFilename 

func (x *File) GetFilename() *Filename

func (*File) Len 

func (x *File) Len() int

Len

func (*File) ProtoMessage 

func (*File) ProtoMessage()

func (*File) ProtoReflect 

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

func (*File) Reset 

func (x *File) Reset()

func (*File) SetData 

func (x *File) SetData(data []byte) *File

SetData

func (*File) SetFilename 

func (x *File) SetFilename(filename string) *File

SetFilename

func (*File) String 

func (x *File) String() string

String

type Filename 

type Filename struct {

	// Filename specifies name of a file
	Filename string `protobuf:"bytes,100,opt,name=filename,proto3" json:"filename,omitempty"`
	// contains filtered or unexported fields
}

Filename represents abstract filename.

func NewFilename 

func NewFilename(filename ...string) *Filename

NewFilename

func (*Filename) Descriptor deprecated 

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

Deprecated: Use Filename.ProtoReflect.Descriptor instead.

func (*Filename) Ensure 

func (x *Filename) Ensure() *Filename

Ensure

func (*Filename) Equals 

func (x *Filename) Equals(filename *Filename) bool

Equals

func (*Filename) GetFilename 

func (x *Filename) GetFilename() string

func (*Filename) ProtoMessage 

func (*Filename) ProtoMessage()

func (*Filename) ProtoReflect 

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

func (*Filename) Reset 

func (x *Filename) Reset()

func (*Filename) Set 

func (x *Filename) Set(filename string) *Filename

Set

func (*Filename) String 

func (x *Filename) String() string

String

type GetOffsetter 

type GetOffsetter interface {
	// GetOffset gets current offset within the file (set)
	GetOffset() int64
}

type HealthCheckRequest 

type HealthCheckRequest struct {

	// Which service to check
	Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

HealthCheckRequest represents health check request

func (*HealthCheckRequest) Descriptor deprecated 

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

Deprecated: Use HealthCheckRequest.ProtoReflect.Descriptor instead.

func (*HealthCheckRequest) GetService 

func (x *HealthCheckRequest) GetService() string

func (*HealthCheckRequest) ProtoMessage 

func (*HealthCheckRequest) ProtoMessage()

func (*HealthCheckRequest) ProtoReflect 

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

func (*HealthCheckRequest) Reset 

func (x *HealthCheckRequest) Reset()

type HealthCheckResponse 

type HealthCheckResponse struct {

	// Whether service is serving requests
	Status ServingStatus `protobuf:"varint,1,opt,name=status,proto3,enum=api.common.ServingStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

HealthCheckResponse represents response for health check request

func (*HealthCheckResponse) Descriptor deprecated 

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

Deprecated: Use HealthCheckResponse.ProtoReflect.Descriptor instead.

func (*HealthCheckResponse) GetStatus 

func (x *HealthCheckResponse) GetStatus() ServingStatus

func (*HealthCheckResponse) ProtoMessage 

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) ProtoReflect 

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

func (*HealthCheckResponse) Reset 

func (x *HealthCheckResponse) Reset()

type IDataChunk 

type IDataChunk interface {
	// GetDataLen gets length of the data of the DataChunk
	GetDataLen() int
	// GetData gets data of the DataChunk
	GetData() []byte
	// SetData sets data of the DataChunk
	SetData([]byte)
	// GetLast returns whether this DataChunk is the last in the file (set)
	GetLast() bool
	// SetLast sets flag whether this DataChunk is the last in the file (set)
	SetLast(bool)
	// GetOffset gets offset of the DataChunk within the file (set)
	GetOffset() int64
	// SetOffset sets offset of the DataChunk within the file (set)
	SetOffset(int64)
	// Stringer is a nice touch to log DataChunk(s)
	fmt.Stringer
}

IDataChunk represents DataChunk interface

type IDataChunkFile 

type IDataChunkFile interface {
	GetOffsetter

	io.Writer
	io.WriterTo
	io.Reader
	io.ReaderFrom
	io.Closer
}

IDataChunkFile represents generic DataChunkFile which can transport IDataChunk(s)

type IDataChunkTransport 

type IDataChunkTransport interface {
	// NewIDataChunk creates new adbstracted data chunk. Typically, to be sent at the transport level by Send()
	NewIDataChunk(GetOffsetter) IDataChunk
	// Recv receives incoming abstracted IDataChunk at the transport layer.
	Recv() (IDataChunk, error)
	// Send sends IDataChunk at the transport layer.
	Send(IDataChunk) error
}

IDataChunkTransport represents interface to transport abstracted data via IDataChunk. Interfaces transport functions to Receive, Send and create abstracted IDataChunk.

type KafkaAddress 

type KafkaAddress struct {

	// Topic within Kafka
	Topic string `protobuf:"bytes,100,opt,name=topic,proto3" json:"topic,omitempty"`
	// Partition within Kafka topic
	Partition int32 `protobuf:"varint,200,opt,name=partition,proto3" json:"partition,omitempty"`
	// contains filtered or unexported fields
}

KafkaAddress represents Kafka address within Kafka endpoint (cluster).

func NewKafkaAddress 

func NewKafkaAddress(topic string, partition int32) *KafkaAddress

NewKafkaAddress

func (*KafkaAddress) Descriptor deprecated 

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

Deprecated: Use KafkaAddress.ProtoReflect.Descriptor instead.

func (*KafkaAddress) GetPartition 

func (x *KafkaAddress) GetPartition() int32

func (*KafkaAddress) GetTopic 

func (x *KafkaAddress) GetTopic() string

func (*KafkaAddress) GetTopics 

func (x *KafkaAddress) GetTopics() []string

GetTopics

func (*KafkaAddress) ProtoMessage 

func (*KafkaAddress) ProtoMessage()

func (*KafkaAddress) ProtoReflect 

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

func (*KafkaAddress) Reset 

func (x *KafkaAddress) Reset()

func (*KafkaAddress) String 

func (x *KafkaAddress) String() string

String

type KafkaEndpoint 

type KafkaEndpoint struct {

	// Brokers specifies list of Kafka's cluster
	Brokers []string `protobuf:"bytes,100,rep,name=brokers,proto3" json:"brokers,omitempty"`
	// contains filtered or unexported fields
}

KafkaEndpoint represents Kafka cluster access endpoint

func NewKafkaEndpoint 

func NewKafkaEndpoint(brokers []string) *KafkaEndpoint

NewKafkaEndpoint

func (*KafkaEndpoint) Descriptor deprecated 

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

Deprecated: Use KafkaEndpoint.ProtoReflect.Descriptor instead.

func (*KafkaEndpoint) GetBrokers 

func (x *KafkaEndpoint) GetBrokers() []string

func (*KafkaEndpoint) ProtoMessage 

func (*KafkaEndpoint) ProtoMessage()

func (*KafkaEndpoint) ProtoReflect 

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

func (*KafkaEndpoint) Reset 

func (x *KafkaEndpoint) Reset()

func (*KafkaEndpoint) String 

func (x *KafkaEndpoint) String() string

String

type MachineID 

type MachineID struct {

	// Data is an machine identifier data
	Data string `protobuf:"bytes,100,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

MachineID specifies identifier of a machine.

func NewMachineID 

func NewMachineID() *MachineID

NewMachineID

func NewRandomMachineID 

func NewRandomMachineID() *MachineID

NewRandomMachineID

func (*MachineID) Descriptor deprecated 

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

Deprecated: Use MachineID.ProtoReflect.Descriptor instead.

func (*MachineID) GetData 

func (x *MachineID) GetData() string

func (*MachineID) ProtoMessage 

func (*MachineID) ProtoMessage()

func (*MachineID) ProtoReflect 

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

func (*MachineID) Reset 

func (x *MachineID) Reset()

func (*MachineID) SetString 

func (x *MachineID) SetString(str string) *MachineID

SetString

func (*MachineID) String 

func (x *MachineID) String() string

String

type Metadata 

type Metadata struct {

	// Type of the object. [Optional]
	// Object has to have either type or name, one of them is expected to be in place.
	// Object can be typed/identified either by type or by name.
	Type *int32 `protobuf:"varint,100,opt,name=type,proto3,oneof" json:"type,omitempty"`
	// Name of the object. [Optional]
	// Object has to have either type or name, one of the is expected to be presented.
	// Object can be typed/identified either by type or by name.
	Name *string `protobuf:"bytes,200,opt,name=name,proto3,oneof" json:"name,omitempty"`
	// Version of the object. [Optional]
	Version *int32 `protobuf:"varint,300,opt,name=version,proto3,oneof" json:"version,omitempty"`
	// Description represents string with human-readable description of the object. [Optional]
	Description *string `protobuf:"bytes,400,opt,name=description,proto3,oneof" json:"description,omitempty"`
	// Status represents status code of the object. [Optional]
	Status *int32 `protobuf:"varint,500,opt,name=status,proto3,oneof" json:"status,omitempty"`
	// Mode represents mode code of the object. [Optional]
	Mode *int32 `protobuf:"varint,600,opt,name=mode,proto3,oneof" json:"mode,omitempty"`
	// Ts is the timestamp of the object. [Optional]
	Ts *timestamppb.Timestamp `protobuf:"bytes,700,opt,name=ts,proto3,oneof" json:"ts,omitempty"`
	// Addresses represents map of addresses of the object. [Optional]
	// Internal and external or whatever may be needed.
	Addresses *AddressMap `protobuf:"bytes,800,opt,name=addresses,proto3,oneof" json:"addresses,omitempty"`
	// Properties represents properties of the data chunk, such as len, offset, etc... . [Optional]
	Properties *DataChunkProperties `protobuf:"bytes,900,opt,name=properties,proto3,oneof" json:"properties,omitempty"`
	// Multiple associated components
	Types    *SliceInt32 `protobuf:"bytes,1000,opt,name=types,proto3,oneof" json:"types,omitempty"`
	Versions *SliceInt32 `protobuf:"bytes,1100,opt,name=versions,proto3,oneof" json:"versions,omitempty"`
	Statuses *SliceInt32 `protobuf:"bytes,1200,opt,name=statuses,proto3,oneof" json:"statuses,omitempty"`
	Modes    *SliceInt32 `protobuf:"bytes,1300,opt,name=modes,proto3,oneof" json:"modes,omitempty"`
	// contains filtered or unexported fields
}

Metadata describes metadata of the object

func NewMetadata 

func NewMetadata() *Metadata

NewMetadata

func (*Metadata) Append 

func (x *Metadata) Append(entities ...interface{}) *Metadata

Append wraps AddressMap.Append

func (*Metadata) CreateTimestamp 

func (x *Metadata) CreateTimestamp() *Metadata

CreateTimestamp creates current timestamp

func (*Metadata) Descriptor deprecated 

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) EnsureAddresses 

func (x *Metadata) EnsureAddresses() *AddressMap

EnsureAddresses

func (*Metadata) EnsureModes 

func (x *Metadata) EnsureModes() *SliceInt32

EnsureModes

func (*Metadata) EnsureProperties 

func (x *Metadata) EnsureProperties() *DataChunkProperties

EnsureProperties

func (*Metadata) EnsureStatuses 

func (x *Metadata) EnsureStatuses() *SliceInt32

EnsureStatuses

func (*Metadata) EnsureTypes 

func (x *Metadata) EnsureTypes() *SliceInt32

EnsureTypes

func (*Metadata) EnsureVersions 

func (x *Metadata) EnsureVersions() *SliceInt32

EnsureVersions

func (*Metadata) GetAddress 

func (x *Metadata) GetAddress() *UUID

GetAddress

func (*Metadata) GetAddresses 

func (x *Metadata) GetAddresses() *AddressMap

func (*Metadata) GetAssetID 

func (x *Metadata) GetAssetID() *MachineID

GetAssetID

func (*Metadata) GetContextUuid 

func (x *Metadata) GetContextUuid() *UUID

GetContextUUID

func (*Metadata) GetCustom 

func (x *Metadata) GetCustom() string

GetCustom

func (*Metadata) GetDescription 

func (x *Metadata) GetDescription() string

func (*Metadata) GetDirname 

func (x *Metadata) GetDirname() string

GetDirname

func (*Metadata) GetDomain 

func (x *Metadata) GetDomain() *Domain

GetDomain

func (*Metadata) GetFilename 

func (x *Metadata) GetFilename() string

GetFilename

func (*Metadata) GetMachineID 

func (x *Metadata) GetMachineID() *MachineID

GetMachineID

func (*Metadata) GetMode 

func (x *Metadata) GetMode() int32

func (*Metadata) GetModes 

func (x *Metadata) GetModes() *SliceInt32

func (*Metadata) GetName 

func (x *Metadata) GetName() string

func (*Metadata) GetProperties 

func (x *Metadata) GetProperties() *DataChunkProperties

func (*Metadata) GetResultDomain 

func (x *Metadata) GetResultDomain() *Domain

GetResultDomain

func (*Metadata) GetStatus 

func (x *Metadata) GetStatus() int32

func (*Metadata) GetStatuses 

func (x *Metadata) GetStatuses() *SliceInt32

func (*Metadata) GetTaskUuid 

func (x *Metadata) GetTaskUuid() *UUID

GetTaskUUID

func (*Metadata) GetTs 

func (x *Metadata) GetTs() *timestamppb.Timestamp

func (*Metadata) GetType 

func (x *Metadata) GetType() int32

func (*Metadata) GetTypes 

func (x *Metadata) GetTypes() *SliceInt32

func (*Metadata) GetUserID 

func (x *Metadata) GetUserID() *UserID

GetUserID

func (*Metadata) GetUuid 

func (x *Metadata) GetUuid() *UUID

GetUUID

func (*Metadata) GetVersion 

func (x *Metadata) GetVersion() int32

func (*Metadata) GetVersions 

func (x *Metadata) GetVersions() *SliceInt32

func (*Metadata) Has 

func (x *Metadata) Has(domain ...*Domain) bool

Has wraps AddressMap.Has

func (*Metadata) HasAddresses 

func (x *Metadata) HasAddresses() bool

HasAddresses

func (*Metadata) HasDescription 

func (x *Metadata) HasDescription() bool

HasDescription

func (*Metadata) HasMode 

func (x *Metadata) HasMode() bool

HasMode

func (*Metadata) HasModes 

func (x *Metadata) HasModes() bool

HasModes

func (*Metadata) HasName 

func (x *Metadata) HasName() bool

HasName

func (*Metadata) HasProperties 

func (x *Metadata) HasProperties() bool

HasProperties

func (*Metadata) HasStatus 

func (x *Metadata) HasStatus() bool

HasStatus

func (*Metadata) HasStatuses 

func (x *Metadata) HasStatuses() bool

HasStatuses

func (*Metadata) HasTimestamp 

func (x *Metadata) HasTimestamp() bool

HasTimestamp

func (*Metadata) HasType 

func (x *Metadata) HasType() bool

HasType

func (*Metadata) HasTypes 

func (x *Metadata) HasTypes() bool

HasTypes

func (*Metadata) HasVersion 

func (x *Metadata) HasVersion() bool

HasVersion

func (*Metadata) HasVersions 

func (x *Metadata) HasVersions() bool

HasVersions

func (*Metadata) Log 

func (x *Metadata) Log()

Log

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect 

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

func (*Metadata) Reset 

func (x *Metadata) Reset()

func (*Metadata) Set 

func (x *Metadata) Set(entities ...interface{}) *Metadata

Set wraps AddressMap.Set

func (*Metadata) SetAddress 

func (x *Metadata) SetAddress(address *Address) *Metadata

SetAddress

func (*Metadata) SetAddresses 

func (x *Metadata) SetAddresses(addresses *AddressMap) *Metadata

SetAddresses

func (*Metadata) SetAssetID 

func (x *Metadata) SetAssetID(assetID *MachineID) *Metadata

SetAssetID

func (*Metadata) SetContextUUID 

func (x *Metadata) SetContextUUID(uuid *UUID) *Metadata

SetContextUUID

func (*Metadata) SetCustom 

func (x *Metadata) SetCustom(s string) *Metadata

SetCustom

func (*Metadata) SetDescription 

func (x *Metadata) SetDescription(description string) *Metadata

SetDescription

func (*Metadata) SetDirname 

func (x *Metadata) SetDirname(dirname string) *Metadata

SetDirname

func (*Metadata) SetDomain 

func (x *Metadata) SetDomain(domain *Domain) *Metadata

SetDomain

func (*Metadata) SetFilename 

func (x *Metadata) SetFilename(filename string) *Metadata

SetFilename

func (*Metadata) SetKafka 

func (x *Metadata) SetKafka(topic string, partition int32) *Metadata

SetKafka

func (*Metadata) SetMachineID 

func (x *Metadata) SetMachineID(machineID *MachineID) *Metadata

SetMachineID

func (*Metadata) SetMode 

func (x *Metadata) SetMode(mode int32) *Metadata

SetMode

func (*Metadata) SetModes 

func (x *Metadata) SetModes(modes *SliceInt32) *Metadata

SetModes

func (*Metadata) SetName 

func (x *Metadata) SetName(name string) *Metadata

SetName

func (*Metadata) SetProperties 

func (x *Metadata) SetProperties(properties *DataChunkProperties) *Metadata

SetProperties

func (*Metadata) SetRandomUuid 

func (x *Metadata) SetRandomUuid(domains ...*Domain) *Metadata

SetRandomUuid domains are optional

func (*Metadata) SetResultDomain 

func (x *Metadata) SetResultDomain(domain *Domain) *Metadata

SetResultDomain

func (*Metadata) SetS3 

func (x *Metadata) SetS3(bucket, object string) *Metadata

SetS3

func (*Metadata) SetStatus 

func (x *Metadata) SetStatus(status int32) *Metadata

SetStatus

func (*Metadata) SetStatuses 

func (x *Metadata) SetStatuses(statuses *SliceInt32) *Metadata

SetStatuses

func (*Metadata) SetTaskUUID 

func (x *Metadata) SetTaskUUID(uuid *UUID) *Metadata

SetTaskUUID

func (*Metadata) SetTimestamp 

func (x *Metadata) SetTimestamp(seconds int64, nanos int32) *Metadata

SetTimestamp

func (*Metadata) SetType 

func (x *Metadata) SetType(_type int32) *Metadata

SetType

func (*Metadata) SetTypes 

func (x *Metadata) SetTypes(types *SliceInt32) *Metadata

SetTypes

func (*Metadata) SetURL 

func (x *Metadata) SetURL(url string) *Metadata

SetURL

func (*Metadata) SetUUID 

func (x *Metadata) SetUUID(uuid *UUID) *Metadata

SetUUID

func (*Metadata) SetUserID 

func (x *Metadata) SetUserID(userID *UserID) *Metadata

SetUserID

func (*Metadata) SetUuidFromString 

func (x *Metadata) SetUuidFromString(id string, domain ...*Domain) *Metadata

Address customization

SetUuidFromString

func (*Metadata) SetVersion 

func (x *Metadata) SetVersion(version int32) *Metadata

SetVersion

func (*Metadata) SetVersions 

func (x *Metadata) SetVersions(versions *SliceInt32) *Metadata

SetVersions

func (*Metadata) String 

func (x *Metadata) String() string

String

type Metric 

type Metric struct {

	// Optional. Type of the metric
	Type *MetricType `protobuf:"varint,100,opt,name=type,proto3,enum=api.common.MetricType,oneof" json:"type,omitempty"`
	// Optional. Name of the metric
	Name *string `protobuf:"bytes,200,opt,name=name,proto3,oneof" json:"name,omitempty"`
	// Optional. Timestamp.
	Ts *timestamppb.Timestamp `protobuf:"bytes,300,opt,name=ts,proto3,oneof" json:"ts,omitempty"`
	// Optional. Description represents human-readable description on what it is.
	Description *string `protobuf:"bytes,400,opt,name=description,proto3,oneof" json:"description,omitempty"`
	// Value is the purpose of the whole Metric data type,
	// is expected to be present all the time, and can be of any type
	//
	// Types that are assignable to Value:
	//	*Metric_StringValue
	//	*Metric_DoubleValue
	//	*Metric_Int32Value
	//	*Metric_Uint32Value
	//	*Metric_Int64Value
	//	*Metric_Uint64Value
	//	*Metric_BytesValue
	Value isMetric_Value `protobuf_oneof:"Value"`
	// contains filtered or unexported fields
}

Metric is one metric tuple (metric identifier [optional], timestamp [optional], description [optional], metric value) Metric can be classified either by type or by name. Identifier can be omitted, in case either both sides understand what they are talking about or identifier is provided in parent's (outer) data type, such as Metric

func NewMetric 

func NewMetric() *Metric

NewMetric

func (*Metric) Descriptor deprecated 

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

Deprecated: Use Metric.ProtoReflect.Descriptor instead.

func (*Metric) GetBytesValue 

func (x *Metric) GetBytesValue() []byte

func (*Metric) GetDescription 

func (x *Metric) GetDescription() string

func (*Metric) GetDoubleValue 

func (x *Metric) GetDoubleValue() float64

func (*Metric) GetInt32Value 

func (x *Metric) GetInt32Value() int32

func (*Metric) GetInt64Value 

func (x *Metric) GetInt64Value() int64

func (*Metric) GetName 

func (x *Metric) GetName() string

func (*Metric) GetStringValue 

func (x *Metric) GetStringValue() string

func (*Metric) GetTs 

func (x *Metric) GetTs() *timestamppb.Timestamp

func (*Metric) GetType 

func (x *Metric) GetType() MetricType

func (*Metric) GetUint32Value 

func (x *Metric) GetUint32Value() uint32

func (*Metric) GetUint64Value 

func (x *Metric) GetUint64Value() uint64

func (*Metric) GetValue 

func (m *Metric) GetValue() isMetric_Value

func (*Metric) ProtoMessage 

func (*Metric) ProtoMessage()

func (*Metric) ProtoReflect 

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

func (*Metric) Reset 

func (x *Metric) Reset()

func (*Metric) String 

func (x *Metric) String() string

String

type MetricType 

type MetricType int32

MetricType represents all metric types in the system. 

const (
	// Due to first enum value has to be zero in proto3
	MetricType_METRIC_TYPE_RESERVED MetricType = 0
	// Unspecified means we do not know its type
	MetricType_METRIC_TYPE_UNSPECIFIED MetricType = 100
	// CPU usage metric
	MetricType_METRIC_TYPE_CPU MetricType = 200
	// RAM usage metric
	MetricType_METRIC_TYPE_RAM MetricType = 300
)

func (MetricType) Descriptor 

func (MetricType) Descriptor() protoreflect.EnumDescriptor

func (MetricType) Enum 

func (x MetricType) Enum() *MetricType

func (MetricType) EnumDescriptor deprecated 

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

Deprecated: Use MetricType.Descriptor instead.

func (MetricType) Number 

func (x MetricType) Number() protoreflect.EnumNumber

func (MetricType) Type 

func (MetricType) Type() protoreflect.EnumType

type Metric_BytesValue 

type Metric_BytesValue struct {
	// OneOf. bytes value of the metric
	BytesValue []byte `protobuf:"bytes,560,opt,name=bytes_value,json=bytesValue,proto3,oneof"`
}

type Metric_DoubleValue 

type Metric_DoubleValue struct {
	// OneOf. double value of the metric
	DoubleValue float64 `protobuf:"fixed64,510,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

type Metric_Int32Value 

type Metric_Int32Value struct {
	// OneOf. int32 value of the metric
	Int32Value int32 `protobuf:"varint,520,opt,name=int32_value,json=int32Value,proto3,oneof"`
}

type Metric_Int64Value 

type Metric_Int64Value struct {
	// OneOf. int64 value of the metric
	Int64Value int64 `protobuf:"varint,540,opt,name=int64_value,json=int64Value,proto3,oneof"`
}

type Metric_StringValue 

type Metric_StringValue struct {
	// OneOf. string value of the metric
	StringValue string `protobuf:"bytes,500,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type Metric_Uint32Value 

type Metric_Uint32Value struct {
	// OneOf. uint32 value of the metric
	Uint32Value uint32 `protobuf:"varint,530,opt,name=uint32_value,json=uint32Value,proto3,oneof"`
}

type Metric_Uint64Value 

type Metric_Uint64Value struct {
	// OneOf. uint64 value of the metric
	Uint64Value uint64 `protobuf:"varint,550,opt,name=uint64_value,json=uint64Value,proto3,oneof"`
}

type Metrics 

type Metrics struct {

	// Header represents metadata of the set of metrics
	Header *Metadata `protobuf:"bytes,100,opt,name=header,proto3" json:"header,omitempty"`
	// Optional. Type of metrics set.
	// Object can be typed/identified either by type or by name.
	Type *int32 `protobuf:"varint,200,opt,name=type,proto3,oneof" json:"type,omitempty"`
	// Optional. Name of metrics set.
	// Object can be typed/identified either by type or by name.
	Name *string `protobuf:"bytes,300,opt,name=name,proto3,oneof" json:"name,omitempty"`
	// Metrics is the purpose of the whole Metrics data type, is expected to be present at all time.
	Metrics []*Metric `protobuf:"bytes,400,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

Metrics is a set of Metric tuples. Metric can be classified either by type or by name. MetricType can be specified once for the whole set of metrics, instead of specifying in each one of them.

func NewMetrics 

func NewMetrics() *Metrics

NewMetrics

func (*Metrics) Descriptor deprecated 

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

Deprecated: Use Metrics.ProtoReflect.Descriptor instead.

func (*Metrics) GetHeader 

func (x *Metrics) GetHeader() *Metadata

func (*Metrics) GetMetrics 

func (x *Metrics) GetMetrics() []*Metric

func (*Metrics) GetName 

func (x *Metrics) GetName() string

func (*Metrics) GetType 

func (x *Metrics) GetType() int32

func (*Metrics) ProtoMessage 

func (*Metrics) ProtoMessage()

func (*Metrics) ProtoReflect 

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

func (*Metrics) Reset 

func (x *Metrics) Reset()

func (*Metrics) String 

func (x *Metrics) String() string

String

type MetricsType 

type MetricsType int32

MetricsType represents areas of metrics accumulation - such as resource utilization, etc 

const (
	// Due to first enum value has to be zero in proto3
	MetricsType_METRICS_TYPE_RESERVED MetricsType = 0
	// Unspecified means we do not know its type
	MetricsType_METRICS_TYPE_UNSPECIFIED MetricsType = 100
	// Resource utilization, such as CPU, RAM, etc
	MetricsType_METRICS_TYPE_RESOURCE_UTILIZATION MetricsType = 200
)

func (MetricsType) Descriptor 

func (MetricsType) Descriptor() protoreflect.EnumDescriptor

func (MetricsType) Enum 

func (x MetricsType) Enum() *MetricsType

func (MetricsType) EnumDescriptor deprecated 

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

Deprecated: Use MetricsType.Descriptor instead.

func (MetricsType) Number 

func (x MetricsType) Number() protoreflect.EnumNumber

func (MetricsType) Type 

func (MetricsType) Type() protoreflect.EnumType

type ObjectRequest 

type ObjectRequest struct {

	// Request Domain - what type of entity the request is made about Ex.: atlas.DomainTask
	RequestDomain *Domain `protobuf:"bytes,100,opt,name=request_domain,json=requestDomain,proto3,oneof" json:"request_domain,omitempty"`
	// Result Domain - what type of entity is expected as a result.
	// Ex.: atlas.DomainReport, atlas.DomainTask, atlas.DomainStatus, atlas.DomainFile
	ResultDomain *Domain `protobuf:"bytes,200,opt,name=result_domain,json=resultDomain,proto3,oneof" json:"result_domain,omitempty"`
	// Addresses of the entity the
	// request is made about
	Addresses *AddressMap `protobuf:"bytes,300,opt,name=addresses,proto3" json:"addresses,omitempty"`
	// Filter(s) for this entity (applicable only in case it is a json)
	JsonPaths []string `protobuf:"bytes,400,rep,name=json_paths,json=jsonPaths,proto3" json:"json_paths,omitempty"`
	// contains filtered or unexported fields
}

ObjectRequest represents request for the object(s)

func NewObjectRequest 

func NewObjectRequest() *ObjectRequest

NewObjectRequest is a constructor

func (*ObjectRequest) AppendAddress 

func (x *ObjectRequest) AppendAddress(entities ...interface{}) *ObjectRequest

AppendAddress is a convenience wrapper to append oen address with optional domain(s) The format is: [domain,] address, [address, ...]

func (*ObjectRequest) Descriptor deprecated 

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

Deprecated: Use ObjectRequest.ProtoReflect.Descriptor instead.

func (*ObjectRequest) GetAddress 

func (x *ObjectRequest) GetAddress(domains ...*Domain) *Address

GetAddress is a convenience wrapper to get one address of a specified domain

func (*ObjectRequest) GetAddresses 

func (x *ObjectRequest) GetAddresses() *AddressMap

func (*ObjectRequest) GetJsonPaths 

func (x *ObjectRequest) GetJsonPaths() []string

func (*ObjectRequest) GetRequestDomain 

func (x *ObjectRequest) GetRequestDomain() *Domain

func (*ObjectRequest) GetResultDomain 

func (x *ObjectRequest) GetResultDomain() *Domain

func (*ObjectRequest) ProtoMessage 

func (*ObjectRequest) ProtoMessage()

func (*ObjectRequest) ProtoReflect 

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

func (*ObjectRequest) Reset 

func (x *ObjectRequest) Reset()

func (*ObjectRequest) SetAddress 

func (x *ObjectRequest) SetAddress(entities ...interface{}) *ObjectRequest

SetAddress is a convenience wrapper to set one address with optional domain(s) The format is: [domain,] address, [address, ...]

func (*ObjectRequest) SetRequestDomain 

func (x *ObjectRequest) SetRequestDomain(domain *Domain) *ObjectRequest

SetRequestDomain is a setter

func (*ObjectRequest) SetResultDomain 

func (x *ObjectRequest) SetResultDomain(domain *Domain) *ObjectRequest

SetResultDomain is a setter

func (*ObjectRequest) String 

func (x *ObjectRequest) String() string

String is a stringifier

type ObjectStatus 

type ObjectStatus struct {

	// Status represents status of an object
	Status *Status `protobuf:"bytes,100,opt,name=status,proto3" json:"status,omitempty"`
	// Domain represents domain of an object
	Domain *Domain `protobuf:"bytes,200,opt,name=domain,proto3,oneof" json:"domain,omitempty"`
	// Address represents address of an object
	Address *Address `protobuf:"bytes,300,opt,name=address,proto3,oneof" json:"address,omitempty"`
	// contains filtered or unexported fields
}

ObjectStatus specifies status of an object

func NewObjectStatus 

func NewObjectStatus(status ...*Status) *ObjectStatus

NewObjectStatus

func (*ObjectStatus) Descriptor deprecated 

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

Deprecated: Use ObjectStatus.ProtoReflect.Descriptor instead.

func (*ObjectStatus) Ensure 

func (x *ObjectStatus) Ensure() *ObjectStatus

Ensure returns new or existing Status

func (*ObjectStatus) GetAddress 

func (x *ObjectStatus) GetAddress() *Address

func (*ObjectStatus) GetDomain 

func (x *ObjectStatus) GetDomain() *Domain

func (*ObjectStatus) GetStatus 

func (x *ObjectStatus) GetStatus() *Status

func (*ObjectStatus) ProtoMessage 

func (*ObjectStatus) ProtoMessage()

func (*ObjectStatus) ProtoReflect 

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

func (*ObjectStatus) Reset 

func (x *ObjectStatus) Reset()

func (*ObjectStatus) SetAddress 

func (x *ObjectStatus) SetAddress(address *Address) *ObjectStatus

SetAddress sets address

func (*ObjectStatus) SetDomain 

func (x *ObjectStatus) SetDomain(domain *Domain) *ObjectStatus

SetDomain sets address

func (*ObjectStatus) SetStatus 

func (x *ObjectStatus) SetStatus(status *Status) *ObjectStatus

SetStatus sets status

func (*ObjectStatus) String 

func (x *ObjectStatus) String() string

String

type ObjectsList 

type ObjectsList struct {

	// Status specifies general status of the whole list
	Status *Status `protobuf:"bytes,100,opt,name=status,proto3" json:"status,omitempty"`
	// Reports specifies reports regarding the requested objects
	Reports []*Report `protobuf:"bytes,500,rep,name=reports,proto3" json:"reports,omitempty"`
	// Tasks specifies tasks of the requested objects
	Tasks []*Task `protobuf:"bytes,600,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// Statuses specifies statuses of the requested objects
	Statuses []*Status `protobuf:"bytes,700,rep,name=statuses,proto3" json:"statuses,omitempty"`
	// ObjectsStatus specifies object status
	ObjectStatuses []*ObjectStatus `protobuf:"bytes,800,rep,name=object_statuses,json=objectStatuses,proto3" json:"object_statuses,omitempty"`
	// Files specifies files of the requested objects
	Files []*File `protobuf:"bytes,900,rep,name=files,proto3" json:"files,omitempty"`
	// contains filtered or unexported fields
}

ObjectsList specifies list of the objects

func NewObjectsList 

func NewObjectsList() *ObjectsList

NewObjectsList

func (*ObjectsList) AddFile 

func (x *ObjectsList) AddFile(files ...*File) *ObjectsList

AddFile

func (*ObjectsList) AddObjectStatus 

func (x *ObjectsList) AddObjectStatus(statuses ...*ObjectStatus) *ObjectsList

AddObjectStatus

func (*ObjectsList) AddReport 

func (x *ObjectsList) AddReport(reports ...*Report) *ObjectsList

AddReport

func (*ObjectsList) AddStatus 

func (x *ObjectsList) AddStatus(statuses ...*Status) *ObjectsList

AddStatus

func (*ObjectsList) AddTask 

func (x *ObjectsList) AddTask(tasks ...*Task) *ObjectsList

AddTask

func (*ObjectsList) Descriptor deprecated 

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

Deprecated: Use ObjectsList.ProtoReflect.Descriptor instead.

func (*ObjectsList) GetFiles 

func (x *ObjectsList) GetFiles() []*File

func (*ObjectsList) GetObjectStatuses 

func (x *ObjectsList) GetObjectStatuses() []*ObjectStatus

func (*ObjectsList) GetReports 

func (x *ObjectsList) GetReports() []*Report

func (*ObjectsList) GetStatus 

func (x *ObjectsList) GetStatus() *Status

func (*ObjectsList) GetStatuses 

func (x *ObjectsList) GetStatuses() []*Status

func (*ObjectsList) GetTasks 

func (x *ObjectsList) GetTasks() []*Task

func (*ObjectsList) LenFiles 

func (x *ObjectsList) LenFiles() int

LenFiles

func (*ObjectsList) LenObjectStatuses 

func (x *ObjectsList) LenObjectStatuses() int

LenObjectStatuses

func (*ObjectsList) LenReports 

func (x *ObjectsList) LenReports() int

LenReports

func (*ObjectsList) LenStatuses 

func (x *ObjectsList) LenStatuses() int

LenStatuses

func (*ObjectsList) LenTasks 

func (x *ObjectsList) LenTasks() int

LenTasks

func (*ObjectsList) ProtoMessage 

func (*ObjectsList) ProtoMessage()

func (*ObjectsList) ProtoReflect 

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

func (*ObjectsList) Reset 

func (x *ObjectsList) Reset()

func (*ObjectsList) SetStatus 

func (x *ObjectsList) SetStatus(status *Status) *ObjectsList

SetStatus

func (*ObjectsList) String 

func (x *ObjectsList) String() string

String

type ObjectsRequest 

type ObjectsRequest struct {

	// Request Domain - what type of entity the request is made about Ex.: atlas.DomainTask
	RequestDomain *Domain `protobuf:"bytes,100,opt,name=request_domain,json=requestDomain,proto3,oneof" json:"request_domain,omitempty"`
	// Result Domain - what type of entity is expected as a result.
	// Ex.: atlas.DomainReport, atlas.DomainTask, atlas.DomainStatus, atlas.DomainFile
	ResultDomain *Domain `protobuf:"bytes,300,opt,name=result_domain,json=resultDomain,proto3,oneof" json:"result_domain,omitempty"`
	// Requests specifies multiple requests about objects
	Requests []*ObjectRequest `protobuf:"bytes,200,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

ObjectsRequest specifies request about multiple objects

func NewObjectsRequest 

func NewObjectsRequest() *ObjectsRequest

NewObjectsRequest is a constructor

func (*ObjectsRequest) Append 

func (x *ObjectsRequest) Append(request ...*ObjectRequest) *ObjectsRequest

Append appends request(s)

func (*ObjectsRequest) Descriptor deprecated 

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

Deprecated: Use ObjectsRequest.ProtoReflect.Descriptor instead.

func (*ObjectsRequest) GetRequestDomain 

func (x *ObjectsRequest) GetRequestDomain() *Domain

func (*ObjectsRequest) GetRequests 

func (x *ObjectsRequest) GetRequests() []*ObjectRequest

func (*ObjectsRequest) GetRequestsNum 

func (x *ObjectsRequest) GetRequestsNum() int

GetRequestsNum gets number of requests

func (*ObjectsRequest) GetResultDomain 

func (x *ObjectsRequest) GetResultDomain() *Domain

func (*ObjectsRequest) ProtoMessage 

func (*ObjectsRequest) ProtoMessage()

func (*ObjectsRequest) ProtoReflect 

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

func (*ObjectsRequest) Reset 

func (x *ObjectsRequest) Reset()

func (*ObjectsRequest) SetRequestDomain 

func (x *ObjectsRequest) SetRequestDomain(domain *Domain) *ObjectsRequest

SetRequestDomain is a setter

func (*ObjectsRequest) SetResultDomain 

func (x *ObjectsRequest) SetResultDomain(domain *Domain) *ObjectsRequest

SetResultDomain is a setter

func (*ObjectsRequest) String 

func (x *ObjectsRequest) String() string

String is a stringifier

type PresentationOptions 

type PresentationOptions struct {

	// Encoding represents encoding of the object.
	Encoding *Encoding `protobuf:"bytes,100,opt,name=encoding,proto3,oneof" json:"encoding,omitempty"`
	// Compression represents compression of the object.
	Compression *Compression `protobuf:"bytes,200,opt,name=compression,proto3,oneof" json:"compression,omitempty"`
	// contains filtered or unexported fields
}

PresentationOptions describes presentation options of the object

func NewPresentationOptions 

func NewPresentationOptions() *PresentationOptions

NewPresentationOptions

func (*PresentationOptions) Descriptor deprecated 

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

Deprecated: Use PresentationOptions.ProtoReflect.Descriptor instead.

func (*PresentationOptions) GetCompression 

func (x *PresentationOptions) GetCompression() *Compression

func (*PresentationOptions) GetEncoding 

func (x *PresentationOptions) GetEncoding() *Encoding

func (*PresentationOptions) HasCompression 

func (x *PresentationOptions) HasCompression() bool

HasCompression

func (*PresentationOptions) HasEncoding 

func (x *PresentationOptions) HasEncoding() bool

HasEncoding

func (*PresentationOptions) Log 

func (x *PresentationOptions) Log()

Log

func (*PresentationOptions) ProtoMessage 

func (*PresentationOptions) ProtoMessage()

func (*PresentationOptions) ProtoReflect 

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

func (*PresentationOptions) Reset 

func (x *PresentationOptions) Reset()

func (*PresentationOptions) SetCompression 

func (x *PresentationOptions) SetCompression(compression *Compression) *PresentationOptions

SetCompression

func (*PresentationOptions) SetEncoding 

func (x *PresentationOptions) SetEncoding(encoding *Encoding) *PresentationOptions

SetEncoding

func (*PresentationOptions) String 

func (x *PresentationOptions) String() string

String

type Report 

type Report struct {

	// Header specifies report headre
	Header *Metadata `protobuf:"bytes,100,opt,name=header,proto3,oneof" json:"header,omitempty"`
	// Bytes is the purpose of the whole report type
	// May contain any arbitrary sequence of bytes no longer than 2^32
	Bytes []byte `protobuf:"bytes,200,opt,name=bytes,proto3" json:"bytes,omitempty"`
	// Report may contain nested reports - parts of combined report
	Children []*Report `protobuf:"bytes,300,rep,name=children,proto3" json:"children,omitempty"`
	// contains filtered or unexported fields
}

Report specifies one report

func NewReport 

func NewReport() *Report

NewReport

func (*Report) AddSubReport 

func (x *Report) AddSubReport(r *Report) *Report

AddSubReport

func (*Report) Descriptor deprecated 

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

Deprecated: Use Report.ProtoReflect.Descriptor instead.

func (*Report) EnsureHeader 

func (x *Report) EnsureHeader() *Metadata

EnsureHeader

func (*Report) GetBytes 

func (x *Report) GetBytes() []byte

func (*Report) GetChildren 

func (x *Report) GetChildren() []*Report

func (*Report) GetHeader 

func (x *Report) GetHeader() *Metadata

func (*Report) HasSubReports 

func (x *Report) HasSubReports() bool

HasSubReports

func (*Report) ProtoMessage 

func (*Report) ProtoMessage()

func (*Report) ProtoReflect 

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

func (*Report) Reset 

func (x *Report) Reset()

func (*Report) SetBytes 

func (x *Report) SetBytes(bytes []byte) *Report

SetBytes

func (*Report) String 

func (x *Report) String() string

String

func (*Report) WalkSubReports 

func (x *Report) WalkSubReports(f func(i int, subReport *Report)) *Report

WalkSubReports

type ResponseHeader 

type ResponseHeader struct {

	// Properties specifies properties of a DataChunk
	Properties *DataChunkProperties `protobuf:"bytes,100,opt,name=properties,proto3,oneof" json:"properties,omitempty"`
	// Trace specifies trace
	Trace *Trace `protobuf:"bytes,200,opt,name=trace,proto3,oneof" json:"trace,omitempty"`
	// Error specifies error
	Error *Error `protobuf:"bytes,400,opt,name=error,proto3,oneof" json:"error,omitempty"`
	// contains filtered or unexported fields
}

ResponseHeader specifies header of a response

func (*ResponseHeader) Descriptor deprecated 

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

Deprecated: Use ResponseHeader.ProtoReflect.Descriptor instead.

func (*ResponseHeader) GetError 

func (x *ResponseHeader) GetError() *Error

func (*ResponseHeader) GetProperties 

func (x *ResponseHeader) GetProperties() *DataChunkProperties

func (*ResponseHeader) GetTrace 

func (x *ResponseHeader) GetTrace() *Trace

func (*ResponseHeader) ProtoMessage 

func (*ResponseHeader) ProtoMessage()

func (*ResponseHeader) ProtoReflect 

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

func (*ResponseHeader) Reset 

func (x *ResponseHeader) Reset()

type S3Address 

type S3Address struct {

	// Bucket name
	Bucket string `protobuf:"bytes,100,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// Object name
	Object string `protobuf:"bytes,200,opt,name=object,proto3" json:"object,omitempty"`
	// contains filtered or unexported fields
}

S3Address represents S3 and MinIO address

func NewS3Address 

func NewS3Address(bucket, object string) *S3Address

NewS3Address creates new S3Address

func NewS3AddressFromString 

func NewS3AddressFromString(str string) *S3Address

NewS3AddressFromString creates new S3Address from string. The first section of the string is considered to be a bucket Expected format is: bucket/path/to/the/object

func (*S3Address) Descriptor deprecated 

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

Deprecated: Use S3Address.ProtoReflect.Descriptor instead.

func (*S3Address) GetBucket 

func (x *S3Address) GetBucket() string

func (*S3Address) GetBucketNameError 

func (x *S3Address) GetBucketNameError() error

GetBucketNameError returns an error in case BucketName is incorrect

func (*S3Address) GetError 

func (x *S3Address) GetError() error

GetError returns and error in case S3Address is not valid

func (*S3Address) GetFilename 

func (x *S3Address) GetFilename() string

GetFilename gets filename of an object

func (*S3Address) GetObject 

func (x *S3Address) GetObject() string

func (*S3Address) GetObjectNameError 

func (x *S3Address) GetObjectNameError() error

GetObjectNameError returns an error in case ObjectName is incorrect

func (*S3Address) IsBucketNameValid 

func (x *S3Address) IsBucketNameValid() bool

IsBucketNameValid checks whether bucket name is valid

func (*S3Address) IsObjectNameValid 

func (x *S3Address) IsObjectNameValid() bool

IsObjectNameValid checks whether object name is valid

func (*S3Address) IsValid 

func (x *S3Address) IsValid() bool

IsValid checks whether address is valid

func (*S3Address) ProtoMessage 

func (*S3Address) ProtoMessage()

func (*S3Address) ProtoReflect 

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

func (*S3Address) Reset 

func (x *S3Address) Reset()

func (*S3Address) SetBucket 

func (x *S3Address) SetBucket(bucket string) *S3Address

SetBucket sets bucket

func (*S3Address) SetObject 

func (x *S3Address) SetObject(object string) *S3Address

SetObject sets object

func (*S3Address) String 

func (x *S3Address) String() string

String stringifies S3Address

type ServingStatus 

type ServingStatus int32

ServingStatus represents status of the service 

const (
	// Unknown status
	ServingStatus_UNKNOWN ServingStatus = 0
	// Service is serving
	ServingStatus_SERVING ServingStatus = 1
	// Service is not serving
	ServingStatus_NOT_SERVING ServingStatus = 2
)

func (ServingStatus) Descriptor 

func (ServingStatus) Descriptor() protoreflect.EnumDescriptor

func (ServingStatus) Enum 

func (x ServingStatus) Enum() *ServingStatus

func (ServingStatus) EnumDescriptor deprecated 

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

Deprecated: Use ServingStatus.Descriptor instead.

func (ServingStatus) Number 

func (x ServingStatus) Number() protoreflect.EnumNumber

func (ServingStatus) Type 

func (ServingStatus) Type() protoreflect.EnumType

type SliceInt32 

type SliceInt32 struct {
	Slice []int32 `protobuf:"varint,100,rep,packed,name=slice,proto3" json:"slice,omitempty"`
	// contains filtered or unexported fields
}

func NewSliceInt32 

func NewSliceInt32() *SliceInt32

NewSliceInt32

func (*SliceInt32) Add 

func (x *SliceInt32) Add(a ...int32) *SliceInt32

Add

func (*SliceInt32) Descriptor deprecated 

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

Deprecated: Use SliceInt32.ProtoReflect.Descriptor instead.

func (*SliceInt32) Ensure 

func (x *SliceInt32) Ensure() *SliceInt32

Ensure

func (*SliceInt32) Fetch 

func (x *SliceInt32) Fetch(i int) (int32, bool)

Fetch

func (*SliceInt32) Get 

func (x *SliceInt32) Get(i int) int32

Get

func (*SliceInt32) GetAll 

func (x *SliceInt32) GetAll() []int32

GetAll

func (*SliceInt32) GetSlice 

func (x *SliceInt32) GetSlice() []int32

func (*SliceInt32) Len 

func (x *SliceInt32) Len() int

Len

func (*SliceInt32) ProtoMessage 

func (*SliceInt32) ProtoMessage()

func (*SliceInt32) ProtoReflect 

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

func (*SliceInt32) Reset 

func (x *SliceInt32) Reset()

func (*SliceInt32) String 

func (x *SliceInt32) String() string

String

type Status 

type Status struct {

	// Code represents code of the status
	Code int32 `protobuf:"varint,100,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

Status represents status of the object(s)

func FindStatus 

func FindStatus(status *Status) *Status

FindStatus returns registered status with the same string value as provided

func NewStatus 

func NewStatus(code ...int32) *Status

NewStatus

func NormalizeStatus 

func NormalizeStatus(status *Status) *Status

NormalizeStatus returns either registered status with the same string value as provided status or provided status.

func RegisterStatus 

func RegisterStatus(status *Status) *Status

RegisterStatus tries to register specified Status. New entity must be non-equal to all registered entities. Returns nil in case new entity can not be registered, say it is equal to previously registered entity

func StatusFromCode 

func StatusFromCode(code int32) *Status

StatusFromCode tries to find registered status with specified code

func (*Status) Descriptor deprecated 

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) Ensure 

func (x *Status) Ensure() *Status

Ensure returns new or existing Status

func (*Status) Equals 

func (x *Status) Equals(status *Status) bool

Equals checks whether two objects are equal internally

func (*Status) GetCode 

func (x *Status) GetCode() int32

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect 

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

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) SetCode 

func (x *Status) SetCode(code int32) *Status

SetCode sets status

func (*Status) String 

func (x *Status) String() string

String

type Task 

type Task struct {

	// Header of the task
	Header *Metadata `protobuf:"bytes,100,opt,name=header,proto3" json:"header,omitempty"`
	// Optional. Any arbitrary sequence of bytes no longer than 2^32
	Bytes []byte `protobuf:"bytes,200,opt,name=bytes,proto3" json:"bytes,omitempty"`
	// Optional. Multiple task's subjects.
	Subjects []*Metadata `protobuf:"bytes,300,rep,name=subjects,proto3" json:"subjects,omitempty"`
	// Optional. Recursive chain of tasks
	Parents []*Task `protobuf:"bytes,400,rep,name=parents,proto3" json:"parents,omitempty"`
	// Optional. Recursive chain of tasks
	Children []*Task `protobuf:"bytes,500,rep,name=children,proto3" json:"children,omitempty"`
	// contains filtered or unexported fields
}

func NewTask 

func NewTask() *Task

NewTask creates new Command with pre-allocated header

func NewTaskUnmarshalFrom 

func NewTaskUnmarshalFrom(bytes []byte) (*Task, error)

NewTaskUnmarshalFrom creates new Task from a slice of bytes

func (*Task) AddParent 

func (x *Task) AddParent(task *Task) *Task

AddParent adds one parent of the task

func (*Task) AddParents 

func (x *Task) AddParents(tasks ...*Task) *Task

AddParents adds multiple parents of the task

func (*Task) AddSubject 

func (x *Task) AddSubject(subject *Metadata) *Task

AddSubject ands one subject to the task

func (*Task) AddSubjects 

func (x *Task) AddSubjects(subjects ...*Metadata) *Task

AddSubjects adds multiple subjects to the task

func (*Task) AddSubtask 

func (x *Task) AddSubtask(task *Task) *Task

AddSubtask adds one subtask to the task

func (*Task) AddSubtasks 

func (x *Task) AddSubtasks(tasks ...*Task) *Task

AddSubtasks adds multiple subtasks to the task

func (*Task) AppendResult 

func (x *Task) AppendResult(address *Address) *Task

AppendResult

func (*Task) CreateUuid 

func (x *Task) CreateUuid() *Task

CreateUuid creates new random UUID

func (*Task) Derive 

func (x *Task) Derive() *Task

Derive produces derivative task from the task as:

  1. fetches first (0-indexed) subtask from available subtasks
  2. and attaches all the rest subtasks (if any) as subtasks of the fetched one, which it the new top now.

Original task is modified.

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) EnsureHeader 

func (x *Task) EnsureHeader() *Metadata

EnsureHeader

func (*Task) FirstParent 

func (x *Task) FirstParent() *Task

FirstParent fetches first (0-indexed) parent. List of list does not change.

func (*Task) FirstSubject 

func (x *Task) FirstSubject() *Metadata

FirstSubject fetches first (0-indexed) subject. List of list does not change.

func (*Task) FirstSubtask 

func (x *Task) FirstSubtask() *Task

FirstSubtask fetches first (0-indexed) subtask. List of subtasks does not change.

func (*Task) GetBytes 

func (x *Task) GetBytes() []byte

func (*Task) GetChildren 

func (x *Task) GetChildren() []*Task

func (*Task) GetContextUuid 

func (x *Task) GetContextUuid() *UUID

GetContextUuid

func (*Task) GetContextUuidAsString 

func (x *Task) GetContextUuidAsString() string

GetContextUuidAsString

func (*Task) GetDescription 

func (x *Task) GetDescription() string

GetDescription

func (*Task) GetEmail 

func (x *Task) GetEmail() *Email

GetEmail

func (*Task) GetEmailAsString 

func (x *Task) GetEmailAsString() string

GetEmailAsString

func (*Task) GetHeader 

func (x *Task) GetHeader() *Metadata

func (*Task) GetName 

func (x *Task) GetName() string

GetName gets task name

func (*Task) GetParents 

func (x *Task) GetParents() []*Task

func (*Task) GetPayload 

func (x *Task) GetPayload(msg proto.Message) error

GetPayload extracts profobuf message (type) from task's data. Message is unmarshalled from task's data into provided message.

func (*Task) GetReferenceUuid 

func (x *Task) GetReferenceUuid() *UUID

GetReferenceUuid

func (*Task) GetReferenceUuidAsString 

func (x *Task) GetReferenceUuidAsString() string

GetReferenceUuidAsString

func (*Task) GetResult 

func (x *Task) GetResult() *Address

GetResult

func (*Task) GetResults 

func (x *Task) GetResults() []*Address

GetResults

func (*Task) GetStatus 

func (x *Task) GetStatus() int32

GetStatus gets task status

func (*Task) GetSubjects 

func (x *Task) GetSubjects() []*Metadata

func (*Task) GetType 

func (x *Task) GetType() int32

GetType gets task type

func (*Task) GetUserID 

func (x *Task) GetUserID() *UserID

GetUserID

func (*Task) GetUserIDAsString 

func (x *Task) GetUserIDAsString() string

GetUserIDAsString

func (*Task) GetUuid 

func (x *Task) GetUuid() *UUID

GetUuid

func (*Task) GetUuidAsString 

func (x *Task) GetUuidAsString() string

GetUuidAsString

func (*Task) LastParent 

func (x *Task) LastParent() *Task

LastParent fetches last parent. List of list does not change.

func (*Task) LastSubject 

func (x *Task) LastSubject() *Metadata

LastSubject fetches last subject. List of list does not change.

func (*Task) LastSubtask 

func (x *Task) LastSubtask() *Task

LastSubtask fetches last subtask. List of subtasks does not change.

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

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

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) SetBytes 

func (x *Task) SetBytes(bytes []byte) *Task

SetBytes sets bytes as task's data. Provided bytes are not interpreted and used as-is.

func (*Task) SetContextUuid 

func (x *Task) SetContextUuid(uuid *UUID) *Task

SetContextUuid

func (*Task) SetContextUuidFromString 

func (x *Task) SetContextUuidFromString(id string) *Task

SetContextUuidFromString

func (*Task) SetDescription 

func (x *Task) SetDescription(description string) *Task

SetDescription

func (*Task) SetEmail 

func (x *Task) SetEmail(address *Address) *Task

SetEmail

func (*Task) SetEmailFromString 

func (x *Task) SetEmailFromString(email string) *Task

SetEmailFromString

func (*Task) SetName 

func (x *Task) SetName(name string) *Task

SetName

func (*Task) SetPayload 

func (x *Task) SetPayload(msg proto.Message) error

SetPayload puts any protobuf message (type) into task's data. Message is marshalled into binary form and set as data bytes of the task.

func (*Task) SetReferenceUuid 

func (x *Task) SetReferenceUuid(uuid *UUID) *Task

SetReferenceUuid

func (*Task) SetReferenceUuidFromString 

func (x *Task) SetReferenceUuidFromString(id string) *Task

SetReferenceUuidFromString

func (*Task) SetResult 

func (x *Task) SetResult(address *Address) *Task

SetResult

func (*Task) SetStatus 

func (x *Task) SetStatus(status int32) *Task

SetStatus sets task status

func (*Task) SetType 

func (x *Task) SetType(_type int32) *Task

SetType

func (*Task) SetUserID 

func (x *Task) SetUserID(address *Address) *Task

SetUserID

func (*Task) SetUserIDFromString 

func (x *Task) SetUserIDFromString(id string) *Task

SetUserIDFromString

func (*Task) SetUuid 

func (x *Task) SetUuid(address *Address) *Task

SetUuid

func (*Task) SetUuidFromString 

func (x *Task) SetUuidFromString(id string) *Task

SetUuidFromString

func (*Task) ShiftSubtasks 

func (x *Task) ShiftSubtasks() *Task

ShiftSubtasks fetches first (0-indexed) task from available tasks. Fetched task is removed from the list of tasks. List of subtasks changes.

func (*Task) String 

func (x *Task) String() string

String

func (*Task) UnmarshalFrom 

func (x *Task) UnmarshalFrom(bytes []byte) error

UnmarshalFrom unmarshal commands from a slice of bytes

type Trace 

type Trace struct {

	// TraceUid specifies UUID of the trace
	TraceUid *UUID `protobuf:"bytes,100,opt,name=trace_uid,json=traceUid,proto3,oneof" json:"trace_uid,omitempty"`
	// NodeUid specifies id the the node in the trace
	NodeUid *string `protobuf:"bytes,200,opt,name=node_uid,json=nodeUid,proto3,oneof" json:"node_uid,omitempty"`
	// contains filtered or unexported fields
}

Trace represents an object trace

func (*Trace) Descriptor deprecated 

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

Deprecated: Use Trace.ProtoReflect.Descriptor instead.

func (*Trace) GetNodeUid 

func (x *Trace) GetNodeUid() string

func (*Trace) GetTraceUid 

func (x *Trace) GetTraceUid() *UUID

func (*Trace) ProtoMessage 

func (*Trace) ProtoMessage()

func (*Trace) ProtoReflect 

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

func (*Trace) Reset 

func (x *Trace) Reset()

type URL 

type URL struct {

	// URL value
	Url string `protobuf:"bytes,100,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

URL represents abstract url.

func NewURL 

func NewURL(url ...string) *URL

NewURL

func (*URL) Descriptor deprecated 

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

Deprecated: Use URL.ProtoReflect.Descriptor instead.

func (*URL) Equals 

func (x *URL) Equals(url *URL) bool

Equals

func (*URL) GetUrl 

func (x *URL) GetUrl() string

func (*URL) ProtoMessage 

func (*URL) ProtoMessage()

func (*URL) ProtoReflect 

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

func (*URL) Reset 

func (x *URL) Reset()

func (*URL) Set 

func (x *URL) Set(url string) *URL

Set

func (*URL) String 

func (x *URL) String() string

String

type UUID 

type UUID struct {

	// Data specifies UUID and is any arbitrary sequence of bytes no longer than 2^32
	Data []byte `protobuf:"bytes,100,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

UUID represents unique identifier.

func NewUuid 

func NewUuid() *UUID

NewUuid

func NewUuidFromString 

func NewUuidFromString(str string) *UUID

NewUuidFromString

func NewUuidRandom 

func NewUuidRandom() *UUID

NewUuidRandom

func (*UUID) Descriptor deprecated 

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

Deprecated: Use UUID.ProtoReflect.Descriptor instead.

func (*UUID) GetBytes 

func (x *UUID) GetBytes() []byte

GetBytes

func (*UUID) GetData 

func (x *UUID) GetData() []byte

func (*UUID) ProtoMessage 

func (*UUID) ProtoMessage()

func (*UUID) ProtoReflect 

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

func (*UUID) Reset 

func (x *UUID) Reset()

func (*UUID) SetBytes 

func (x *UUID) SetBytes(bytes []byte) *UUID

SetBytes

func (*UUID) SetString 

func (x *UUID) SetString(str string) *UUID

SetString

func (*UUID) String 

func (x *UUID) String() string

String

type UserID 

type UserID struct {

	// Data specifies user id and is any arbitrary sequence of bytes no longer than 2^32
	Data []byte `protobuf:"bytes,100,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

UserID specifies Identifier of a user.

func NewRandomUserID 

func NewRandomUserID() *UserID

NewRandomUserID

func NewUserID 

func NewUserID() *UserID

NewUserID

func NewUserIDFromString 

func NewUserIDFromString(str string) *UserID

NewUserIDFromString

func (*UserID) Descriptor deprecated 

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

Deprecated: Use UserID.ProtoReflect.Descriptor instead.

func (*UserID) GetBytes 

func (x *UserID) GetBytes() []byte

GetBytes

func (*UserID) GetData 

func (x *UserID) GetData() []byte

func (*UserID) ProtoMessage 

func (*UserID) ProtoMessage()

func (*UserID) ProtoReflect 

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

func (*UserID) Reset 

func (x *UserID) Reset()

func (*UserID) SetBytes 

func (x *UserID) SetBytes(bytes []byte) *UserID

SetBytes

func (*UserID) SetString 

func (x *UserID) SetString(str string) *UserID

SetString

func (*UserID) String 

func (x *UserID) String() string

String

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.