queue_info

Documentation

Overview

Package queue_info is a generated protocol buffer package.

It is generated from these files:

queue_info/service_desc.proto

It has these top-level messages:

ServiceDescription

Index

• Constants
• Variables
• func DeleteServiceData(serviceId string)
• func LoadServiceConfig(serviceId string, cfg apis.BinaryMarshaller) error
• func SaveServiceConfig(serviceId string, conf apis.BinaryMarshaller) error
• func SaveServiceDescription(desc *ServiceDescription) error
• type ServiceDescription
  • func GetServiceDescription(serviceId string) *ServiceDescription
  • func NewServiceDescription(name, sType string, exportId uint64) *ServiceDescription
  • func UnmarshalServiceDesc(data []byte) (*ServiceDescription, error)
  • func (*ServiceDescription) Descriptor() ([]byte, []int)
  • func (this *ServiceDescription) Equal(that interface{}) bool
  • func (m *ServiceDescription) GetCreateTs() int64
  • func (m *ServiceDescription) GetDisabled() bool
  • func (m *ServiceDescription) GetExportId() uint64
  • func (m *ServiceDescription) GetName() string
  • func (m *ServiceDescription) GetSType() string
  • func (m *ServiceDescription) GetServiceId() string
  • func (m *ServiceDescription) GetToDelete() bool
  • func (this *ServiceDescription) GoString() string
  • func (m *ServiceDescription) Marshal() (data []byte, err error)
  • func (m *ServiceDescription) MarshalTo(data []byte) (int, error)
  • func (*ServiceDescription) ProtoMessage()
  • func (m *ServiceDescription) Reset()
  • func (m *ServiceDescription) Size() (n int)
  • func (this *ServiceDescription) String() string
  • func (m *ServiceDescription) Unmarshal(data []byte) error
• type ServiceDescriptionList
  • func GetServiceDescriptions() ServiceDescriptionList
  • func (p ServiceDescriptionList) Len() int
  • func (p ServiceDescriptionList) Less(i, j int) bool
  • func (p ServiceDescriptionList) Swap(i, j int)

Constants

const ServiceConfigPrefix = ":config:"

const ServiceDescPrefix = ":desc:"

Variables

var (
	ErrInvalidLengthServiceDesc = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowServiceDesc   = fmt.Errorf("proto: integer overflow")
)

Functions

func DeleteServiceData

func DeleteServiceData(serviceId string)

func LoadServiceConfig

func LoadServiceConfig(serviceId string, cfg apis.BinaryMarshaller) error

func SaveServiceConfig

func SaveServiceConfig(serviceId string, conf apis.BinaryMarshaller) error

SaveServiceConfig saves service config into database.

func SaveServiceDescription

func SaveServiceDescription(desc *ServiceDescription) error

SaveServiceDescription saves service config into database.

Types

type ServiceDescription

type ServiceDescription struct {
	ExportId  uint64 `protobuf:"varint,1,req,name=export_id,json=exportId" json:"export_id"`
	SType     string `protobuf:"bytes,2,req,name=s_type,json=sType" json:"s_type"`
	Name      string `protobuf:"bytes,3,req,name=name" json:"name"`
	CreateTs  int64  `protobuf:"varint,4,req,name=create_ts,json=createTs" json:"create_ts"`
	Disabled  bool   `protobuf:"varint,5,req,name=disabled" json:"disabled"`
	ToDelete  bool   `protobuf:"varint,6,req,name=to_delete,json=toDelete" json:"to_delete"`
	ServiceId string `protobuf:"bytes,7,req,name=service_id,json=serviceId" json:"service_id"`
}

func GetServiceDescription

func GetServiceDescription(serviceId string) *ServiceDescription

GetServiceDescriptions Loads all service descriptions prefixed with ServiceDescPrefix

func NewServiceDescription

func NewServiceDescription(name, sType string, exportId uint64) *ServiceDescription

func UnmarshalServiceDesc

func UnmarshalServiceDesc(data []byte) (*ServiceDescription, error)

func (*ServiceDescription) Descriptor

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

func (*ServiceDescription) Equal

func (this *ServiceDescription) Equal(that interface{}) bool

func (*ServiceDescription) GetCreateTs

func (m *ServiceDescription) GetCreateTs() int64

func (*ServiceDescription) GetDisabled

func (m *ServiceDescription) GetDisabled() bool

func (*ServiceDescription) GetExportId

func (m *ServiceDescription) GetExportId() uint64

func (*ServiceDescription) GetName

func (m *ServiceDescription) GetName() string

func (*ServiceDescription) GetSType

func (m *ServiceDescription) GetSType() string

func (*ServiceDescription) GetServiceId

func (m *ServiceDescription) GetServiceId() string

func (*ServiceDescription) GetToDelete

func (m *ServiceDescription) GetToDelete() bool

func (*ServiceDescription) GoString

func (this *ServiceDescription) GoString() string

func (*ServiceDescription) Marshal

func (m *ServiceDescription) Marshal() (data []byte, err error)

func (*ServiceDescription) MarshalTo

func (m *ServiceDescription) MarshalTo(data []byte) (int, error)

func (*ServiceDescription) ProtoMessage

func (*ServiceDescription) ProtoMessage()

func (*ServiceDescription) Reset

func (m *ServiceDescription) Reset()

func (*ServiceDescription) Size

func (m *ServiceDescription) Size() (n int)

func (*ServiceDescription) String

func (this *ServiceDescription) String() string

func (*ServiceDescription) Unmarshal

func (m *ServiceDescription) Unmarshal(data []byte) error

type ServiceDescriptionList

type ServiceDescriptionList []*ServiceDescription

func GetServiceDescriptions

func GetServiceDescriptions() ServiceDescriptionList

GetServiceDescriptions Loads all service descriptions prefixed with ServiceDescPrefix

func (ServiceDescriptionList) Len

func (p ServiceDescriptionList) Len() int

func (ServiceDescriptionList) Less

func (p ServiceDescriptionList) Less(i, j int) bool

func (ServiceDescriptionList) Swap

func (p ServiceDescriptionList) Swap(i, j int)