pb

package
v0.0.0-...-af321b4 Latest Latest
Warning

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

 Go to latest Published: Apr 13, 2023 License: MPL-2.0 Imports: 28 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthAccount        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAccount          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAccount = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthControl        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowControl          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupControl = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthEdge        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEdge          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEdge = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthFlow        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowFlow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupFlow = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthKv        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowKv          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupKv = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthLabel        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLabel          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupLabel = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthNetwork        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowNetwork          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupNetwork = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTimestamp        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTimestamp          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTimestamp = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthToken        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowToken          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupToken = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthUlid        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowUlid          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupUlid = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthWire        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowWire          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupWire = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Capability_name = map[int32]string{
	0: "CONNECT",
	1: "SERVE",
	2: "ACCESS",
	3: "MGMT",
	4: "CONFIG",
}
View Source 
var Capability_value = map[string]int32{
	"CONNECT": 0,
	"SERVE":   1,
	"ACCESS":  2,
	"MGMT":    3,
	"CONFIG":  4,
}
View Source 
var ErrInvalidAccount = errors.New("invalid account key")
View Source 
var Request_Type_name = map[int32]string{
	0: "HTTP",
	1: "WEBSOCKET",
	2: "TCP",
	3: "UDP",
	4: "RPC",
	5: "AGENT_CONNECT",
}
View Source 
var Request_Type_value = map[string]int32{
	"HTTP":          0,
	"WEBSOCKET":     1,
	"TCP":           2,
	"UDP":           3,
	"RPC":           4,
	"AGENT_CONNECT": 5,
}
View Source 
var Signature_SigType_name = map[int32]string{
	0: "BLAKE2HMAC",
	1: "ED25519",
	2: "EXTERNAL",
}
View Source 
var Signature_SigType_value = map[string]int32{
	"BLAKE2HMAC": 0,
	"ED25519":    1,
	"EXTERNAL":   2,
}
View Source 
var TokenRole_name = map[int32]string{
	0: "AGENT",
	1: "HUB",
	2: "MANAGE",
}
View Source 
var TokenRole_value = map[string]int32{
	"AGENT":  0,
	"HUB":    1,
	"MANAGE": 2,
}

Functions

func RegisterControlManagementServer 

func RegisterControlManagementServer(s *grpc.Server, srv ControlManagementServer)

func RegisterControlServicesServer 

func RegisterControlServicesServer(s *grpc.Server, srv ControlServicesServer)

func RegisterEdgeServicesServer 

func RegisterEdgeServicesServer(s *grpc.Server, srv EdgeServicesServer)

func RegisterFlowTopReporterServer 

func RegisterFlowTopReporterServer(s *grpc.Server, srv FlowTopReporterServer)

Types

type Account 

type Account struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	AccountId *ULID  `protobuf:"bytes,2,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
}

func AccountFromKey 

func AccountFromKey(k []byte) (*Account, error)

func AccountFromStringKey 

func AccountFromStringKey(k []byte) (*Account, error)

func (*Account) Descriptor 

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

func (*Account) Equal 

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

func (*Account) GetAccountId 

func (m *Account) GetAccountId() *ULID

func (*Account) GetNamespace 

func (m *Account) GetNamespace() string

func (*Account) GoString 

func (this *Account) GoString() string

func (*Account) HashKey 

func (a *Account) HashKey() string

Hash the data and present a stable hash key useful for use in things like file and url paths.

func (*Account) Key 

func (a *Account) Key() []byte

Collapse the Account to an unambigious sequence

func (*Account) Marshal 

func (m *Account) Marshal() (dAtA []byte, err error)

func (*Account) MarshalJSON 

func (msg *Account) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Account) MarshalTo 

func (m *Account) MarshalTo(dAtA []byte) (int, error)

func (*Account) MarshalToSizedBuffer 

func (m *Account) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Account) ProtoMessage 

func (*Account) ProtoMessage()

func (*Account) Reset 

func (m *Account) Reset()

func (*Account) Size 

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

func (*Account) SpecString 

func (a *Account) SpecString() string

func (*Account) String 

func (a *Account) String() string

func (*Account) StringKey 

func (a *Account) StringKey() string

func (*Account) Unmarshal 

func (m *Account) Unmarshal(dAtA []byte) error

func (*Account) UnmarshalJSON 

func (msg *Account) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Account) XXX_DiscardUnknown 

func (m *Account) XXX_DiscardUnknown()

func (*Account) XXX_Marshal 

func (m *Account) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Account) XXX_Merge 

func (m *Account) XXX_Merge(src proto.Message)

func (*Account) XXX_Size 

func (m *Account) XXX_Size() int

func (*Account) XXX_Unmarshal 

func (m *Account) XXX_Unmarshal(b []byte) error

type AccountServices 

type AccountServices struct {
	Account  *Account        `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"`
	Services []*ServiceRoute `protobuf:"bytes,2,rep,name=services,proto3" json:"services,omitempty"`
}

func (*AccountServices) Descriptor 

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

func (*AccountServices) Equal 

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

func (*AccountServices) GetAccount 

func (m *AccountServices) GetAccount() *Account

func (*AccountServices) GetServices 

func (m *AccountServices) GetServices() []*ServiceRoute

func (*AccountServices) GoString 

func (this *AccountServices) GoString() string

func (*AccountServices) Marshal 

func (m *AccountServices) Marshal() (dAtA []byte, err error)

func (*AccountServices) MarshalJSON 

func (msg *AccountServices) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*AccountServices) MarshalTo 

func (m *AccountServices) MarshalTo(dAtA []byte) (int, error)

func (*AccountServices) MarshalToSizedBuffer 

func (m *AccountServices) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AccountServices) ProtoMessage 

func (*AccountServices) ProtoMessage()

func (*AccountServices) Reset 

func (m *AccountServices) Reset()

func (*AccountServices) Size 

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

func (*AccountServices) String 

func (this *AccountServices) String() string

func (*AccountServices) Unmarshal 

func (m *AccountServices) Unmarshal(dAtA []byte) error

func (*AccountServices) UnmarshalJSON 

func (msg *AccountServices) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*AccountServices) XXX_DiscardUnknown 

func (m *AccountServices) XXX_DiscardUnknown()

func (*AccountServices) XXX_Marshal 

func (m *AccountServices) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AccountServices) XXX_Merge 

func (m *AccountServices) XXX_Merge(src proto.Message)

func (*AccountServices) XXX_Size 

func (m *AccountServices) XXX_Size() int

func (*AccountServices) XXX_Unmarshal 

func (m *AccountServices) XXX_Unmarshal(b []byte) error

type Account_Limits 

type Account_Limits struct {
	HttpRequests float64 `protobuf:"fixed64,1,opt,name=http_requests,json=httpRequests,proto3" json:"http_requests,omitempty"`
	Bandwidth    float64 `protobuf:"fixed64,2,opt,name=bandwidth,proto3" json:"bandwidth,omitempty"`
}

func (*Account_Limits) Descriptor 

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

func (*Account_Limits) Equal 

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

func (*Account_Limits) GetBandwidth 

func (m *Account_Limits) GetBandwidth() float64

func (*Account_Limits) GetHttpRequests 

func (m *Account_Limits) GetHttpRequests() float64

func (*Account_Limits) GoString 

func (this *Account_Limits) GoString() string

func (*Account_Limits) Marshal 

func (m *Account_Limits) Marshal() (dAtA []byte, err error)

func (*Account_Limits) MarshalJSON 

func (msg *Account_Limits) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Account_Limits) MarshalTo 

func (m *Account_Limits) MarshalTo(dAtA []byte) (int, error)

func (*Account_Limits) MarshalToSizedBuffer 

func (m *Account_Limits) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Account_Limits) ProtoMessage 

func (*Account_Limits) ProtoMessage()

func (*Account_Limits) Reset 

func (m *Account_Limits) Reset()

func (*Account_Limits) Size 

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

func (*Account_Limits) String 

func (this *Account_Limits) String() string

func (*Account_Limits) Unmarshal 

func (m *Account_Limits) Unmarshal(dAtA []byte) error

func (*Account_Limits) UnmarshalJSON 

func (msg *Account_Limits) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Account_Limits) XXX_DiscardUnknown 

func (m *Account_Limits) XXX_DiscardUnknown()

func (*Account_Limits) XXX_Marshal 

func (m *Account_Limits) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Account_Limits) XXX_Merge 

func (m *Account_Limits) XXX_Merge(src proto.Message)

func (*Account_Limits) XXX_Size 

func (m *Account_Limits) XXX_Size() int

func (*Account_Limits) XXX_Unmarshal 

func (m *Account_Limits) XXX_Unmarshal(b []byte) error

type ActivityEntry 

type ActivityEntry struct {
	RouteAdded   *AccountServices `protobuf:"bytes,1,opt,name=route_added,json=routeAdded,proto3" json:"route_added,omitempty"`
	RouteRemoved *ULID            `protobuf:"bytes,2,opt,name=route_removed,json=routeRemoved,proto3" json:"route_removed,omitempty"`
}

func (*ActivityEntry) Descriptor 

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

func (*ActivityEntry) Equal 

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

func (*ActivityEntry) GetRouteAdded 

func (m *ActivityEntry) GetRouteAdded() *AccountServices

func (*ActivityEntry) GetRouteRemoved 

func (m *ActivityEntry) GetRouteRemoved() *ULID

func (*ActivityEntry) GoString 

func (this *ActivityEntry) GoString() string

func (*ActivityEntry) Marshal 

func (m *ActivityEntry) Marshal() (dAtA []byte, err error)

func (*ActivityEntry) MarshalJSON 

func (msg *ActivityEntry) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ActivityEntry) MarshalTo 

func (m *ActivityEntry) MarshalTo(dAtA []byte) (int, error)

func (*ActivityEntry) MarshalToSizedBuffer 

func (m *ActivityEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ActivityEntry) ProtoMessage 

func (*ActivityEntry) ProtoMessage()

func (*ActivityEntry) Reset 

func (m *ActivityEntry) Reset()

func (*ActivityEntry) Size 

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

func (*ActivityEntry) String 

func (this *ActivityEntry) String() string

func (*ActivityEntry) Unmarshal 

func (m *ActivityEntry) Unmarshal(dAtA []byte) error

func (*ActivityEntry) UnmarshalJSON 

func (msg *ActivityEntry) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*ActivityEntry) XXX_DiscardUnknown 

func (m *ActivityEntry) XXX_DiscardUnknown()

func (*ActivityEntry) XXX_Marshal 

func (m *ActivityEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActivityEntry) XXX_Merge 

func (m *ActivityEntry) XXX_Merge(src proto.Message)

func (*ActivityEntry) XXX_Size 

func (m *ActivityEntry) XXX_Size() int

func (*ActivityEntry) XXX_Unmarshal 

func (m *ActivityEntry) XXX_Unmarshal(b []byte) error

type AddAccountRequest 

type AddAccountRequest struct {
	Account *Account        `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"`
	Limits  *Account_Limits `protobuf:"bytes,2,opt,name=limits,proto3" json:"limits,omitempty"`
}

func (*AddAccountRequest) Descriptor 

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

func (*AddAccountRequest) Equal 

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

func (*AddAccountRequest) GetAccount 

func (m *AddAccountRequest) GetAccount() *Account

func (*AddAccountRequest) GetLimits 

func (m *AddAccountRequest) GetLimits() *Account_Limits

func (*AddAccountRequest) GoString 

func (this *AddAccountRequest) GoString() string

func (*AddAccountRequest) Marshal 

func (m *AddAccountRequest) Marshal() (dAtA []byte, err error)

func (*AddAccountRequest) MarshalJSON 

func (msg *AddAccountRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*AddAccountRequest) MarshalTo 

func (m *AddAccountRequest) MarshalTo(dAtA []byte) (int, error)

func (*AddAccountRequest) MarshalToSizedBuffer 

func (m *AddAccountRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AddAccountRequest) ProtoMessage 

func (*AddAccountRequest) ProtoMessage()

func (*AddAccountRequest) Reset 

func (m *AddAccountRequest) Reset()

func (*AddAccountRequest) Size 

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

func (*AddAccountRequest) String 

func (this *AddAccountRequest) String() string

func (*AddAccountRequest) Unmarshal 

func (m *AddAccountRequest) Unmarshal(dAtA []byte) error

func (*AddAccountRequest) UnmarshalJSON 

func (msg *AddAccountRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*AddAccountRequest) XXX_DiscardUnknown 

func (m *AddAccountRequest) XXX_DiscardUnknown()

func (*AddAccountRequest) XXX_Marshal 

func (m *AddAccountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddAccountRequest) XXX_Merge 

func (m *AddAccountRequest) XXX_Merge(src proto.Message)

func (*AddAccountRequest) XXX_Size 

func (m *AddAccountRequest) XXX_Size() int

func (*AddAccountRequest) XXX_Unmarshal 

func (m *AddAccountRequest) XXX_Unmarshal(b []byte) error

type AddLabelLinkRequest 

type AddLabelLinkRequest struct {
	Labels  *LabelSet `protobuf:"bytes,1,opt,name=labels,proto3" json:"labels,omitempty"`
	Account *Account  `protobuf:"bytes,2,opt,name=account,proto3" json:"account,omitempty"`
	Target  *LabelSet `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
}

func (*AddLabelLinkRequest) Descriptor 

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

func (*AddLabelLinkRequest) Equal 

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

func (*AddLabelLinkRequest) GetAccount 

func (m *AddLabelLinkRequest) GetAccount() *Account

func (*AddLabelLinkRequest) GetLabels 

func (m *AddLabelLinkRequest) GetLabels() *LabelSet

func (*AddLabelLinkRequest) GetTarget 

func (m *AddLabelLinkRequest) GetTarget() *LabelSet

func (*AddLabelLinkRequest) GoString 

func (this *AddLabelLinkRequest) GoString() string

func (*AddLabelLinkRequest) Marshal 

func (m *AddLabelLinkRequest) Marshal() (dAtA []byte, err error)

func (*AddLabelLinkRequest) MarshalJSON 

func (msg *AddLabelLinkRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*AddLabelLinkRequest) MarshalTo 

func (m *AddLabelLinkRequest) MarshalTo(dAtA []byte) (int, error)

func (*AddLabelLinkRequest) MarshalToSizedBuffer 

func (m *AddLabelLinkRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AddLabelLinkRequest) ProtoMessage 

func (*AddLabelLinkRequest) ProtoMessage()

func (*AddLabelLinkRequest) Reset 

func (m *AddLabelLinkRequest) Reset()

func (*AddLabelLinkRequest) Size 

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

func (*AddLabelLinkRequest) String 

func (this *AddLabelLinkRequest) String() string

func (*AddLabelLinkRequest) Unmarshal 

func (m *AddLabelLinkRequest) Unmarshal(dAtA []byte) error

func (*AddLabelLinkRequest) UnmarshalJSON 

func (msg *AddLabelLinkRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*AddLabelLinkRequest) XXX_DiscardUnknown 

func (m *AddLabelLinkRequest) XXX_DiscardUnknown()

func (*AddLabelLinkRequest) XXX_Marshal 

func (m *AddLabelLinkRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddLabelLinkRequest) XXX_Merge 

func (m *AddLabelLinkRequest) XXX_Merge(src proto.Message)

func (*AddLabelLinkRequest) XXX_Size 

func (m *AddLabelLinkRequest) XXX_Size() int

func (*AddLabelLinkRequest) XXX_Unmarshal 

func (m *AddLabelLinkRequest) XXX_Unmarshal(b []byte) error

type Auth 

type Auth struct {
	User     string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
}

func (*Auth) Descriptor 

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

func (*Auth) Equal 

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

func (*Auth) GetPassword 

func (m *Auth) GetPassword() string

func (*Auth) GetUser 

func (m *Auth) GetUser() string

func (*Auth) GoString 

func (this *Auth) GoString() string

func (*Auth) Marshal 

func (m *Auth) Marshal() (dAtA []byte, err error)

func (*Auth) MarshalJSON 

func (msg *Auth) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Auth) MarshalTo 

func (m *Auth) MarshalTo(dAtA []byte) (int, error)

func (*Auth) MarshalToSizedBuffer 

func (m *Auth) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Auth) ProtoMessage 

func (*Auth) ProtoMessage()

func (*Auth) Reset 

func (m *Auth) Reset()

func (*Auth) Size 

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

func (*Auth) String 

func (this *Auth) String() string

func (*Auth) Unmarshal 

func (m *Auth) Unmarshal(dAtA []byte) error

func (*Auth) UnmarshalJSON 

func (msg *Auth) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Auth) XXX_DiscardUnknown 

func (m *Auth) XXX_DiscardUnknown()

func (*Auth) XXX_Marshal 

func (m *Auth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Auth) XXX_Merge 

func (m *Auth) XXX_Merge(src proto.Message)

func (*Auth) XXX_Size 

func (m *Auth) XXX_Size() int

func (*Auth) XXX_Unmarshal 

func (m *Auth) XXX_Unmarshal(b []byte) error

type Capability 

type Capability int32
const (
	CONNECT Capability = 0
	SERVE   Capability = 1
	ACCESS  Capability = 2
	MGMT    Capability = 3
	CONFIG  Capability = 4
)

func (Capability) EnumDescriptor 

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

func (Capability) String 

func (x Capability) String() string

type CentralActivity 

type CentralActivity struct {
	AccountServices []*AccountServices `protobuf:"bytes,1,rep,name=account_services,json=accountServices,proto3" json:"account_services,omitempty"`
	RequestStats    bool               `protobuf:"varint,2,opt,name=request_stats,json=requestStats,proto3" json:"request_stats,omitempty"`
	NewLabelLinks   *LabelLinks        `protobuf:"bytes,3,opt,name=new_label_links,json=newLabelLinks,proto3" json:"new_label_links,omitempty"`
	HubChange       *HubChange         `protobuf:"bytes,4,opt,name=hub_change,json=hubChange,proto3" json:"hub_change,omitempty"`
}

func (*CentralActivity) Descriptor 

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

func (*CentralActivity) Equal 

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

func (*CentralActivity) GetAccountServices 

func (m *CentralActivity) GetAccountServices() []*AccountServices

func (*CentralActivity) GetHubChange 

func (m *CentralActivity) GetHubChange() *HubChange
func (m *CentralActivity) GetNewLabelLinks() *LabelLinks

func (*CentralActivity) GetRequestStats 

func (m *CentralActivity) GetRequestStats() bool

func (*CentralActivity) GoString 

func (this *CentralActivity) GoString() string

func (*CentralActivity) Marshal 

func (m *CentralActivity) Marshal() (dAtA []byte, err error)

func (*CentralActivity) MarshalJSON 

func (msg *CentralActivity) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*CentralActivity) MarshalTo 

func (m *CentralActivity) MarshalTo(dAtA []byte) (int, error)

func (*CentralActivity) MarshalToSizedBuffer 

func (m *CentralActivity) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CentralActivity) ProtoMessage 

func (*CentralActivity) ProtoMessage()

func (*CentralActivity) Reset 

func (m *CentralActivity) Reset()

func (*CentralActivity) Size 

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

func (*CentralActivity) String 

func (this *CentralActivity) String() string

func (*CentralActivity) Unmarshal 

func (m *CentralActivity) Unmarshal(dAtA []byte) error

func (*CentralActivity) UnmarshalJSON 

func (msg *CentralActivity) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*CentralActivity) XXX_DiscardUnknown 

func (m *CentralActivity) XXX_DiscardUnknown()

func (*CentralActivity) XXX_Marshal 

func (m *CentralActivity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CentralActivity) XXX_Merge 

func (m *CentralActivity) XXX_Merge(src proto.Message)

func (*CentralActivity) XXX_Size 

func (m *CentralActivity) XXX_Size() int

func (*CentralActivity) XXX_Unmarshal 

func (m *CentralActivity) XXX_Unmarshal(b []byte) error

type ConfigRequest 

type ConfigRequest struct {
	StableId   *ULID              `protobuf:"bytes,1,opt,name=stable_id,json=stableId,proto3" json:"stable_id,omitempty"`
	InstanceId *ULID              `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	Locations  []*NetworkLocation `protobuf:"bytes,3,rep,name=locations,proto3" json:"locations,omitempty"`
}

func (*ConfigRequest) Descriptor 

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

func (*ConfigRequest) Equal 

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

func (*ConfigRequest) GetInstanceId 

func (m *ConfigRequest) GetInstanceId() *ULID

func (*ConfigRequest) GetLocations 

func (m *ConfigRequest) GetLocations() []*NetworkLocation

func (*ConfigRequest) GetStableId 

func (m *ConfigRequest) GetStableId() *ULID

func (*ConfigRequest) GoString 

func (this *ConfigRequest) GoString() string

func (*ConfigRequest) Marshal 

func (m *ConfigRequest) Marshal() (dAtA []byte, err error)

func (*ConfigRequest) MarshalJSON 

func (msg *ConfigRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ConfigRequest) MarshalTo 

func (m *ConfigRequest) MarshalTo(dAtA []byte) (int, error)

func (*ConfigRequest) MarshalToSizedBuffer 

func (m *ConfigRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ConfigRequest) ProtoMessage 

func (*ConfigRequest) ProtoMessage()

func (*ConfigRequest) Reset 

func (m *ConfigRequest) Reset()

func (*ConfigRequest) Size 

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

func (*ConfigRequest) String 

func (this *ConfigRequest) String() string

func (*ConfigRequest) Unmarshal 

func (m *ConfigRequest) Unmarshal(dAtA []byte) error

func (*ConfigRequest) UnmarshalJSON 

func (msg *ConfigRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*ConfigRequest) XXX_DiscardUnknown 

func (m *ConfigRequest) XXX_DiscardUnknown()

func (*ConfigRequest) XXX_Marshal 

func (m *ConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigRequest) XXX_Merge 

func (m *ConfigRequest) XXX_Merge(src proto.Message)

func (*ConfigRequest) XXX_Size 

func (m *ConfigRequest) XXX_Size() int

func (*ConfigRequest) XXX_Unmarshal 

func (m *ConfigRequest) XXX_Unmarshal(b []byte) error

type ConfigResponse 

type ConfigResponse struct {
	TlsKey      []byte `protobuf:"bytes,1,opt,name=tls_key,json=tlsKey,proto3" json:"tls_key,omitempty"`
	TlsCert     []byte `protobuf:"bytes,2,opt,name=tls_cert,json=tlsCert,proto3" json:"tls_cert,omitempty"`
	TokenPub    []byte `protobuf:"bytes,3,opt,name=token_pub,json=tokenPub,proto3" json:"token_pub,omitempty"`
	S3AccessKey string `protobuf:"bytes,4,opt,name=s3_access_key,json=s3AccessKey,proto3" json:"s3_access_key,omitempty"`
	S3SecretKey string `protobuf:"bytes,5,opt,name=s3_secret_key,json=s3SecretKey,proto3" json:"s3_secret_key,omitempty"`
	S3Bucket    string `protobuf:"bytes,6,opt,name=s3_bucket,json=s3Bucket,proto3" json:"s3_bucket,omitempty"`
	ImageTag    string `protobuf:"bytes,7,opt,name=image_tag,json=imageTag,proto3" json:"image_tag,omitempty"`
}

func (*ConfigResponse) Descriptor 

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

func (*ConfigResponse) Equal 

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

func (*ConfigResponse) GetImageTag 

func (m *ConfigResponse) GetImageTag() string

func (*ConfigResponse) GetS3AccessKey 

func (m *ConfigResponse) GetS3AccessKey() string

func (*ConfigResponse) GetS3Bucket 

func (m *ConfigResponse) GetS3Bucket() string

func (*ConfigResponse) GetS3SecretKey 

func (m *ConfigResponse) GetS3SecretKey() string

func (*ConfigResponse) GetTlsCert 

func (m *ConfigResponse) GetTlsCert() []byte

func (*ConfigResponse) GetTlsKey 

func (m *ConfigResponse) GetTlsKey() []byte

func (*ConfigResponse) GetTokenPub 

func (m *ConfigResponse) GetTokenPub() []byte

func (*ConfigResponse) GoString 

func (this *ConfigResponse) GoString() string

func (*ConfigResponse) Marshal 

func (m *ConfigResponse) Marshal() (dAtA []byte, err error)

func (*ConfigResponse) MarshalJSON 

func (msg *ConfigResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ConfigResponse) MarshalTo 

func (m *ConfigResponse) MarshalTo(dAtA []byte) (int, error)

func (*ConfigResponse) MarshalToSizedBuffer 

func (m *ConfigResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ConfigResponse) ProtoMessage 

func (*ConfigResponse) ProtoMessage()

func (*ConfigResponse) Reset 

func (m *ConfigResponse) Reset()

func (*ConfigResponse) Size 

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

func (*ConfigResponse) String 

func (this *ConfigResponse) String() string

func (*ConfigResponse) Unmarshal 

func (m *ConfigResponse) Unmarshal(dAtA []byte) error

func (*ConfigResponse) UnmarshalJSON 

func (msg *ConfigResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*ConfigResponse) XXX_DiscardUnknown 

func (m *ConfigResponse) XXX_DiscardUnknown()

func (*ConfigResponse) XXX_Marshal 

func (m *ConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigResponse) XXX_Merge 

func (m *ConfigResponse) XXX_Merge(src proto.Message)

func (*ConfigResponse) XXX_Size 

func (m *ConfigResponse) XXX_Size() int

func (*ConfigResponse) XXX_Unmarshal 

func (m *ConfigResponse) XXX_Unmarshal(b []byte) error

type Confirmation 

type Confirmation struct {
	Time        *Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	Status      string     `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Compression string     `protobuf:"bytes,3,opt,name=compression,proto3" json:"compression,omitempty"`
}

func (*Confirmation) Descriptor 

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

func (*Confirmation) Equal 

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

func (*Confirmation) GetCompression 

func (m *Confirmation) GetCompression() string

func (*Confirmation) GetStatus 

func (m *Confirmation) GetStatus() string

func (*Confirmation) GetTime 

func (m *Confirmation) GetTime() *Timestamp

func (*Confirmation) GoString 

func (this *Confirmation) GoString() string

func (*Confirmation) Marshal 

func (m *Confirmation) Marshal() (dAtA []byte, err error)

func (*Confirmation) MarshalJSON 

func (msg *Confirmation) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Confirmation) MarshalTo 

func (m *Confirmation) MarshalTo(dAtA []byte) (int, error)

func (*Confirmation) MarshalToSizedBuffer 

func (m *Confirmation) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Confirmation) ProtoMessage 

func (*Confirmation) ProtoMessage()

func (*Confirmation) Reset 

func (m *Confirmation) Reset()

func (*Confirmation) Size 

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

func (*Confirmation) String 

func (this *Confirmation) String() string

func (*Confirmation) Unmarshal 

func (m *Confirmation) Unmarshal(dAtA []byte) error

func (*Confirmation) UnmarshalJSON 

func (msg *Confirmation) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Confirmation) XXX_DiscardUnknown 

func (m *Confirmation) XXX_DiscardUnknown()

func (*Confirmation) XXX_Marshal 

func (m *Confirmation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Confirmation) XXX_Merge 

func (m *Confirmation) XXX_Merge(src proto.Message)

func (*Confirmation) XXX_Size 

func (m *Confirmation) XXX_Size() int

func (*Confirmation) XXX_Unmarshal 

func (m *Confirmation) XXX_Unmarshal(b []byte) error

type ConnectAck 

type ConnectAck struct {
	ServiceId *ULID `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
}

func (*ConnectAck) Descriptor 

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

func (*ConnectAck) Equal 

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

func (*ConnectAck) GetServiceId 

func (m *ConnectAck) GetServiceId() *ULID

func (*ConnectAck) GoString 

func (this *ConnectAck) GoString() string

func (*ConnectAck) Marshal 

func (m *ConnectAck) Marshal() (dAtA []byte, err error)

func (*ConnectAck) MarshalJSON 

func (msg *ConnectAck) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ConnectAck) MarshalTo 

func (m *ConnectAck) MarshalTo(dAtA []byte) (int, error)

func (*ConnectAck) MarshalToSizedBuffer 

func (m *ConnectAck) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ConnectAck) ProtoMessage 

func (*ConnectAck) ProtoMessage()

func (*ConnectAck) Reset 

func (m *ConnectAck) Reset()

func (*ConnectAck) Size 

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

func (*ConnectAck) String 

func (this *ConnectAck) String() string

func (*ConnectAck) Unmarshal 

func (m *ConnectAck) Unmarshal(dAtA []byte) error

func (*ConnectAck) UnmarshalJSON 

func (msg *ConnectAck) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*ConnectAck) XXX_DiscardUnknown 

func (m *ConnectAck) XXX_DiscardUnknown()

func (*ConnectAck) XXX_Marshal 

func (m *ConnectAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConnectAck) XXX_Merge 

func (m *ConnectAck) XXX_Merge(src proto.Message)

func (*ConnectAck) XXX_Size 

func (m *ConnectAck) XXX_Size() int

func (*ConnectAck) XXX_Unmarshal 

func (m *ConnectAck) XXX_Unmarshal(b []byte) error

type ConnectRequest 

type ConnectRequest struct {
	Target       *LabelSet `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	Type         string    `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	PivotAccount *Account  `protobuf:"bytes,3,opt,name=pivot_account,json=pivotAccount,proto3" json:"pivot_account,omitempty"`
	ProtocolId   string    `protobuf:"bytes,4,opt,name=protocol_id,json=protocolId,proto3" json:"protocol_id,omitempty"`
	SourceAddr   []byte    `protobuf:"bytes,5,opt,name=source_addr,json=sourceAddr,proto3" json:"source_addr,omitempty"`
}

func (*ConnectRequest) Descriptor 

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

func (*ConnectRequest) Equal 

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

func (*ConnectRequest) GetPivotAccount 

func (m *ConnectRequest) GetPivotAccount() *Account

func (*ConnectRequest) GetProtocolId 

func (m *ConnectRequest) GetProtocolId() string

func (*ConnectRequest) GetSourceAddr 

func (m *ConnectRequest) GetSourceAddr() []byte

func (*ConnectRequest) GetTarget 

func (m *ConnectRequest) GetTarget() *LabelSet

func (*ConnectRequest) GetType 

func (m *ConnectRequest) GetType() string

func (*ConnectRequest) GoString 

func (this *ConnectRequest) GoString() string

func (*ConnectRequest) Marshal 

func (m *ConnectRequest) Marshal() (dAtA []byte, err error)

func (*ConnectRequest) MarshalJSON 

func (msg *ConnectRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ConnectRequest) MarshalTo 

func (m *ConnectRequest) MarshalTo(dAtA []byte) (int, error)

func (*ConnectRequest) MarshalToSizedBuffer 

func (m *ConnectRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ConnectRequest) ProtoMessage 

func (*ConnectRequest) ProtoMessage()

func (*ConnectRequest) Reset 

func (m *ConnectRequest) Reset()

func (*ConnectRequest) Size 

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

func (*ConnectRequest) String 

func (this *ConnectRequest) String() string

func (*ConnectRequest) Unmarshal 

func (m *ConnectRequest) Unmarshal(dAtA []byte) error

func (*ConnectRequest) UnmarshalJSON 

func (msg *ConnectRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*ConnectRequest) XXX_DiscardUnknown 

func (m *ConnectRequest) XXX_DiscardUnknown()

func (*ConnectRequest) XXX_Marshal 

func (m *ConnectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConnectRequest) XXX_Merge 

func (m *ConnectRequest) XXX_Merge(src proto.Message)

func (*ConnectRequest) XXX_Size 

func (m *ConnectRequest) XXX_Size() int

func (*ConnectRequest) XXX_Unmarshal 

func (m *ConnectRequest) XXX_Unmarshal(b []byte) error

type ControlManagementClient 

type ControlManagementClient interface {
	Register(ctx context.Context, in *ControlRegister, opts ...grpc.CallOption) (*ControlToken, error)
	AddAccount(ctx context.Context, in *AddAccountRequest, opts ...grpc.CallOption) (*Noop, error)
	AddLabelLink(ctx context.Context, in *AddLabelLinkRequest, opts ...grpc.CallOption) (*Noop, error)
	RemoveLabelLink(ctx context.Context, in *RemoveLabelLinkRequest, opts ...grpc.CallOption) (*Noop, error)
	CreateToken(ctx context.Context, in *CreateTokenRequest, opts ...grpc.CallOption) (*CreateTokenResponse, error)
	IssueHubToken(ctx context.Context, in *Noop, opts ...grpc.CallOption) (*CreateTokenResponse, error)
	GetTokenPublicKey(ctx context.Context, in *Noop, opts ...grpc.CallOption) (*TokenInfo, error)
	ListAccounts(ctx context.Context, in *ListAccountsRequest, opts ...grpc.CallOption) (*ListAccountsResponse, error)
}

ControlManagementClient is the client API for ControlManagement service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewControlManagementClient 

func NewControlManagementClient(cc *grpc.ClientConn) ControlManagementClient

type ControlManagementServer 

type ControlManagementServer interface {
	Register(context.Context, *ControlRegister) (*ControlToken, error)
	AddAccount(context.Context, *AddAccountRequest) (*Noop, error)
	AddLabelLink(context.Context, *AddLabelLinkRequest) (*Noop, error)
	RemoveLabelLink(context.Context, *RemoveLabelLinkRequest) (*Noop, error)
	CreateToken(context.Context, *CreateTokenRequest) (*CreateTokenResponse, error)
	IssueHubToken(context.Context, *Noop) (*CreateTokenResponse, error)
	GetTokenPublicKey(context.Context, *Noop) (*TokenInfo, error)
	ListAccounts(context.Context, *ListAccountsRequest) (*ListAccountsResponse, error)
}

ControlManagementServer is the server API for ControlManagement service.

type ControlRegister 

type ControlRegister struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
}

func (*ControlRegister) Descriptor 

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

func (*ControlRegister) Equal 

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

func (*ControlRegister) GetNamespace 

func (m *ControlRegister) GetNamespace() string

func (*ControlRegister) GoString 

func (this *ControlRegister) GoString() string

func (*ControlRegister) Marshal 

func (m *ControlRegister) Marshal() (dAtA []byte, err error)

func (*ControlRegister) MarshalJSON 

func (msg *ControlRegister) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ControlRegister) MarshalTo 

func (m *ControlRegister) MarshalTo(dAtA []byte) (int, error)

func (*ControlRegister) MarshalToSizedBuffer 

func (m *ControlRegister) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ControlRegister) ProtoMessage 

func (*ControlRegister) ProtoMessage()

func (*ControlRegister) Reset 

func (m *ControlRegister) Reset()

func (*ControlRegister) Size 

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

func (*ControlRegister) String 

func (this *ControlRegister) String() string

func (*ControlRegister) Unmarshal 

func (m *ControlRegister) Unmarshal(dAtA []byte) error

func (*ControlRegister) UnmarshalJSON 

func (msg *ControlRegister) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*ControlRegister) XXX_DiscardUnknown 

func (m *ControlRegister) XXX_DiscardUnknown()

func (*ControlRegister) XXX_Marshal 

func (m *ControlRegister) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ControlRegister) XXX_Merge 

func (m *ControlRegister) XXX_Merge(src proto.Message)

func (*ControlRegister) XXX_Size 

func (m *ControlRegister) XXX_Size() int

func (*ControlRegister) XXX_Unmarshal 

func (m *ControlRegister) XXX_Unmarshal(b []byte) error

type ControlServicesClient 

type ControlServicesClient interface {
	AddService(ctx context.Context, in *ServiceRequest, opts ...grpc.CallOption) (*ServiceResponse, error)
	RemoveService(ctx context.Context, in *ServiceRequest, opts ...grpc.CallOption) (*ServiceResponse, error)
	ListServices(ctx context.Context, in *ListServicesRequest, opts ...grpc.CallOption) (*ListServicesResponse, error)
	FetchConfig(ctx context.Context, in *ConfigRequest, opts ...grpc.CallOption) (*ConfigResponse, error)
	StreamActivity(ctx context.Context, opts ...grpc.CallOption) (ControlServices_StreamActivityClient, error)
	SyncHub(ctx context.Context, in *HubSync, opts ...grpc.CallOption) (*HubSyncResponse, error)
	HubDisconnect(ctx context.Context, in *HubDisconnectRequest, opts ...grpc.CallOption) (*Noop, error)
	AllHubs(ctx context.Context, in *Noop, opts ...grpc.CallOption) (*ListOfHubs, error)
	RequestServiceToken(ctx context.Context, in *ServiceTokenRequest, opts ...grpc.CallOption) (*ServiceTokenResponse, error)
}

ControlServicesClient is the client API for ControlServices service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewControlServicesClient 

func NewControlServicesClient(cc *grpc.ClientConn) ControlServicesClient

type ControlServicesServer 

type ControlServicesServer interface {
	AddService(context.Context, *ServiceRequest) (*ServiceResponse, error)
	RemoveService(context.Context, *ServiceRequest) (*ServiceResponse, error)
	ListServices(context.Context, *ListServicesRequest) (*ListServicesResponse, error)
	FetchConfig(context.Context, *ConfigRequest) (*ConfigResponse, error)
	StreamActivity(ControlServices_StreamActivityServer) error
	SyncHub(context.Context, *HubSync) (*HubSyncResponse, error)
	HubDisconnect(context.Context, *HubDisconnectRequest) (*Noop, error)
	AllHubs(context.Context, *Noop) (*ListOfHubs, error)
	RequestServiceToken(context.Context, *ServiceTokenRequest) (*ServiceTokenResponse, error)
}

ControlServicesServer is the server API for ControlServices service.

type ControlServices_StreamActivityClient 

type ControlServices_StreamActivityClient interface {
	Send(*HubActivity) error
	Recv() (*CentralActivity, error)
	grpc.ClientStream
}

type ControlServices_StreamActivityServer 

type ControlServices_StreamActivityServer interface {
	Send(*CentralActivity) error
	Recv() (*HubActivity, error)
	grpc.ServerStream
}

type ControlToken 

type ControlToken struct {
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
}

func (*ControlToken) Descriptor 

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

func (*ControlToken) Equal 

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

func (*ControlToken) GetToken 

func (m *ControlToken) GetToken() string

func (*ControlToken) GoString 

func (this *ControlToken) GoString() string

func (*ControlToken) Marshal 

func (m *ControlToken) Marshal() (dAtA []byte, err error)

func (*ControlToken) MarshalJSON 

func (msg *ControlToken) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ControlToken) MarshalTo 

func (m *ControlToken) MarshalTo(dAtA []byte) (int, error)

func (*ControlToken) MarshalToSizedBuffer 

func (m *ControlToken) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ControlToken) ProtoMessage 

func (*ControlToken) ProtoMessage()

func (*ControlToken) Reset 

func (m *ControlToken) Reset()

func (*ControlToken) Size 

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

func (*ControlToken) String 

func (this *ControlToken) String() string

func (*ControlToken) Unmarshal 

func (m *ControlToken) Unmarshal(dAtA []byte) error

func (*ControlToken) UnmarshalJSON 

func (msg *ControlToken) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*ControlToken) XXX_DiscardUnknown 

func (m *ControlToken) XXX_DiscardUnknown()

func (*ControlToken) XXX_Marshal 

func (m *ControlToken) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ControlToken) XXX_Merge 

func (m *ControlToken) XXX_Merge(src proto.Message)

func (*ControlToken) XXX_Size 

func (m *ControlToken) XXX_Size() int

func (*ControlToken) XXX_Unmarshal 

func (m *ControlToken) XXX_Unmarshal(b []byte) error

type CreateTokenRequest 

type CreateTokenRequest struct {
	Account       *Account          `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"`
	Capabilities  []TokenCapability `protobuf:"bytes,2,rep,name=capabilities,proto3" json:"capabilities"`
	ValidDuration *Timestamp        `protobuf:"bytes,3,opt,name=valid_duration,json=validDuration,proto3" json:"valid_duration,omitempty"`
}

func (*CreateTokenRequest) Descriptor 

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

func (*CreateTokenRequest) Equal 

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

func (*CreateTokenRequest) GetAccount 

func (m *CreateTokenRequest) GetAccount() *Account

func (*CreateTokenRequest) GetCapabilities 

func (m *CreateTokenRequest) GetCapabilities() []TokenCapability

func (*CreateTokenRequest) GetValidDuration 

func (m *CreateTokenRequest) GetValidDuration() *Timestamp

func (*CreateTokenRequest) GoString 

func (this *CreateTokenRequest) GoString() string

func (*CreateTokenRequest) Marshal 

func (m *CreateTokenRequest) Marshal() (dAtA []byte, err error)

func (*CreateTokenRequest) MarshalJSON 

func (msg *CreateTokenRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*CreateTokenRequest) MarshalTo 

func (m *CreateTokenRequest) MarshalTo(dAtA []byte) (int, error)

func (*CreateTokenRequest) MarshalToSizedBuffer 

func (m *CreateTokenRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateTokenRequest) ProtoMessage 

func (*CreateTokenRequest) ProtoMessage()

func (*CreateTokenRequest) Reset 

func (m *CreateTokenRequest) Reset()

func (*CreateTokenRequest) Size 

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

func (*CreateTokenRequest) String 

func (this *CreateTokenRequest) String() string

func (*CreateTokenRequest) Unmarshal 

func (m *CreateTokenRequest) Unmarshal(dAtA []byte) error

func (*CreateTokenRequest) UnmarshalJSON 

func (msg *CreateTokenRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*CreateTokenRequest) XXX_DiscardUnknown 

func (m *CreateTokenRequest) XXX_DiscardUnknown()

func (*CreateTokenRequest) XXX_Marshal 

func (m *CreateTokenRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateTokenRequest) XXX_Merge 

func (m *CreateTokenRequest) XXX_Merge(src proto.Message)

func (*CreateTokenRequest) XXX_Size 

func (m *CreateTokenRequest) XXX_Size() int

func (*CreateTokenRequest) XXX_Unmarshal 

func (m *CreateTokenRequest) XXX_Unmarshal(b []byte) error

type CreateTokenResponse 

type CreateTokenResponse struct {
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
}

func (*CreateTokenResponse) Descriptor 

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

func (*CreateTokenResponse) Equal 

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

func (*CreateTokenResponse) GetToken 

func (m *CreateTokenResponse) GetToken() string

func (*CreateTokenResponse) GoString 

func (this *CreateTokenResponse) GoString() string

func (*CreateTokenResponse) Marshal 

func (m *CreateTokenResponse) Marshal() (dAtA []byte, err error)

func (*CreateTokenResponse) MarshalJSON 

func (msg *CreateTokenResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*CreateTokenResponse) MarshalTo 

func (m *CreateTokenResponse) MarshalTo(dAtA []byte) (int, error)

func (*CreateTokenResponse) MarshalToSizedBuffer 

func (m *CreateTokenResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateTokenResponse) ProtoMessage 

func (*CreateTokenResponse) ProtoMessage()

func (*CreateTokenResponse) Reset 

func (m *CreateTokenResponse) Reset()

func (*CreateTokenResponse) Size 

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

func (*CreateTokenResponse) String 

func (this *CreateTokenResponse) String() string

func (*CreateTokenResponse) Unmarshal 

func (m *CreateTokenResponse) Unmarshal(dAtA []byte) error

func (*CreateTokenResponse) UnmarshalJSON 

func (msg *CreateTokenResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*CreateTokenResponse) XXX_DiscardUnknown 

func (m *CreateTokenResponse) XXX_DiscardUnknown()

func (*CreateTokenResponse) XXX_Marshal 

func (m *CreateTokenResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateTokenResponse) XXX_Merge 

func (m *CreateTokenResponse) XXX_Merge(src proto.Message)

func (*CreateTokenResponse) XXX_Size 

func (m *CreateTokenResponse) XXX_Size() int

func (*CreateTokenResponse) XXX_Unmarshal 

func (m *CreateTokenResponse) XXX_Unmarshal(b []byte) error

type EdgeServicesClient 

type EdgeServicesClient interface {
	LookupEndpoints(ctx context.Context, in *LookupEndpointsRequest, opts ...grpc.CallOption) (*LookupEndpointsResponse, error)
	ResolveLabelLink(ctx context.Context, in *ResolveLabelLinkRequest, opts ...grpc.CallOption) (*ResolveLabelLinkResponse, error)
}

EdgeServicesClient is the client API for EdgeServices service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewEdgeServicesClient 

func NewEdgeServicesClient(cc *grpc.ClientConn) EdgeServicesClient

type EdgeServicesServer 

type EdgeServicesServer interface {
	LookupEndpoints(context.Context, *LookupEndpointsRequest) (*LookupEndpointsResponse, error)
	ResolveLabelLink(context.Context, *ResolveLabelLinkRequest) (*ResolveLabelLinkResponse, error)
}

EdgeServicesServer is the server API for EdgeServices service.

type FlowRecord 

type FlowRecord struct {
	Agent    *FlowRecord_AgentConnection `protobuf:"bytes,1,opt,name=agent,proto3" json:"agent,omitempty"`
	Stream   *FlowStream                 `protobuf:"bytes,2,opt,name=stream,proto3" json:"stream,omitempty"`
	HubStats *FlowRecord_HubStats        `protobuf:"bytes,3,opt,name=hub_stats,json=hubStats,proto3" json:"hub_stats,omitempty"`
}

func (*FlowRecord) Descriptor 

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

func (*FlowRecord) Equal 

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

func (*FlowRecord) GetAgent 

func (m *FlowRecord) GetAgent() *FlowRecord_AgentConnection

func (*FlowRecord) GetHubStats 

func (m *FlowRecord) GetHubStats() *FlowRecord_HubStats

func (*FlowRecord) GetStream 

func (m *FlowRecord) GetStream() *FlowStream

func (*FlowRecord) GoString 

func (this *FlowRecord) GoString() string

func (*FlowRecord) Marshal 

func (m *FlowRecord) Marshal() (dAtA []byte, err error)

func (*FlowRecord) MarshalJSON 

func (msg *FlowRecord) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*FlowRecord) MarshalTo 

func (m *FlowRecord) MarshalTo(dAtA []byte) (int, error)

func (*FlowRecord) MarshalToSizedBuffer 

func (m *FlowRecord) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FlowRecord) ProtoMessage 

func (*FlowRecord) ProtoMessage()

func (*FlowRecord) Reset 

func (m *FlowRecord) Reset()

func (*FlowRecord) Size 

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

func (*FlowRecord) String 

func (this *FlowRecord) String() string

func (*FlowRecord) Unmarshal 

func (m *FlowRecord) Unmarshal(dAtA []byte) error

func (*FlowRecord) UnmarshalJSON 

func (msg *FlowRecord) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*FlowRecord) XXX_DiscardUnknown 

func (m *FlowRecord) XXX_DiscardUnknown()

func (*FlowRecord) XXX_Marshal 

func (m *FlowRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlowRecord) XXX_Merge 

func (m *FlowRecord) XXX_Merge(src proto.Message)

func (*FlowRecord) XXX_Size 

func (m *FlowRecord) XXX_Size() int

func (*FlowRecord) XXX_Unmarshal 

func (m *FlowRecord) XXX_Unmarshal(b []byte) error

type FlowRecord_AgentConnection 

type FlowRecord_AgentConnection struct {
	HubId         *ULID      `protobuf:"bytes,1,opt,name=hub_id,json=hubId,proto3" json:"hub_id,omitempty"`
	AgentId       *ULID      `protobuf:"bytes,2,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	Account       *Account   `protobuf:"bytes,3,opt,name=account,proto3" json:"account,omitempty"`
	StartedAt     *Timestamp `protobuf:"bytes,10,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	EndedAt       *Timestamp `protobuf:"bytes,11,opt,name=ended_at,json=endedAt,proto3" json:"ended_at,omitempty"`
	NumServices   int32      `protobuf:"varint,12,opt,name=num_services,json=numServices,proto3" json:"num_services,omitempty"`
	ActiveStreams int64      `protobuf:"varint,13,opt,name=active_streams,json=activeStreams,proto3" json:"active_streams,omitempty"`
}

func (*FlowRecord_AgentConnection) Descriptor 

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

func (*FlowRecord_AgentConnection) Equal 

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

func (*FlowRecord_AgentConnection) GetAccount 

func (m *FlowRecord_AgentConnection) GetAccount() *Account

func (*FlowRecord_AgentConnection) GetActiveStreams 

func (m *FlowRecord_AgentConnection) GetActiveStreams() int64

func (*FlowRecord_AgentConnection) GetAgentId 

func (m *FlowRecord_AgentConnection) GetAgentId() *ULID

func (*FlowRecord_AgentConnection) GetEndedAt 

func (m *FlowRecord_AgentConnection) GetEndedAt() *Timestamp

func (*FlowRecord_AgentConnection) GetHubId 

func (m *FlowRecord_AgentConnection) GetHubId() *ULID

func (*FlowRecord_AgentConnection) GetNumServices 

func (m *FlowRecord_AgentConnection) GetNumServices() int32

func (*FlowRecord_AgentConnection) GetStartedAt 

func (m *FlowRecord_AgentConnection) GetStartedAt() *Timestamp

func (*FlowRecord_AgentConnection) GoString 

func (this *FlowRecord_AgentConnection) GoString() string

func (*FlowRecord_AgentConnection) Marshal 

func (m *FlowRecord_AgentConnection) Marshal() (dAtA []byte, err error)

func (*FlowRecord_AgentConnection) MarshalJSON 

func (msg *FlowRecord_AgentConnection) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*FlowRecord_AgentConnection) MarshalTo 

func (m *FlowRecord_AgentConnection) MarshalTo(dAtA []byte) (int, error)

func (*FlowRecord_AgentConnection) MarshalToSizedBuffer 

func (m *FlowRecord_AgentConnection) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FlowRecord_AgentConnection) ProtoMessage 

func (*FlowRecord_AgentConnection) ProtoMessage()

func (*FlowRecord_AgentConnection) Reset 

func (m *FlowRecord_AgentConnection) Reset()

func (*FlowRecord_AgentConnection) Size 

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

func (*FlowRecord_AgentConnection) String 

func (this *FlowRecord_AgentConnection) String() string

func (*FlowRecord_AgentConnection) Unmarshal 

func (m *FlowRecord_AgentConnection) Unmarshal(dAtA []byte) error

func (*FlowRecord_AgentConnection) UnmarshalJSON 

func (msg *FlowRecord_AgentConnection) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*FlowRecord_AgentConnection) XXX_DiscardUnknown 

func (m *FlowRecord_AgentConnection) XXX_DiscardUnknown()

func (*FlowRecord_AgentConnection) XXX_Marshal 

func (m *FlowRecord_AgentConnection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlowRecord_AgentConnection) XXX_Merge 

func (m *FlowRecord_AgentConnection) XXX_Merge(src proto.Message)

func (*FlowRecord_AgentConnection) XXX_Size 

func (m *FlowRecord_AgentConnection) XXX_Size() int

func (*FlowRecord_AgentConnection) XXX_Unmarshal 

func (m *FlowRecord_AgentConnection) XXX_Unmarshal(b []byte) error

type FlowRecord_HubStats 

type FlowRecord_HubStats struct {
	HubId        *ULID `protobuf:"bytes,1,opt,name=hub_id,json=hubId,proto3" json:"hub_id,omitempty"`
	ActiveAgents int64 `protobuf:"varint,2,opt,name=active_agents,json=activeAgents,proto3" json:"active_agents,omitempty"`
	TotalAgents  int64 `protobuf:"varint,3,opt,name=total_agents,json=totalAgents,proto3" json:"total_agents,omitempty"`
	Services     int64 `protobuf:"varint,4,opt,name=services,proto3" json:"services,omitempty"`
}

func (*FlowRecord_HubStats) Descriptor 

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

func (*FlowRecord_HubStats) Equal 

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

func (*FlowRecord_HubStats) GetActiveAgents 

func (m *FlowRecord_HubStats) GetActiveAgents() int64

func (*FlowRecord_HubStats) GetHubId 

func (m *FlowRecord_HubStats) GetHubId() *ULID

func (*FlowRecord_HubStats) GetServices 

func (m *FlowRecord_HubStats) GetServices() int64

func (*FlowRecord_HubStats) GetTotalAgents 

func (m *FlowRecord_HubStats) GetTotalAgents() int64

func (*FlowRecord_HubStats) GoString 

func (this *FlowRecord_HubStats) GoString() string

func (*FlowRecord_HubStats) Marshal 

func (m *FlowRecord_HubStats) Marshal() (dAtA []byte, err error)

func (*FlowRecord_HubStats) MarshalJSON 

func (msg *FlowRecord_HubStats) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*FlowRecord_HubStats) MarshalTo 

func (m *FlowRecord_HubStats) MarshalTo(dAtA []byte) (int, error)

func (*FlowRecord_HubStats) MarshalToSizedBuffer 

func (m *FlowRecord_HubStats) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FlowRecord_HubStats) ProtoMessage 

func (*FlowRecord_HubStats) ProtoMessage()

func (*FlowRecord_HubStats) Reset 

func (m *FlowRecord_HubStats) Reset()

func (*FlowRecord_HubStats) Size 

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

func (*FlowRecord_HubStats) String 

func (this *FlowRecord_HubStats) String() string

func (*FlowRecord_HubStats) Unmarshal 

func (m *FlowRecord_HubStats) Unmarshal(dAtA []byte) error

func (*FlowRecord_HubStats) UnmarshalJSON 

func (msg *FlowRecord_HubStats) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*FlowRecord_HubStats) XXX_DiscardUnknown 

func (m *FlowRecord_HubStats) XXX_DiscardUnknown()

func (*FlowRecord_HubStats) XXX_Marshal 

func (m *FlowRecord_HubStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlowRecord_HubStats) XXX_Merge 

func (m *FlowRecord_HubStats) XXX_Merge(src proto.Message)

func (*FlowRecord_HubStats) XXX_Size 

func (m *FlowRecord_HubStats) XXX_Size() int

func (*FlowRecord_HubStats) XXX_Unmarshal 

func (m *FlowRecord_HubStats) XXX_Unmarshal(b []byte) error

type FlowStream 

type FlowStream struct {
	FlowId      *ULID      `protobuf:"bytes,1,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	HubId       *ULID      `protobuf:"bytes,2,opt,name=hub_id,json=hubId,proto3" json:"hub_id,omitempty"`
	AgentId     *ULID      `protobuf:"bytes,3,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	ServiceId   *ULID      `protobuf:"bytes,4,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	Account     *Account   `protobuf:"bytes,5,opt,name=account,proto3" json:"account,omitempty"`
	Labels      *LabelSet  `protobuf:"bytes,6,opt,name=labels,proto3" json:"labels,omitempty"`
	StartedAt   *Timestamp `protobuf:"bytes,10,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	EndedAt     *Timestamp `protobuf:"bytes,11,opt,name=ended_at,json=endedAt,proto3" json:"ended_at,omitempty"`
	NumMessages int64      `protobuf:"varint,12,opt,name=num_messages,json=numMessages,proto3" json:"num_messages,omitempty"`
	NumBytes    int64      `protobuf:"varint,13,opt,name=num_bytes,json=numBytes,proto3" json:"num_bytes,omitempty"`
	Duration    int64      `protobuf:"varint,14,opt,name=duration,proto3" json:"duration,omitempty"`
}

func (*FlowStream) Descriptor 

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

func (*FlowStream) Equal 

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

func (*FlowStream) GetAccount 

func (m *FlowStream) GetAccount() *Account

func (*FlowStream) GetAgentId 

func (m *FlowStream) GetAgentId() *ULID

func (*FlowStream) GetDuration 

func (m *FlowStream) GetDuration() int64

func (*FlowStream) GetEndedAt 

func (m *FlowStream) GetEndedAt() *Timestamp

func (*FlowStream) GetFlowId 

func (m *FlowStream) GetFlowId() *ULID

func (*FlowStream) GetHubId 

func (m *FlowStream) GetHubId() *ULID

func (*FlowStream) GetLabels 

func (m *FlowStream) GetLabels() *LabelSet

func (*FlowStream) GetNumBytes 

func (m *FlowStream) GetNumBytes() int64

func (*FlowStream) GetNumMessages 

func (m *FlowStream) GetNumMessages() int64

func (*FlowStream) GetServiceId 

func (m *FlowStream) GetServiceId() *ULID

func (*FlowStream) GetStartedAt 

func (m *FlowStream) GetStartedAt() *Timestamp

func (*FlowStream) GoString 

func (this *FlowStream) GoString() string

func (*FlowStream) Marshal 

func (m *FlowStream) Marshal() (dAtA []byte, err error)

func (*FlowStream) MarshalJSON 

func (msg *FlowStream) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*FlowStream) MarshalTo 

func (m *FlowStream) MarshalTo(dAtA []byte) (int, error)

func (*FlowStream) MarshalToSizedBuffer 

func (m *FlowStream) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FlowStream) ProtoMessage 

func (*FlowStream) ProtoMessage()

func (*FlowStream) Reset 

func (m *FlowStream) Reset()

func (*FlowStream) Size 

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

func (*FlowStream) String 

func (this *FlowStream) String() string

func (*FlowStream) Unmarshal 

func (m *FlowStream) Unmarshal(dAtA []byte) error

func (*FlowStream) UnmarshalJSON 

func (msg *FlowStream) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*FlowStream) XXX_DiscardUnknown 

func (m *FlowStream) XXX_DiscardUnknown()

func (*FlowStream) XXX_Marshal 

func (m *FlowStream) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlowStream) XXX_Merge 

func (m *FlowStream) XXX_Merge(src proto.Message)

func (*FlowStream) XXX_Size 

func (m *FlowStream) XXX_Size() int

func (*FlowStream) XXX_Unmarshal 

func (m *FlowStream) XXX_Unmarshal(b []byte) error

type FlowTopReporterClient 

type FlowTopReporterClient interface {
	CurrentFlowTop(ctx context.Context, in *FlowTopRequest, opts ...grpc.CallOption) (*FlowTopSnapshot, error)
}

FlowTopReporterClient is the client API for FlowTopReporter service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewFlowTopReporterClient 

func NewFlowTopReporterClient(cc *grpc.ClientConn) FlowTopReporterClient

type FlowTopReporterServer 

type FlowTopReporterServer interface {
	CurrentFlowTop(context.Context, *FlowTopRequest) (*FlowTopSnapshot, error)
}

FlowTopReporterServer is the server API for FlowTopReporter service.

type FlowTopRequest 

type FlowTopRequest struct {
	MaxRecords int32 `protobuf:"varint,1,opt,name=max_records,json=maxRecords,proto3" json:"max_records,omitempty"`
}

func (*FlowTopRequest) Descriptor 

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

func (*FlowTopRequest) Equal 

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

func (*FlowTopRequest) GetMaxRecords 

func (m *FlowTopRequest) GetMaxRecords() int32

func (*FlowTopRequest) GoString 

func (this *FlowTopRequest) GoString() string

func (*FlowTopRequest) Marshal 

func (m *FlowTopRequest) Marshal() (dAtA []byte, err error)

func (*FlowTopRequest) MarshalJSON 

func (msg *FlowTopRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*FlowTopRequest) MarshalTo 

func (m *FlowTopRequest) MarshalTo(dAtA []byte) (int, error)

func (*FlowTopRequest) MarshalToSizedBuffer 

func (m *FlowTopRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FlowTopRequest) ProtoMessage 

func (*FlowTopRequest) ProtoMessage()

func (*FlowTopRequest) Reset 

func (m *FlowTopRequest) Reset()

func (*FlowTopRequest) Size 

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

func (*FlowTopRequest) String 

func (this *FlowTopRequest) String() string

func (*FlowTopRequest) Unmarshal 

func (m *FlowTopRequest) Unmarshal(dAtA []byte) error

func (*FlowTopRequest) UnmarshalJSON 

func (msg *FlowTopRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*FlowTopRequest) XXX_DiscardUnknown 

func (m *FlowTopRequest) XXX_DiscardUnknown()

func (*FlowTopRequest) XXX_Marshal 

func (m *FlowTopRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlowTopRequest) XXX_Merge 

func (m *FlowTopRequest) XXX_Merge(src proto.Message)

func (*FlowTopRequest) XXX_Size 

func (m *FlowTopRequest) XXX_Size() int

func (*FlowTopRequest) XXX_Unmarshal 

func (m *FlowTopRequest) XXX_Unmarshal(b []byte) error

type FlowTopSnapshot 

type FlowTopSnapshot struct {
	Records []*FlowStream `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
}

func (*FlowTopSnapshot) Descriptor 

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

func (*FlowTopSnapshot) Equal 

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

func (*FlowTopSnapshot) GetRecords 

func (m *FlowTopSnapshot) GetRecords() []*FlowStream

func (*FlowTopSnapshot) GoString 

func (this *FlowTopSnapshot) GoString() string

func (*FlowTopSnapshot) Marshal 

func (m *FlowTopSnapshot) Marshal() (dAtA []byte, err error)

func (*FlowTopSnapshot) MarshalJSON 

func (msg *FlowTopSnapshot) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*FlowTopSnapshot) MarshalTo 

func (m *FlowTopSnapshot) MarshalTo(dAtA []byte) (int, error)

func (*FlowTopSnapshot) MarshalToSizedBuffer 

func (m *FlowTopSnapshot) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FlowTopSnapshot) ProtoMessage 

func (*FlowTopSnapshot) ProtoMessage()

func (*FlowTopSnapshot) Reset 

func (m *FlowTopSnapshot) Reset()

func (*FlowTopSnapshot) Size 

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

func (*FlowTopSnapshot) String 

func (this *FlowTopSnapshot) String() string

func (*FlowTopSnapshot) Unmarshal 

func (m *FlowTopSnapshot) Unmarshal(dAtA []byte) error

func (*FlowTopSnapshot) UnmarshalJSON 

func (msg *FlowTopSnapshot) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*FlowTopSnapshot) XXX_DiscardUnknown 

func (m *FlowTopSnapshot) XXX_DiscardUnknown()

func (*FlowTopSnapshot) XXX_Marshal 

func (m *FlowTopSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlowTopSnapshot) XXX_Merge 

func (m *FlowTopSnapshot) XXX_Merge(src proto.Message)

func (*FlowTopSnapshot) XXX_Size 

func (m *FlowTopSnapshot) XXX_Size() int

func (*FlowTopSnapshot) XXX_Unmarshal 

func (m *FlowTopSnapshot) XXX_Unmarshal(b []byte) error
type Header struct {
	Name  string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value []string `protobuf:"bytes,2,rep,name=value,proto3" json:"value,omitempty"`
}

func (*Header) Descriptor 

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

func (*Header) Equal 

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

func (*Header) GetName 

func (m *Header) GetName() string

func (*Header) GetValue 

func (m *Header) GetValue() []string

func (*Header) GoString 

func (this *Header) GoString() string

func (*Header) Marshal 

func (m *Header) Marshal() (dAtA []byte, err error)

func (*Header) MarshalJSON 

func (msg *Header) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Header) MarshalTo 

func (m *Header) MarshalTo(dAtA []byte) (int, error)

func (*Header) MarshalToSizedBuffer 

func (m *Header) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Header) ProtoMessage 

func (*Header) ProtoMessage()

func (*Header) Reset 

func (m *Header) Reset()

func (*Header) Size 

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

func (*Header) String 

func (this *Header) String() string

func (*Header) Unmarshal 

func (m *Header) Unmarshal(dAtA []byte) error

func (*Header) UnmarshalJSON 

func (msg *Header) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Header) XXX_DiscardUnknown 

func (m *Header) XXX_DiscardUnknown()

func (*Header) XXX_Marshal 

func (m *Header) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Header) XXX_Merge 

func (m *Header) XXX_Merge(src proto.Message)

func (*Header) XXX_Size 

func (m *Header) XXX_Size() int

func (*Header) XXX_Unmarshal 

func (m *Header) XXX_Unmarshal(b []byte) error

type Headers 

type Headers struct {
	Headers []*KVPair `protobuf:"bytes,1,rep,name=headers,proto3" json:"headers,omitempty"`
}

func (*Headers) Descriptor 

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

func (*Headers) Equal 

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

func (*Headers) GetHeaders 

func (m *Headers) GetHeaders() []*KVPair

func (*Headers) GoString 

func (this *Headers) GoString() string

func (*Headers) Marshal 

func (m *Headers) Marshal() (dAtA []byte, err error)

func (*Headers) MarshalJSON 

func (msg *Headers) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Headers) MarshalTo 

func (m *Headers) MarshalTo(dAtA []byte) (int, error)

func (*Headers) MarshalToSizedBuffer 

func (m *Headers) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Headers) ProtoMessage 

func (*Headers) ProtoMessage()

func (*Headers) Reset 

func (m *Headers) Reset()

func (*Headers) Size 

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

func (*Headers) String 

func (this *Headers) String() string

func (*Headers) Unmarshal 

func (m *Headers) Unmarshal(dAtA []byte) error

func (*Headers) UnmarshalJSON 

func (msg *Headers) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Headers) XXX_DiscardUnknown 

func (m *Headers) XXX_DiscardUnknown()

func (*Headers) XXX_Marshal 

func (m *Headers) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Headers) XXX_Merge 

func (m *Headers) XXX_Merge(src proto.Message)

func (*Headers) XXX_Size 

func (m *Headers) XXX_Size() int

func (*Headers) XXX_Unmarshal 

func (m *Headers) XXX_Unmarshal(b []byte) error

type HubActivity 

type HubActivity struct {
	HubReg *HubActivity_HubRegistration `protobuf:"bytes,1,opt,name=hub_reg,json=hubReg,proto3" json:"hub_reg,omitempty"`
	SentAt *Timestamp                   `protobuf:"bytes,2,opt,name=sent_at,json=sentAt,proto3" json:"sent_at,omitempty"`
	Stats  *HubActivity_HubStats        `protobuf:"bytes,3,opt,name=stats,proto3" json:"stats,omitempty"`
	Flow   []*FlowRecord                `protobuf:"bytes,4,rep,name=flow,proto3" json:"flow,omitempty"`
}

func (*HubActivity) Descriptor 

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

func (*HubActivity) Equal 

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

func (*HubActivity) GetFlow 

func (m *HubActivity) GetFlow() []*FlowRecord

func (*HubActivity) GetHubReg 

func (m *HubActivity) GetHubReg() *HubActivity_HubRegistration

func (*HubActivity) GetSentAt 

func (m *HubActivity) GetSentAt() *Timestamp

func (*HubActivity) GetStats 

func (m *HubActivity) GetStats() *HubActivity_HubStats

func (*HubActivity) GoString 

func (this *HubActivity) GoString() string

func (*HubActivity) Marshal 

func (m *HubActivity) Marshal() (dAtA []byte, err error)

func (*HubActivity) MarshalJSON 

func (msg *HubActivity) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*HubActivity) MarshalTo 

func (m *HubActivity) MarshalTo(dAtA []byte) (int, error)

func (*HubActivity) MarshalToSizedBuffer 

func (m *HubActivity) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HubActivity) ProtoMessage 

func (*HubActivity) ProtoMessage()

func (*HubActivity) Reset 

func (m *HubActivity) Reset()

func (*HubActivity) Size 

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

func (*HubActivity) String 

func (this *HubActivity) String() string

func (*HubActivity) Unmarshal 

func (m *HubActivity) Unmarshal(dAtA []byte) error

func (*HubActivity) UnmarshalJSON 

func (msg *HubActivity) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*HubActivity) XXX_DiscardUnknown 

func (m *HubActivity) XXX_DiscardUnknown()

func (*HubActivity) XXX_Marshal 

func (m *HubActivity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HubActivity) XXX_Merge 

func (m *HubActivity) XXX_Merge(src proto.Message)

func (*HubActivity) XXX_Size 

func (m *HubActivity) XXX_Size() int

func (*HubActivity) XXX_Unmarshal 

func (m *HubActivity) XXX_Unmarshal(b []byte) error

type HubActivity_HubRegistration 

type HubActivity_HubRegistration struct {
	Hub       *ULID              `protobuf:"bytes,1,opt,name=hub,proto3" json:"hub,omitempty"`
	StableHub *ULID              `protobuf:"bytes,2,opt,name=stable_hub,json=stableHub,proto3" json:"stable_hub,omitempty"`
	Locations []*NetworkLocation `protobuf:"bytes,3,rep,name=locations,proto3" json:"locations,omitempty"`
}

func (*HubActivity_HubRegistration) Descriptor 

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

func (*HubActivity_HubRegistration) Equal 

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

func (*HubActivity_HubRegistration) GetHub 

func (m *HubActivity_HubRegistration) GetHub() *ULID

func (*HubActivity_HubRegistration) GetLocations 

func (m *HubActivity_HubRegistration) GetLocations() []*NetworkLocation

func (*HubActivity_HubRegistration) GetStableHub 

func (m *HubActivity_HubRegistration) GetStableHub() *ULID

func (*HubActivity_HubRegistration) GoString 

func (this *HubActivity_HubRegistration) GoString() string

func (*HubActivity_HubRegistration) Marshal 

func (m *HubActivity_HubRegistration) Marshal() (dAtA []byte, err error)

func (*HubActivity_HubRegistration) MarshalJSON 

func (msg *HubActivity_HubRegistration) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*HubActivity_HubRegistration) MarshalTo 

func (m *HubActivity_HubRegistration) MarshalTo(dAtA []byte) (int, error)

func (*HubActivity_HubRegistration) MarshalToSizedBuffer 

func (m *HubActivity_HubRegistration) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HubActivity_HubRegistration) ProtoMessage 

func (*HubActivity_HubRegistration) ProtoMessage()

func (*HubActivity_HubRegistration) Reset 

func (m *HubActivity_HubRegistration) Reset()

func (*HubActivity_HubRegistration) Size 

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

func (*HubActivity_HubRegistration) String 

func (this *HubActivity_HubRegistration) String() string

func (*HubActivity_HubRegistration) Unmarshal 

func (m *HubActivity_HubRegistration) Unmarshal(dAtA []byte) error

func (*HubActivity_HubRegistration) UnmarshalJSON 

func (msg *HubActivity_HubRegistration) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*HubActivity_HubRegistration) XXX_DiscardUnknown 

func (m *HubActivity_HubRegistration) XXX_DiscardUnknown()

func (*HubActivity_HubRegistration) XXX_Marshal 

func (m *HubActivity_HubRegistration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HubActivity_HubRegistration) XXX_Merge 

func (m *HubActivity_HubRegistration) XXX_Merge(src proto.Message)

func (*HubActivity_HubRegistration) XXX_Size 

func (m *HubActivity_HubRegistration) XXX_Size() int

func (*HubActivity_HubRegistration) XXX_Unmarshal 

func (m *HubActivity_HubRegistration) XXX_Unmarshal(b []byte) error

type HubActivity_HubStats 

type HubActivity_HubStats struct {
	AgentConnections     int64      `protobuf:"varint,1,opt,name=agent_connections,json=agentConnections,proto3" json:"agent_connections,omitempty"`
	AccountsSeen         int64      `protobuf:"varint,2,opt,name=accounts_seen,json=accountsSeen,proto3" json:"accounts_seen,omitempty"`
	AccountsCached       int64      `protobuf:"varint,3,opt,name=accounts_cached,json=accountsCached,proto3" json:"accounts_cached,omitempty"`
	CachedBytes          int64      `protobuf:"varint,4,opt,name=cached_bytes,json=cachedBytes,proto3" json:"cached_bytes,omitempty"`
	LastSuccessfulUpdate *Timestamp `protobuf:"bytes,5,opt,name=last_successful_update,json=lastSuccessfulUpdate,proto3" json:"last_successful_update,omitempty"`
	LastAttemptedUpdate  *Timestamp `protobuf:"bytes,6,opt,name=last_attempted_update,json=lastAttemptedUpdate,proto3" json:"last_attempted_update,omitempty"`
}

func (*HubActivity_HubStats) Descriptor 

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

func (*HubActivity_HubStats) Equal 

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

func (*HubActivity_HubStats) GetAccountsCached 

func (m *HubActivity_HubStats) GetAccountsCached() int64

func (*HubActivity_HubStats) GetAccountsSeen 

func (m *HubActivity_HubStats) GetAccountsSeen() int64

func (*HubActivity_HubStats) GetAgentConnections 

func (m *HubActivity_HubStats) GetAgentConnections() int64

func (*HubActivity_HubStats) GetCachedBytes 

func (m *HubActivity_HubStats) GetCachedBytes() int64

func (*HubActivity_HubStats) GetLastAttemptedUpdate 

func (m *HubActivity_HubStats) GetLastAttemptedUpdate() *Timestamp

func (*HubActivity_HubStats) GetLastSuccessfulUpdate 

func (m *HubActivity_HubStats) GetLastSuccessfulUpdate() *Timestamp

func (*HubActivity_HubStats) GoString 

func (this *HubActivity_HubStats) GoString() string

func (*HubActivity_HubStats) Marshal 

func (m *HubActivity_HubStats) Marshal() (dAtA []byte, err error)

func (*HubActivity_HubStats) MarshalJSON 

func (msg *HubActivity_HubStats) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*HubActivity_HubStats) MarshalTo 

func (m *HubActivity_HubStats) MarshalTo(dAtA []byte) (int, error)

func (*HubActivity_HubStats) MarshalToSizedBuffer 

func (m *HubActivity_HubStats) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HubActivity_HubStats) ProtoMessage 

func (*HubActivity_HubStats) ProtoMessage()

func (*HubActivity_HubStats) Reset 

func (m *HubActivity_HubStats) Reset()

func (*HubActivity_HubStats) Size 

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

func (*HubActivity_HubStats) String 

func (this *HubActivity_HubStats) String() string

func (*HubActivity_HubStats) Unmarshal 

func (m *HubActivity_HubStats) Unmarshal(dAtA []byte) error

func (*HubActivity_HubStats) UnmarshalJSON 

func (msg *HubActivity_HubStats) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*HubActivity_HubStats) XXX_DiscardUnknown 

func (m *HubActivity_HubStats) XXX_DiscardUnknown()

func (*HubActivity_HubStats) XXX_Marshal 

func (m *HubActivity_HubStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HubActivity_HubStats) XXX_Merge 

func (m *HubActivity_HubStats) XXX_Merge(src proto.Message)

func (*HubActivity_HubStats) XXX_Size 

func (m *HubActivity_HubStats) XXX_Size() int

func (*HubActivity_HubStats) XXX_Unmarshal 

func (m *HubActivity_HubStats) XXX_Unmarshal(b []byte) error

type HubChange 

type HubChange struct {
	OldId *ULID `protobuf:"bytes,1,opt,name=old_id,json=oldId,proto3" json:"old_id,omitempty"`
	NewId *ULID `protobuf:"bytes,2,opt,name=new_id,json=newId,proto3" json:"new_id,omitempty"`
}

func (*HubChange) Descriptor 

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

func (*HubChange) Equal 

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

func (*HubChange) GetNewId 

func (m *HubChange) GetNewId() *ULID

func (*HubChange) GetOldId 

func (m *HubChange) GetOldId() *ULID

func (*HubChange) GoString 

func (this *HubChange) GoString() string

func (*HubChange) Marshal 

func (m *HubChange) Marshal() (dAtA []byte, err error)

func (*HubChange) MarshalJSON 

func (msg *HubChange) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*HubChange) MarshalTo 

func (m *HubChange) MarshalTo(dAtA []byte) (int, error)

func (*HubChange) MarshalToSizedBuffer 

func (m *HubChange) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HubChange) ProtoMessage 

func (*HubChange) ProtoMessage()

func (*HubChange) Reset 

func (m *HubChange) Reset()

func (*HubChange) Size 

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

func (*HubChange) String 

func (this *HubChange) String() string

func (*HubChange) Unmarshal 

func (m *HubChange) Unmarshal(dAtA []byte) error

func (*HubChange) UnmarshalJSON 

func (msg *HubChange) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*HubChange) XXX_DiscardUnknown 

func (m *HubChange) XXX_DiscardUnknown()

func (*HubChange) XXX_Marshal 

func (m *HubChange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HubChange) XXX_Merge 

func (m *HubChange) XXX_Merge(src proto.Message)

func (*HubChange) XXX_Size 

func (m *HubChange) XXX_Size() int

func (*HubChange) XXX_Unmarshal 

func (m *HubChange) XXX_Unmarshal(b []byte) error

type HubDisconnectRequest 

type HubDisconnectRequest struct {
	StableId   *ULID `protobuf:"bytes,1,opt,name=stable_id,json=stableId,proto3" json:"stable_id,omitempty"`
	InstanceId *ULID `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
}

func (*HubDisconnectRequest) Descriptor 

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

func (*HubDisconnectRequest) Equal 

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

func (*HubDisconnectRequest) GetInstanceId 

func (m *HubDisconnectRequest) GetInstanceId() *ULID

func (*HubDisconnectRequest) GetStableId 

func (m *HubDisconnectRequest) GetStableId() *ULID

func (*HubDisconnectRequest) GoString 

func (this *HubDisconnectRequest) GoString() string

func (*HubDisconnectRequest) Marshal 

func (m *HubDisconnectRequest) Marshal() (dAtA []byte, err error)

func (*HubDisconnectRequest) MarshalJSON 

func (msg *HubDisconnectRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*HubDisconnectRequest) MarshalTo 

func (m *HubDisconnectRequest) MarshalTo(dAtA []byte) (int, error)

func (*HubDisconnectRequest) MarshalToSizedBuffer 

func (m *HubDisconnectRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HubDisconnectRequest) ProtoMessage 

func (*HubDisconnectRequest) ProtoMessage()

func (*HubDisconnectRequest) Reset 

func (m *HubDisconnectRequest) Reset()

func (*HubDisconnectRequest) Size 

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

func (*HubDisconnectRequest) String 

func (this *HubDisconnectRequest) String() string

func (*HubDisconnectRequest) Unmarshal 

func (m *HubDisconnectRequest) Unmarshal(dAtA []byte) error

func (*HubDisconnectRequest) UnmarshalJSON 

func (msg *HubDisconnectRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*HubDisconnectRequest) XXX_DiscardUnknown 

func (m *HubDisconnectRequest) XXX_DiscardUnknown()

func (*HubDisconnectRequest) XXX_Marshal 

func (m *HubDisconnectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HubDisconnectRequest) XXX_Merge 

func (m *HubDisconnectRequest) XXX_Merge(src proto.Message)

func (*HubDisconnectRequest) XXX_Size 

func (m *HubDisconnectRequest) XXX_Size() int

func (*HubDisconnectRequest) XXX_Unmarshal 

func (m *HubDisconnectRequest) XXX_Unmarshal(b []byte) error

type HubInfo 

type HubInfo struct {
	Id        *ULID              `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Locations []*NetworkLocation `protobuf:"bytes,2,rep,name=locations,proto3" json:"locations,omitempty"`
}

func (*HubInfo) Descriptor 

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

func (*HubInfo) Equal 

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

func (*HubInfo) GetId 

func (m *HubInfo) GetId() *ULID

func (*HubInfo) GetLocations 

func (m *HubInfo) GetLocations() []*NetworkLocation

func (*HubInfo) GoString 

func (this *HubInfo) GoString() string

func (*HubInfo) Marshal 

func (m *HubInfo) Marshal() (dAtA []byte, err error)

func (*HubInfo) MarshalJSON 

func (msg *HubInfo) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*HubInfo) MarshalTo 

func (m *HubInfo) MarshalTo(dAtA []byte) (int, error)

func (*HubInfo) MarshalToSizedBuffer 

func (m *HubInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HubInfo) ProtoMessage 

func (*HubInfo) ProtoMessage()

func (*HubInfo) Reset 

func (m *HubInfo) Reset()

func (*HubInfo) Size 

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

func (*HubInfo) String 

func (this *HubInfo) String() string

func (*HubInfo) Unmarshal 

func (m *HubInfo) Unmarshal(dAtA []byte) error

func (*HubInfo) UnmarshalJSON 

func (msg *HubInfo) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*HubInfo) XXX_DiscardUnknown 

func (m *HubInfo) XXX_DiscardUnknown()

func (*HubInfo) XXX_Marshal 

func (m *HubInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HubInfo) XXX_Merge 

func (m *HubInfo) XXX_Merge(src proto.Message)

func (*HubInfo) XXX_Size 

func (m *HubInfo) XXX_Size() int

func (*HubInfo) XXX_Unmarshal 

func (m *HubInfo) XXX_Unmarshal(b []byte) error

type HubRegisterRequest 

type HubRegisterRequest struct {
	StableId   *ULID              `protobuf:"bytes,1,opt,name=stable_id,json=stableId,proto3" json:"stable_id,omitempty"`
	InstanceId *ULID              `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	Locations  []*NetworkLocation `protobuf:"bytes,3,rep,name=locations,proto3" json:"locations,omitempty"`
}

func (*HubRegisterRequest) Descriptor 

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

func (*HubRegisterRequest) Equal 

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

func (*HubRegisterRequest) GetInstanceId 

func (m *HubRegisterRequest) GetInstanceId() *ULID

func (*HubRegisterRequest) GetLocations 

func (m *HubRegisterRequest) GetLocations() []*NetworkLocation

func (*HubRegisterRequest) GetStableId 

func (m *HubRegisterRequest) GetStableId() *ULID

func (*HubRegisterRequest) GoString 

func (this *HubRegisterRequest) GoString() string

func (*HubRegisterRequest) Marshal 

func (m *HubRegisterRequest) Marshal() (dAtA []byte, err error)

func (*HubRegisterRequest) MarshalJSON 

func (msg *HubRegisterRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*HubRegisterRequest) MarshalTo 

func (m *HubRegisterRequest) MarshalTo(dAtA []byte) (int, error)

func (*HubRegisterRequest) MarshalToSizedBuffer 

func (m *HubRegisterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HubRegisterRequest) ProtoMessage 

func (*HubRegisterRequest) ProtoMessage()

func (*HubRegisterRequest) Reset 

func (m *HubRegisterRequest) Reset()

func (*HubRegisterRequest) Size 

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

func (*HubRegisterRequest) String 

func (this *HubRegisterRequest) String() string

func (*HubRegisterRequest) Unmarshal 

func (m *HubRegisterRequest) Unmarshal(dAtA []byte) error

func (*HubRegisterRequest) UnmarshalJSON 

func (msg *HubRegisterRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*HubRegisterRequest) XXX_DiscardUnknown 

func (m *HubRegisterRequest) XXX_DiscardUnknown()

func (*HubRegisterRequest) XXX_Marshal 

func (m *HubRegisterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HubRegisterRequest) XXX_Merge 

func (m *HubRegisterRequest) XXX_Merge(src proto.Message)

func (*HubRegisterRequest) XXX_Size 

func (m *HubRegisterRequest) XXX_Size() int

func (*HubRegisterRequest) XXX_Unmarshal 

func (m *HubRegisterRequest) XXX_Unmarshal(b []byte) error

type HubRegisterResponse 

type HubRegisterResponse struct {
	ControlTime *Timestamp `protobuf:"bytes,1,opt,name=control_time,json=controlTime,proto3" json:"control_time,omitempty"`
}

func (*HubRegisterResponse) Descriptor 

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

func (*HubRegisterResponse) Equal 

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

func (*HubRegisterResponse) GetControlTime 

func (m *HubRegisterResponse) GetControlTime() *Timestamp

func (*HubRegisterResponse) GoString 

func (this *HubRegisterResponse) GoString() string

func (*HubRegisterResponse) Marshal 

func (m *HubRegisterResponse) Marshal() (dAtA []byte, err error)

func (*HubRegisterResponse) MarshalJSON 

func (msg *HubRegisterResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*HubRegisterResponse) MarshalTo 

func (m *HubRegisterResponse) MarshalTo(dAtA []byte) (int, error)

func (*HubRegisterResponse) MarshalToSizedBuffer 

func (m *HubRegisterResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HubRegisterResponse) ProtoMessage 

func (*HubRegisterResponse) ProtoMessage()

func (*HubRegisterResponse) Reset 

func (m *HubRegisterResponse) Reset()

func (*HubRegisterResponse) Size 

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

func (*HubRegisterResponse) String 

func (this *HubRegisterResponse) String() string

func (*HubRegisterResponse) Unmarshal 

func (m *HubRegisterResponse) Unmarshal(dAtA []byte) error

func (*HubRegisterResponse) UnmarshalJSON 

func (msg *HubRegisterResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*HubRegisterResponse) XXX_DiscardUnknown 

func (m *HubRegisterResponse) XXX_DiscardUnknown()

func (*HubRegisterResponse) XXX_Marshal 

func (m *HubRegisterResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HubRegisterResponse) XXX_Merge 

func (m *HubRegisterResponse) XXX_Merge(src proto.Message)

func (*HubRegisterResponse) XXX_Size 

func (m *HubRegisterResponse) XXX_Size() int

func (*HubRegisterResponse) XXX_Unmarshal 

func (m *HubRegisterResponse) XXX_Unmarshal(b []byte) error

type HubSync 

type HubSync struct {
	Id       *ULID             `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	StableId *ULID             `protobuf:"bytes,2,opt,name=stable_id,json=stableId,proto3" json:"stable_id,omitempty"`
	Services []*ServiceRequest `protobuf:"bytes,3,rep,name=services,proto3" json:"services,omitempty"`
}

func (*HubSync) Descriptor 

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

func (*HubSync) Equal 

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

func (*HubSync) GetId 

func (m *HubSync) GetId() *ULID

func (*HubSync) GetServices 

func (m *HubSync) GetServices() []*ServiceRequest

func (*HubSync) GetStableId 

func (m *HubSync) GetStableId() *ULID

func (*HubSync) GoString 

func (this *HubSync) GoString() string

func (*HubSync) Marshal 

func (m *HubSync) Marshal() (dAtA []byte, err error)

func (*HubSync) MarshalJSON 

func (msg *HubSync) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*HubSync) MarshalTo 

func (m *HubSync) MarshalTo(dAtA []byte) (int, error)

func (*HubSync) MarshalToSizedBuffer 

func (m *HubSync) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HubSync) ProtoMessage 

func (*HubSync) ProtoMessage()

func (*HubSync) Reset 

func (m *HubSync) Reset()

func (*HubSync) Size 

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

func (*HubSync) String 

func (this *HubSync) String() string

func (*HubSync) Unmarshal 

func (m *HubSync) Unmarshal(dAtA []byte) error

func (*HubSync) UnmarshalJSON 

func (msg *HubSync) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*HubSync) XXX_DiscardUnknown 

func (m *HubSync) XXX_DiscardUnknown()

func (*HubSync) XXX_Marshal 

func (m *HubSync) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HubSync) XXX_Merge 

func (m *HubSync) XXX_Merge(src proto.Message)

func (*HubSync) XXX_Size 

func (m *HubSync) XXX_Size() int

func (*HubSync) XXX_Unmarshal 

func (m *HubSync) XXX_Unmarshal(b []byte) error

type HubSyncResponse 

type HubSyncResponse struct {
	ServiceCount int64 `protobuf:"varint,1,opt,name=service_count,json=serviceCount,proto3" json:"service_count,omitempty"`
}

func (*HubSyncResponse) Descriptor 

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

func (*HubSyncResponse) Equal 

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

func (*HubSyncResponse) GetServiceCount 

func (m *HubSyncResponse) GetServiceCount() int64

func (*HubSyncResponse) GoString 

func (this *HubSyncResponse) GoString() string

func (*HubSyncResponse) Marshal 

func (m *HubSyncResponse) Marshal() (dAtA []byte, err error)

func (*HubSyncResponse) MarshalJSON 

func (msg *HubSyncResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*HubSyncResponse) MarshalTo 

func (m *HubSyncResponse) MarshalTo(dAtA []byte) (int, error)

func (*HubSyncResponse) MarshalToSizedBuffer 

func (m *HubSyncResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HubSyncResponse) ProtoMessage 

func (*HubSyncResponse) ProtoMessage()

func (*HubSyncResponse) Reset 

func (m *HubSyncResponse) Reset()

func (*HubSyncResponse) Size 

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

func (*HubSyncResponse) String 

func (this *HubSyncResponse) String() string

func (*HubSyncResponse) Unmarshal 

func (m *HubSyncResponse) Unmarshal(dAtA []byte) error

func (*HubSyncResponse) UnmarshalJSON 

func (msg *HubSyncResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*HubSyncResponse) XXX_DiscardUnknown 

func (m *HubSyncResponse) XXX_DiscardUnknown()

func (*HubSyncResponse) XXX_Marshal 

func (m *HubSyncResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HubSyncResponse) XXX_Merge 

func (m *HubSyncResponse) XXX_Merge(src proto.Message)

func (*HubSyncResponse) XXX_Size 

func (m *HubSyncResponse) XXX_Size() int

func (*HubSyncResponse) XXX_Unmarshal 

func (m *HubSyncResponse) XXX_Unmarshal(b []byte) error

type KVPair 

type KVPair struct {
	Key    string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Ikey   int64  `protobuf:"varint,2,opt,name=ikey,proto3" json:"ikey,omitempty"`
	Value  string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Ivalue int64  `protobuf:"varint,4,opt,name=ivalue,proto3" json:"ivalue,omitempty"`
	Bvalue []byte `protobuf:"bytes,5,opt,name=bvalue,proto3" json:"bvalue,omitempty"`
}

func (*KVPair) Descriptor 

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

func (*KVPair) Equal 

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

func (*KVPair) GetBvalue 

func (m *KVPair) GetBvalue() []byte

func (*KVPair) GetIkey 

func (m *KVPair) GetIkey() int64

func (*KVPair) GetIvalue 

func (m *KVPair) GetIvalue() int64

func (*KVPair) GetKey 

func (m *KVPair) GetKey() string

func (*KVPair) GetValue 

func (m *KVPair) GetValue() string

func (*KVPair) GoString 

func (this *KVPair) GoString() string

func (*KVPair) Marshal 

func (m *KVPair) Marshal() (dAtA []byte, err error)

func (*KVPair) MarshalJSON 

func (msg *KVPair) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*KVPair) MarshalTo 

func (m *KVPair) MarshalTo(dAtA []byte) (int, error)

func (*KVPair) MarshalToSizedBuffer 

func (m *KVPair) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KVPair) ProtoMessage 

func (*KVPair) ProtoMessage()

func (*KVPair) Reset 

func (m *KVPair) Reset()

func (*KVPair) Size 

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

func (*KVPair) String 

func (this *KVPair) String() string

func (*KVPair) Unmarshal 

func (m *KVPair) Unmarshal(dAtA []byte) error

func (*KVPair) UnmarshalJSON 

func (msg *KVPair) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*KVPair) ValueString 

func (kv *KVPair) ValueString() string

func (*KVPair) XXX_DiscardUnknown 

func (m *KVPair) XXX_DiscardUnknown()

func (*KVPair) XXX_Marshal 

func (m *KVPair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KVPair) XXX_Merge 

func (m *KVPair) XXX_Merge(src proto.Message)

func (*KVPair) XXX_Size 

func (m *KVPair) XXX_Size() int

func (*KVPair) XXX_Unmarshal 

func (m *KVPair) XXX_Unmarshal(b []byte) error

type Label 

type Label struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*Label) Descriptor 

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

func (*Label) Equal 

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

func (*Label) GetName 

func (m *Label) GetName() string

func (*Label) GetValue 

func (m *Label) GetValue() string

func (*Label) GoString 

func (this *Label) GoString() string

func (*Label) Marshal 

func (m *Label) Marshal() (dAtA []byte, err error)

func (*Label) MarshalJSON 

func (msg *Label) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Label) MarshalTo 

func (m *Label) MarshalTo(dAtA []byte) (int, error)

func (*Label) MarshalToSizedBuffer 

func (m *Label) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Label) ProtoMessage 

func (*Label) ProtoMessage()

func (*Label) Reset 

func (m *Label) Reset()

func (*Label) Size 

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

func (*Label) String 

func (this *Label) String() string

func (*Label) Unmarshal 

func (m *Label) Unmarshal(dAtA []byte) error

func (*Label) UnmarshalJSON 

func (msg *Label) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Label) XXX_DiscardUnknown 

func (m *Label) XXX_DiscardUnknown()

func (*Label) XXX_Marshal 

func (m *Label) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Label) XXX_Merge 

func (m *Label) XXX_Merge(src proto.Message)

func (*Label) XXX_Size 

func (m *Label) XXX_Size() int

func (*Label) XXX_Unmarshal 

func (m *Label) XXX_Unmarshal(b []byte) error
type LabelLink struct {
	Account *Account        `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"`
	Labels  *LabelSet       `protobuf:"bytes,2,opt,name=labels,proto3" json:"labels,omitempty"`
	Target  *LabelSet       `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	Limits  *Account_Limits `protobuf:"bytes,4,opt,name=limits,proto3" json:"limits,omitempty"`
}

func (*LabelLink) Descriptor 

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

func (*LabelLink) Equal 

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

func (*LabelLink) GetAccount 

func (m *LabelLink) GetAccount() *Account

func (*LabelLink) GetLabels 

func (m *LabelLink) GetLabels() *LabelSet

func (*LabelLink) GetLimits 

func (m *LabelLink) GetLimits() *Account_Limits

func (*LabelLink) GetTarget 

func (m *LabelLink) GetTarget() *LabelSet

func (*LabelLink) GoString 

func (this *LabelLink) GoString() string

func (*LabelLink) Marshal 

func (m *LabelLink) Marshal() (dAtA []byte, err error)

func (*LabelLink) MarshalJSON 

func (msg *LabelLink) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*LabelLink) MarshalTo 

func (m *LabelLink) MarshalTo(dAtA []byte) (int, error)

func (*LabelLink) MarshalToSizedBuffer 

func (m *LabelLink) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LabelLink) ProtoMessage 

func (*LabelLink) ProtoMessage()

func (*LabelLink) Reset 

func (m *LabelLink) Reset()

func (*LabelLink) Size 

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

func (*LabelLink) String 

func (this *LabelLink) String() string

func (*LabelLink) Unmarshal 

func (m *LabelLink) Unmarshal(dAtA []byte) error

func (*LabelLink) UnmarshalJSON 

func (msg *LabelLink) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*LabelLink) XXX_DiscardUnknown 

func (m *LabelLink) XXX_DiscardUnknown()

func (*LabelLink) XXX_Marshal 

func (m *LabelLink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LabelLink) XXX_Merge 

func (m *LabelLink) XXX_Merge(src proto.Message)

func (*LabelLink) XXX_Size 

func (m *LabelLink) XXX_Size() int

func (*LabelLink) XXX_Unmarshal 

func (m *LabelLink) XXX_Unmarshal(b []byte) error
type LabelLinks struct {
	LabelLinks []*LabelLink `protobuf:"bytes,1,rep,name=label_links,json=labelLinks,proto3" json:"label_links,omitempty"`
}

func (*LabelLinks) Descriptor 

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

func (*LabelLinks) Equal 

func (this *LabelLinks) Equal(that interface{}) bool
func (m *LabelLinks) GetLabelLinks() []*LabelLink

func (*LabelLinks) GoString 

func (this *LabelLinks) GoString() string

func (*LabelLinks) Marshal 

func (m *LabelLinks) Marshal() (dAtA []byte, err error)

func (*LabelLinks) MarshalJSON 

func (msg *LabelLinks) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*LabelLinks) MarshalTo 

func (m *LabelLinks) MarshalTo(dAtA []byte) (int, error)

func (*LabelLinks) MarshalToSizedBuffer 

func (m *LabelLinks) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LabelLinks) ProtoMessage 

func (*LabelLinks) ProtoMessage()

func (*LabelLinks) Reset 

func (m *LabelLinks) Reset()

func (*LabelLinks) Size 

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

func (*LabelLinks) String 

func (this *LabelLinks) String() string

func (*LabelLinks) Unmarshal 

func (m *LabelLinks) Unmarshal(dAtA []byte) error

func (*LabelLinks) UnmarshalJSON 

func (msg *LabelLinks) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*LabelLinks) XXX_DiscardUnknown 

func (m *LabelLinks) XXX_DiscardUnknown()

func (*LabelLinks) XXX_Marshal 

func (m *LabelLinks) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LabelLinks) XXX_Merge 

func (m *LabelLinks) XXX_Merge(src proto.Message)

func (*LabelLinks) XXX_Size 

func (m *LabelLinks) XXX_Size() int

func (*LabelLinks) XXX_Unmarshal 

func (m *LabelLinks) XXX_Unmarshal(b []byte) error

type LabelSet 

type LabelSet struct {
	Labels []*Label `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty"`
}

func MakeLabels 

func MakeLabels(args ...string) *LabelSet

func ParseLabelSet 

func ParseLabelSet(s string) *LabelSet

func (*LabelSet) Add 

func (ls *LabelSet) Add(name, value string) *LabelSet

func (*LabelSet) AsStringArray 

func (ls *LabelSet) AsStringArray() pq.StringArray

func (*LabelSet) Combine 

func (ls *LabelSet) Combine(o *LabelSet) *LabelSet

func (*LabelSet) Contains 

func (ls *LabelSet) Contains(name, value string) bool

func (*LabelSet) Descriptor 

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

func (*LabelSet) Equal 

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

func (*LabelSet) Finalize 

func (ls *LabelSet) Finalize()

Call if manually creating a LabelSet once it's filled

func (*LabelSet) GetLabel 

func (ls *LabelSet) GetLabel(key string) (string, bool)

func (*LabelSet) GetLabels 

func (m *LabelSet) GetLabels() []*Label

func (*LabelSet) GoString 

func (this *LabelSet) GoString() string

func (*LabelSet) Len 

func (ls *LabelSet) Len() int

func (*LabelSet) Less 

func (ls *LabelSet) Less(i, j int) bool

func (*LabelSet) Marshal 

func (m *LabelSet) Marshal() (dAtA []byte, err error)

func (*LabelSet) MarshalJSON 

func (msg *LabelSet) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*LabelSet) MarshalTo 

func (m *LabelSet) MarshalTo(dAtA []byte) (int, error)

func (*LabelSet) MarshalToSizedBuffer 

func (m *LabelSet) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LabelSet) Matches 

func (ls *LabelSet) Matches(o *LabelSet) bool

func (*LabelSet) ProtoMessage 

func (*LabelSet) ProtoMessage()

func (*LabelSet) Reset 

func (m *LabelSet) Reset()

func (*LabelSet) Scan 

func (ls *LabelSet) Scan(src interface{}) error

func (*LabelSet) Size 

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

func (*LabelSet) SpecString 

func (ls *LabelSet) SpecString() string

func (*LabelSet) String 

func (ls *LabelSet) String() string

func (*LabelSet) Swap 

func (ls *LabelSet) Swap(i, j int)

func (*LabelSet) Unmarshal 

func (m *LabelSet) Unmarshal(dAtA []byte) error

func (*LabelSet) UnmarshalJSON 

func (msg *LabelSet) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*LabelSet) Value 

func (ls *LabelSet) Value() (driver.Value, error)

func (*LabelSet) XXX_DiscardUnknown 

func (m *LabelSet) XXX_DiscardUnknown()

func (*LabelSet) XXX_Marshal 

func (m *LabelSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LabelSet) XXX_Merge 

func (m *LabelSet) XXX_Merge(src proto.Message)

func (*LabelSet) XXX_Size 

func (m *LabelSet) XXX_Size() int

func (*LabelSet) XXX_Unmarshal 

func (m *LabelSet) XXX_Unmarshal(b []byte) error

type Labels 

type Labels struct {
	// These labels are used to identify this specific service instance
	Label []string `protobuf:"bytes,1,rep,name=label,proto3" json:"label,omitempty"`
}

func (*Labels) Descriptor 

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

func (*Labels) Equal 

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

func (*Labels) GetLabel 

func (m *Labels) GetLabel() []string

func (*Labels) GoString 

func (this *Labels) GoString() string

func (*Labels) Marshal 

func (m *Labels) Marshal() (dAtA []byte, err error)

func (*Labels) MarshalJSON 

func (msg *Labels) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Labels) MarshalTo 

func (m *Labels) MarshalTo(dAtA []byte) (int, error)

func (*Labels) MarshalToSizedBuffer 

func (m *Labels) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Labels) ProtoMessage 

func (*Labels) ProtoMessage()

func (*Labels) Reset 

func (m *Labels) Reset()

func (*Labels) Size 

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

func (*Labels) String 

func (this *Labels) String() string

func (*Labels) Unmarshal 

func (m *Labels) Unmarshal(dAtA []byte) error

func (*Labels) UnmarshalJSON 

func (msg *Labels) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Labels) XXX_DiscardUnknown 

func (m *Labels) XXX_DiscardUnknown()

func (*Labels) XXX_Marshal 

func (m *Labels) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Labels) XXX_Merge 

func (m *Labels) XXX_Merge(src proto.Message)

func (*Labels) XXX_Size 

func (m *Labels) XXX_Size() int

func (*Labels) XXX_Unmarshal 

func (m *Labels) XXX_Unmarshal(b []byte) error

type ListAccountsRequest 

type ListAccountsRequest struct {
	Limit  int32  `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Marker []byte `protobuf:"bytes,2,opt,name=marker,proto3" json:"marker,omitempty"`
}

func (*ListAccountsRequest) Descriptor 

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

func (*ListAccountsRequest) Equal 

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

func (*ListAccountsRequest) GetLimit 

func (m *ListAccountsRequest) GetLimit() int32

func (*ListAccountsRequest) GetMarker 

func (m *ListAccountsRequest) GetMarker() []byte

func (*ListAccountsRequest) GoString 

func (this *ListAccountsRequest) GoString() string

func (*ListAccountsRequest) Marshal 

func (m *ListAccountsRequest) Marshal() (dAtA []byte, err error)

func (*ListAccountsRequest) MarshalJSON 

func (msg *ListAccountsRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ListAccountsRequest) MarshalTo 

func (m *ListAccountsRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListAccountsRequest) MarshalToSizedBuffer 

func (m *ListAccountsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListAccountsRequest) ProtoMessage 

func (*ListAccountsRequest) ProtoMessage()

func (*ListAccountsRequest) Reset 

func (m *ListAccountsRequest) Reset()

func (*ListAccountsRequest) Size 

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

func (*ListAccountsRequest) String 

func (this *ListAccountsRequest) String() string

func (*ListAccountsRequest) Unmarshal 

func (m *ListAccountsRequest) Unmarshal(dAtA []byte) error

func (*ListAccountsRequest) UnmarshalJSON 

func (msg *ListAccountsRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*ListAccountsRequest) XXX_DiscardUnknown 

func (m *ListAccountsRequest) XXX_DiscardUnknown()

func (*ListAccountsRequest) XXX_Marshal 

func (m *ListAccountsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListAccountsRequest) XXX_Merge 

func (m *ListAccountsRequest) XXX_Merge(src proto.Message)

func (*ListAccountsRequest) XXX_Size 

func (m *ListAccountsRequest) XXX_Size() int

func (*ListAccountsRequest) XXX_Unmarshal 

func (m *ListAccountsRequest) XXX_Unmarshal(b []byte) error

type ListAccountsResponse 

type ListAccountsResponse struct {
	Accounts   []*Account `protobuf:"bytes,1,rep,name=accounts,proto3" json:"accounts,omitempty"`
	NextMarker []byte     `protobuf:"bytes,2,opt,name=next_marker,json=nextMarker,proto3" json:"next_marker,omitempty"`
}

func (*ListAccountsResponse) Descriptor 

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

func (*ListAccountsResponse) Equal 

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

func (*ListAccountsResponse) GetAccounts 

func (m *ListAccountsResponse) GetAccounts() []*Account

func (*ListAccountsResponse) GetNextMarker 

func (m *ListAccountsResponse) GetNextMarker() []byte

func (*ListAccountsResponse) GoString 

func (this *ListAccountsResponse) GoString() string

func (*ListAccountsResponse) Marshal 

func (m *ListAccountsResponse) Marshal() (dAtA []byte, err error)

func (*ListAccountsResponse) MarshalJSON 

func (msg *ListAccountsResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ListAccountsResponse) MarshalTo 

func (m *ListAccountsResponse) MarshalTo(dAtA []byte) (int, error)

func (*ListAccountsResponse) MarshalToSizedBuffer 

func (m *ListAccountsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListAccountsResponse) ProtoMessage 

func (*ListAccountsResponse) ProtoMessage()

func (*ListAccountsResponse) Reset 

func (m *ListAccountsResponse) Reset()

func (*ListAccountsResponse) Size 

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

func (*ListAccountsResponse) String 

func (this *ListAccountsResponse) String() string

func (*ListAccountsResponse) Unmarshal 

func (m *ListAccountsResponse) Unmarshal(dAtA []byte) error

func (*ListAccountsResponse) UnmarshalJSON 

func (msg *ListAccountsResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*ListAccountsResponse) XXX_DiscardUnknown 

func (m *ListAccountsResponse) XXX_DiscardUnknown()

func (*ListAccountsResponse) XXX_Marshal 

func (m *ListAccountsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListAccountsResponse) XXX_Merge 

func (m *ListAccountsResponse) XXX_Merge(src proto.Message)

func (*ListAccountsResponse) XXX_Size 

func (m *ListAccountsResponse) XXX_Size() int

func (*ListAccountsResponse) XXX_Unmarshal 

func (m *ListAccountsResponse) XXX_Unmarshal(b []byte) error

type ListOfHubs 

type ListOfHubs struct {
	Hubs []*HubInfo `protobuf:"bytes,1,rep,name=hubs,proto3" json:"hubs,omitempty"`
}

func (*ListOfHubs) Descriptor 

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

func (*ListOfHubs) Equal 

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

func (*ListOfHubs) GetHubs 

func (m *ListOfHubs) GetHubs() []*HubInfo

func (*ListOfHubs) GoString 

func (this *ListOfHubs) GoString() string

func (*ListOfHubs) Marshal 

func (m *ListOfHubs) Marshal() (dAtA []byte, err error)

func (*ListOfHubs) MarshalJSON 

func (msg *ListOfHubs) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ListOfHubs) MarshalTo 

func (m *ListOfHubs) MarshalTo(dAtA []byte) (int, error)

func (*ListOfHubs) MarshalToSizedBuffer 

func (m *ListOfHubs) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListOfHubs) ProtoMessage 

func (*ListOfHubs) ProtoMessage()

func (*ListOfHubs) Reset 

func (m *ListOfHubs) Reset()

func (*ListOfHubs) Size 

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

func (*ListOfHubs) String 

func (this *ListOfHubs) String() string

func (*ListOfHubs) Unmarshal 

func (m *ListOfHubs) Unmarshal(dAtA []byte) error

func (*ListOfHubs) UnmarshalJSON 

func (msg *ListOfHubs) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*ListOfHubs) XXX_DiscardUnknown 

func (m *ListOfHubs) XXX_DiscardUnknown()

func (*ListOfHubs) XXX_Marshal 

func (m *ListOfHubs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListOfHubs) XXX_Merge 

func (m *ListOfHubs) XXX_Merge(src proto.Message)

func (*ListOfHubs) XXX_Size 

func (m *ListOfHubs) XXX_Size() int

func (*ListOfHubs) XXX_Unmarshal 

func (m *ListOfHubs) XXX_Unmarshal(b []byte) error

type ListServicesRequest 

type ListServicesRequest struct {
	Account *Account `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"`
}

func (*ListServicesRequest) Descriptor 

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

func (*ListServicesRequest) Equal 

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

func (*ListServicesRequest) GetAccount 

func (m *ListServicesRequest) GetAccount() *Account

func (*ListServicesRequest) GoString 

func (this *ListServicesRequest) GoString() string

func (*ListServicesRequest) Marshal 

func (m *ListServicesRequest) Marshal() (dAtA []byte, err error)

func (*ListServicesRequest) MarshalJSON 

func (msg *ListServicesRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ListServicesRequest) MarshalTo 

func (m *ListServicesRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListServicesRequest) MarshalToSizedBuffer 

func (m *ListServicesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListServicesRequest) ProtoMessage 

func (*ListServicesRequest) ProtoMessage()

func (*ListServicesRequest) Reset 

func (m *ListServicesRequest) Reset()

func (*ListServicesRequest) Size 

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

func (*ListServicesRequest) String 

func (this *ListServicesRequest) String() string

func (*ListServicesRequest) Unmarshal 

func (m *ListServicesRequest) Unmarshal(dAtA []byte) error

func (*ListServicesRequest) UnmarshalJSON 

func (msg *ListServicesRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*ListServicesRequest) XXX_DiscardUnknown 

func (m *ListServicesRequest) XXX_DiscardUnknown()

func (*ListServicesRequest) XXX_Marshal 

func (m *ListServicesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListServicesRequest) XXX_Merge 

func (m *ListServicesRequest) XXX_Merge(src proto.Message)

func (*ListServicesRequest) XXX_Size 

func (m *ListServicesRequest) XXX_Size() int

func (*ListServicesRequest) XXX_Unmarshal 

func (m *ListServicesRequest) XXX_Unmarshal(b []byte) error

type ListServicesResponse 

type ListServicesResponse struct {
	Services []*Service `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
}

func (*ListServicesResponse) Descriptor 

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

func (*ListServicesResponse) Equal 

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

func (*ListServicesResponse) GetServices 

func (m *ListServicesResponse) GetServices() []*Service

func (*ListServicesResponse) GoString 

func (this *ListServicesResponse) GoString() string

func (*ListServicesResponse) Marshal 

func (m *ListServicesResponse) Marshal() (dAtA []byte, err error)

func (*ListServicesResponse) MarshalJSON 

func (msg *ListServicesResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ListServicesResponse) MarshalTo 

func (m *ListServicesResponse) MarshalTo(dAtA []byte) (int, error)

func (*ListServicesResponse) MarshalToSizedBuffer 

func (m *ListServicesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListServicesResponse) ProtoMessage 

func (*ListServicesResponse) ProtoMessage()

func (*ListServicesResponse) Reset 

func (m *ListServicesResponse) Reset()

func (*ListServicesResponse) Size 

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

func (*ListServicesResponse) String 

func (this *ListServicesResponse) String() string

func (*ListServicesResponse) Unmarshal 

func (m *ListServicesResponse) Unmarshal(dAtA []byte) error

func (*ListServicesResponse) UnmarshalJSON 

func (msg *ListServicesResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*ListServicesResponse) XXX_DiscardUnknown 

func (m *ListServicesResponse) XXX_DiscardUnknown()

func (*ListServicesResponse) XXX_Marshal 

func (m *ListServicesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListServicesResponse) XXX_Merge 

func (m *ListServicesResponse) XXX_Merge(src proto.Message)

func (*ListServicesResponse) XXX_Size 

func (m *ListServicesResponse) XXX_Size() int

func (*ListServicesResponse) XXX_Unmarshal 

func (m *ListServicesResponse) XXX_Unmarshal(b []byte) error

type LookupEndpointsRequest 

type LookupEndpointsRequest struct {
	Account *Account  `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"`
	Labels  *LabelSet `protobuf:"bytes,2,opt,name=labels,proto3" json:"labels,omitempty"`
}

func (*LookupEndpointsRequest) Descriptor 

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

func (*LookupEndpointsRequest) Equal 

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

func (*LookupEndpointsRequest) GetAccount 

func (m *LookupEndpointsRequest) GetAccount() *Account

func (*LookupEndpointsRequest) GetLabels 

func (m *LookupEndpointsRequest) GetLabels() *LabelSet

func (*LookupEndpointsRequest) GoString 

func (this *LookupEndpointsRequest) GoString() string

func (*LookupEndpointsRequest) Marshal 

func (m *LookupEndpointsRequest) Marshal() (dAtA []byte, err error)

func (*LookupEndpointsRequest) MarshalJSON 

func (msg *LookupEndpointsRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*LookupEndpointsRequest) MarshalTo 

func (m *LookupEndpointsRequest) MarshalTo(dAtA []byte) (int, error)

func (*LookupEndpointsRequest) MarshalToSizedBuffer 

func (m *LookupEndpointsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LookupEndpointsRequest) ProtoMessage 

func (*LookupEndpointsRequest) ProtoMessage()

func (*LookupEndpointsRequest) Reset 

func (m *LookupEndpointsRequest) Reset()

func (*LookupEndpointsRequest) Size 

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

func (*LookupEndpointsRequest) String 

func (this *LookupEndpointsRequest) String() string

func (*LookupEndpointsRequest) Unmarshal 

func (m *LookupEndpointsRequest) Unmarshal(dAtA []byte) error

func (*LookupEndpointsRequest) UnmarshalJSON 

func (msg *LookupEndpointsRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*LookupEndpointsRequest) XXX_DiscardUnknown 

func (m *LookupEndpointsRequest) XXX_DiscardUnknown()

func (*LookupEndpointsRequest) XXX_Marshal 

func (m *LookupEndpointsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LookupEndpointsRequest) XXX_Merge 

func (m *LookupEndpointsRequest) XXX_Merge(src proto.Message)

func (*LookupEndpointsRequest) XXX_Size 

func (m *LookupEndpointsRequest) XXX_Size() int

func (*LookupEndpointsRequest) XXX_Unmarshal 

func (m *LookupEndpointsRequest) XXX_Unmarshal(b []byte) error

type LookupEndpointsResponse 

type LookupEndpointsResponse struct {
	Routes    []*ServiceRoute `protobuf:"bytes,1,rep,name=routes,proto3" json:"routes,omitempty"`
	CacheTime int64           `protobuf:"varint,2,opt,name=cache_time,json=cacheTime,proto3" json:"cache_time,omitempty"`
}

func (*LookupEndpointsResponse) Descriptor 

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

func (*LookupEndpointsResponse) Equal 

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

func (*LookupEndpointsResponse) GetCacheTime 

func (m *LookupEndpointsResponse) GetCacheTime() int64

func (*LookupEndpointsResponse) GetRoutes 

func (m *LookupEndpointsResponse) GetRoutes() []*ServiceRoute

func (*LookupEndpointsResponse) GoString 

func (this *LookupEndpointsResponse) GoString() string

func (*LookupEndpointsResponse) Marshal 

func (m *LookupEndpointsResponse) Marshal() (dAtA []byte, err error)

func (*LookupEndpointsResponse) MarshalJSON 

func (msg *LookupEndpointsResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*LookupEndpointsResponse) MarshalTo 

func (m *LookupEndpointsResponse) MarshalTo(dAtA []byte) (int, error)

func (*LookupEndpointsResponse) MarshalToSizedBuffer 

func (m *LookupEndpointsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LookupEndpointsResponse) ProtoMessage 

func (*LookupEndpointsResponse) ProtoMessage()

func (*LookupEndpointsResponse) Reset 

func (m *LookupEndpointsResponse) Reset()

func (*LookupEndpointsResponse) Size 

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

func (*LookupEndpointsResponse) String 

func (this *LookupEndpointsResponse) String() string

func (*LookupEndpointsResponse) Unmarshal 

func (m *LookupEndpointsResponse) Unmarshal(dAtA []byte) error

func (*LookupEndpointsResponse) UnmarshalJSON 

func (msg *LookupEndpointsResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*LookupEndpointsResponse) XXX_DiscardUnknown 

func (m *LookupEndpointsResponse) XXX_DiscardUnknown()

func (*LookupEndpointsResponse) XXX_Marshal 

func (m *LookupEndpointsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LookupEndpointsResponse) XXX_Merge 

func (m *LookupEndpointsResponse) XXX_Merge(src proto.Message)

func (*LookupEndpointsResponse) XXX_Size 

func (m *LookupEndpointsResponse) XXX_Size() int

func (*LookupEndpointsResponse) XXX_Unmarshal 

func (m *LookupEndpointsResponse) XXX_Unmarshal(b []byte) error

type NetworkLocation 

type NetworkLocation struct {
	Addresses []string  `protobuf:"bytes,1,rep,name=addresses,proto3" json:"addresses,omitempty"`
	Labels    *LabelSet `protobuf:"bytes,2,opt,name=labels,proto3" json:"labels,omitempty"`
	Name      string    `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
}

func (*NetworkLocation) Cardinality 

func (l *NetworkLocation) Cardinality(r *NetworkLocation) int

func (*NetworkLocation) Descriptor 

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

func (*NetworkLocation) Equal 

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

func (*NetworkLocation) GetAddresses 

func (m *NetworkLocation) GetAddresses() []string

func (*NetworkLocation) GetLabels 

func (m *NetworkLocation) GetLabels() *LabelSet

func (*NetworkLocation) GetName 

func (m *NetworkLocation) GetName() string

func (*NetworkLocation) GoString 

func (this *NetworkLocation) GoString() string

func (*NetworkLocation) IsPublic 

func (l *NetworkLocation) IsPublic() bool

func (*NetworkLocation) Marshal 

func (m *NetworkLocation) Marshal() (dAtA []byte, err error)

func (*NetworkLocation) MarshalJSON 

func (msg *NetworkLocation) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*NetworkLocation) MarshalTo 

func (m *NetworkLocation) MarshalTo(dAtA []byte) (int, error)

func (*NetworkLocation) MarshalToSizedBuffer 

func (m *NetworkLocation) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NetworkLocation) ProtoMessage 

func (*NetworkLocation) ProtoMessage()

func (*NetworkLocation) Reset 

func (m *NetworkLocation) Reset()

func (*NetworkLocation) SameLabels 

func (l *NetworkLocation) SameLabels(r *NetworkLocation) bool

func (*NetworkLocation) Size 

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

func (*NetworkLocation) String 

func (this *NetworkLocation) String() string

func (*NetworkLocation) Unmarshal 

func (m *NetworkLocation) Unmarshal(dAtA []byte) error

func (*NetworkLocation) UnmarshalJSON 

func (msg *NetworkLocation) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*NetworkLocation) XXX_DiscardUnknown 

func (m *NetworkLocation) XXX_DiscardUnknown()

func (*NetworkLocation) XXX_Marshal 

func (m *NetworkLocation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NetworkLocation) XXX_Merge 

func (m *NetworkLocation) XXX_Merge(src proto.Message)

func (*NetworkLocation) XXX_Size 

func (m *NetworkLocation) XXX_Size() int

func (*NetworkLocation) XXX_Unmarshal 

func (m *NetworkLocation) XXX_Unmarshal(b []byte) error

type Noop 

type Noop struct {
}

func (*Noop) Descriptor 

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

func (*Noop) Equal 

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

func (*Noop) GoString 

func (this *Noop) GoString() string

func (*Noop) Marshal 

func (m *Noop) Marshal() (dAtA []byte, err error)

func (*Noop) MarshalJSON 

func (msg *Noop) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Noop) MarshalTo 

func (m *Noop) MarshalTo(dAtA []byte) (int, error)

func (*Noop) MarshalToSizedBuffer 

func (m *Noop) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Noop) ProtoMessage 

func (*Noop) ProtoMessage()

func (*Noop) Reset 

func (m *Noop) Reset()

func (*Noop) Size 

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

func (*Noop) String 

func (this *Noop) String() string

func (*Noop) Unmarshal 

func (m *Noop) Unmarshal(dAtA []byte) error

func (*Noop) UnmarshalJSON 

func (msg *Noop) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Noop) XXX_DiscardUnknown 

func (m *Noop) XXX_DiscardUnknown()

func (*Noop) XXX_Marshal 

func (m *Noop) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Noop) XXX_Merge 

func (m *Noop) XXX_Merge(src proto.Message)

func (*Noop) XXX_Size 

func (m *Noop) XXX_Size() int

func (*Noop) XXX_Unmarshal 

func (m *Noop) XXX_Unmarshal(b []byte) error

type Preamble 

type Preamble struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Token     string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// These are labels that identify the agent. IE location, etc.
	Labels      []string       `protobuf:"bytes,3,rep,name=labels,proto3" json:"labels,omitempty"`
	Services    []*ServiceInfo `protobuf:"bytes,4,rep,name=services,proto3" json:"services,omitempty"`
	Compression string         `protobuf:"bytes,5,opt,name=compression,proto3" json:"compression,omitempty"`
}

func (*Preamble) Descriptor 

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

func (*Preamble) Equal 

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

func (*Preamble) GetCompression 

func (m *Preamble) GetCompression() string

func (*Preamble) GetLabels 

func (m *Preamble) GetLabels() []string

func (*Preamble) GetServices 

func (m *Preamble) GetServices() []*ServiceInfo

func (*Preamble) GetSessionId 

func (m *Preamble) GetSessionId() string

func (*Preamble) GetToken 

func (m *Preamble) GetToken() string

func (*Preamble) GoString 

func (this *Preamble) GoString() string

func (*Preamble) Marshal 

func (m *Preamble) Marshal() (dAtA []byte, err error)

func (*Preamble) MarshalJSON 

func (msg *Preamble) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Preamble) MarshalTo 

func (m *Preamble) MarshalTo(dAtA []byte) (int, error)

func (*Preamble) MarshalToSizedBuffer 

func (m *Preamble) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Preamble) ProtoMessage 

func (*Preamble) ProtoMessage()

func (*Preamble) Reset 

func (m *Preamble) Reset()

func (*Preamble) Size 

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

func (*Preamble) String 

func (this *Preamble) String() string

func (*Preamble) Unmarshal 

func (m *Preamble) Unmarshal(dAtA []byte) error

func (*Preamble) UnmarshalJSON 

func (msg *Preamble) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Preamble) XXX_DiscardUnknown 

func (m *Preamble) XXX_DiscardUnknown()

func (*Preamble) XXX_Marshal 

func (m *Preamble) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Preamble) XXX_Merge 

func (m *Preamble) XXX_Merge(src proto.Message)

func (*Preamble) XXX_Size 

func (m *Preamble) XXX_Size() int

func (*Preamble) XXX_Unmarshal 

func (m *Preamble) XXX_Unmarshal(b []byte) error

type RemoveLabelLinkRequest 

type RemoveLabelLinkRequest struct {
	Labels  *LabelSet `protobuf:"bytes,1,opt,name=labels,proto3" json:"labels,omitempty"`
	Account *Account  `protobuf:"bytes,2,opt,name=account,proto3" json:"account,omitempty"`
}

func (*RemoveLabelLinkRequest) Descriptor 

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

func (*RemoveLabelLinkRequest) Equal 

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

func (*RemoveLabelLinkRequest) GetAccount 

func (m *RemoveLabelLinkRequest) GetAccount() *Account

func (*RemoveLabelLinkRequest) GetLabels 

func (m *RemoveLabelLinkRequest) GetLabels() *LabelSet

func (*RemoveLabelLinkRequest) GoString 

func (this *RemoveLabelLinkRequest) GoString() string

func (*RemoveLabelLinkRequest) Marshal 

func (m *RemoveLabelLinkRequest) Marshal() (dAtA []byte, err error)

func (*RemoveLabelLinkRequest) MarshalJSON 

func (msg *RemoveLabelLinkRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*RemoveLabelLinkRequest) MarshalTo 

func (m *RemoveLabelLinkRequest) MarshalTo(dAtA []byte) (int, error)

func (*RemoveLabelLinkRequest) MarshalToSizedBuffer 

func (m *RemoveLabelLinkRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RemoveLabelLinkRequest) ProtoMessage 

func (*RemoveLabelLinkRequest) ProtoMessage()

func (*RemoveLabelLinkRequest) Reset 

func (m *RemoveLabelLinkRequest) Reset()

func (*RemoveLabelLinkRequest) Size 

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

func (*RemoveLabelLinkRequest) String 

func (this *RemoveLabelLinkRequest) String() string

func (*RemoveLabelLinkRequest) Unmarshal 

func (m *RemoveLabelLinkRequest) Unmarshal(dAtA []byte) error

func (*RemoveLabelLinkRequest) UnmarshalJSON 

func (msg *RemoveLabelLinkRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*RemoveLabelLinkRequest) XXX_DiscardUnknown 

func (m *RemoveLabelLinkRequest) XXX_DiscardUnknown()

func (*RemoveLabelLinkRequest) XXX_Marshal 

func (m *RemoveLabelLinkRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveLabelLinkRequest) XXX_Merge 

func (m *RemoveLabelLinkRequest) XXX_Merge(src proto.Message)

func (*RemoveLabelLinkRequest) XXX_Size 

func (m *RemoveLabelLinkRequest) XXX_Size() int

func (*RemoveLabelLinkRequest) XXX_Unmarshal 

func (m *RemoveLabelLinkRequest) XXX_Unmarshal(b []byte) error

type Request 

type Request struct {
	Type          Request_Type `protobuf:"varint,1,opt,name=type,proto3,enum=pb.Request_Type" json:"type,omitempty"`
	Method        string       `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Path          string       `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	Query         string       `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"`
	Fragment      string       `protobuf:"bytes,5,opt,name=fragment,proto3" json:"fragment,omitempty"`
	Auth          *Auth        `protobuf:"bytes,6,opt,name=auth,proto3" json:"auth,omitempty"`
	Headers       []*Header    `protobuf:"bytes,7,rep,name=headers,proto3" json:"headers,omitempty"`
	RemoteAddr    string       `protobuf:"bytes,8,opt,name=remote_addr,json=remoteAddr,proto3" json:"remote_addr,omitempty"`
	Host          string       `protobuf:"bytes,9,opt,name=host,proto3" json:"host,omitempty"`
	AgentId       []byte       `protobuf:"bytes,10,opt,name=agentId,proto3" json:"agentId,omitempty"`
	TargetService string       `protobuf:"bytes,11,opt,name=target_service,json=targetService,proto3" json:"target_service,omitempty"`
	PivotAccount  *Account     `protobuf:"bytes,12,opt,name=pivot_account,json=pivotAccount,proto3" json:"pivot_account,omitempty"`
}

func (*Request) Descriptor 

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

func (*Request) Equal 

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

func (*Request) GetAgentId 

func (m *Request) GetAgentId() []byte

func (*Request) GetAuth 

func (m *Request) GetAuth() *Auth

func (*Request) GetFragment 

func (m *Request) GetFragment() string

func (*Request) GetHeaders 

func (m *Request) GetHeaders() []*Header

func (*Request) GetHost 

func (m *Request) GetHost() string

func (*Request) GetMethod 

func (m *Request) GetMethod() string

func (*Request) GetPath 

func (m *Request) GetPath() string

func (*Request) GetPivotAccount 

func (m *Request) GetPivotAccount() *Account

func (*Request) GetQuery 

func (m *Request) GetQuery() string

func (*Request) GetRemoteAddr 

func (m *Request) GetRemoteAddr() string

func (*Request) GetTargetService 

func (m *Request) GetTargetService() string

func (*Request) GetType 

func (m *Request) GetType() Request_Type

func (*Request) GoString 

func (this *Request) GoString() string

func (*Request) Marshal 

func (m *Request) Marshal() (dAtA []byte, err error)

func (*Request) MarshalJSON 

func (msg *Request) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Request) MarshalTo 

func (m *Request) MarshalTo(dAtA []byte) (int, error)

func (*Request) MarshalToSizedBuffer 

func (m *Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) Size 

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

func (*Request) String 

func (this *Request) String() string

func (*Request) Unmarshal 

func (m *Request) Unmarshal(dAtA []byte) error

func (*Request) UnmarshalJSON 

func (msg *Request) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Request) XXX_Merge 

func (m *Request) XXX_Merge(src proto.Message)

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

func (m *Request) XXX_Unmarshal(b []byte) error

type Request_Type 

type Request_Type int32
const (
	HTTP          Request_Type = 0
	WEBSOCKET     Request_Type = 1
	TCP           Request_Type = 2
	UDP           Request_Type = 3
	RPC           Request_Type = 4
	AGENT_CONNECT Request_Type = 5
)

func (Request_Type) EnumDescriptor 

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

func (Request_Type) String 

func (x Request_Type) String() string

type ResolveLabelLinkRequest 

type ResolveLabelLinkRequest struct {
	Labels *LabelSet `protobuf:"bytes,1,opt,name=labels,proto3" json:"labels,omitempty"`
}

func (*ResolveLabelLinkRequest) Descriptor 

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

func (*ResolveLabelLinkRequest) Equal 

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

func (*ResolveLabelLinkRequest) GetLabels 

func (m *ResolveLabelLinkRequest) GetLabels() *LabelSet

func (*ResolveLabelLinkRequest) GoString 

func (this *ResolveLabelLinkRequest) GoString() string

func (*ResolveLabelLinkRequest) Marshal 

func (m *ResolveLabelLinkRequest) Marshal() (dAtA []byte, err error)

func (*ResolveLabelLinkRequest) MarshalJSON 

func (msg *ResolveLabelLinkRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ResolveLabelLinkRequest) MarshalTo 

func (m *ResolveLabelLinkRequest) MarshalTo(dAtA []byte) (int, error)

func (*ResolveLabelLinkRequest) MarshalToSizedBuffer 

func (m *ResolveLabelLinkRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResolveLabelLinkRequest) ProtoMessage 

func (*ResolveLabelLinkRequest) ProtoMessage()

func (*ResolveLabelLinkRequest) Reset 

func (m *ResolveLabelLinkRequest) Reset()

func (*ResolveLabelLinkRequest) Size 

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

func (*ResolveLabelLinkRequest) String 

func (this *ResolveLabelLinkRequest) String() string

func (*ResolveLabelLinkRequest) Unmarshal 

func (m *ResolveLabelLinkRequest) Unmarshal(dAtA []byte) error

func (*ResolveLabelLinkRequest) UnmarshalJSON 

func (msg *ResolveLabelLinkRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*ResolveLabelLinkRequest) XXX_DiscardUnknown 

func (m *ResolveLabelLinkRequest) XXX_DiscardUnknown()

func (*ResolveLabelLinkRequest) XXX_Marshal 

func (m *ResolveLabelLinkRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResolveLabelLinkRequest) XXX_Merge 

func (m *ResolveLabelLinkRequest) XXX_Merge(src proto.Message)

func (*ResolveLabelLinkRequest) XXX_Size 

func (m *ResolveLabelLinkRequest) XXX_Size() int

func (*ResolveLabelLinkRequest) XXX_Unmarshal 

func (m *ResolveLabelLinkRequest) XXX_Unmarshal(b []byte) error

type ResolveLabelLinkResponse 

type ResolveLabelLinkResponse struct {
	Account   *Account        `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"`
	Labels    *LabelSet       `protobuf:"bytes,2,opt,name=labels,proto3" json:"labels,omitempty"`
	Limits    *Account_Limits `protobuf:"bytes,3,opt,name=limits,proto3" json:"limits,omitempty"`
	CacheTime int64           `protobuf:"varint,4,opt,name=cache_time,json=cacheTime,proto3" json:"cache_time,omitempty"`
}

func (*ResolveLabelLinkResponse) Descriptor 

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

func (*ResolveLabelLinkResponse) Equal 

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

func (*ResolveLabelLinkResponse) GetAccount 

func (m *ResolveLabelLinkResponse) GetAccount() *Account

func (*ResolveLabelLinkResponse) GetCacheTime 

func (m *ResolveLabelLinkResponse) GetCacheTime() int64

func (*ResolveLabelLinkResponse) GetLabels 

func (m *ResolveLabelLinkResponse) GetLabels() *LabelSet

func (*ResolveLabelLinkResponse) GetLimits 

func (m *ResolveLabelLinkResponse) GetLimits() *Account_Limits

func (*ResolveLabelLinkResponse) GoString 

func (this *ResolveLabelLinkResponse) GoString() string

func (*ResolveLabelLinkResponse) Marshal 

func (m *ResolveLabelLinkResponse) Marshal() (dAtA []byte, err error)

func (*ResolveLabelLinkResponse) MarshalJSON 

func (msg *ResolveLabelLinkResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ResolveLabelLinkResponse) MarshalTo 

func (m *ResolveLabelLinkResponse) MarshalTo(dAtA []byte) (int, error)

func (*ResolveLabelLinkResponse) MarshalToSizedBuffer 

func (m *ResolveLabelLinkResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResolveLabelLinkResponse) ProtoMessage 

func (*ResolveLabelLinkResponse) ProtoMessage()

func (*ResolveLabelLinkResponse) Reset 

func (m *ResolveLabelLinkResponse) Reset()

func (*ResolveLabelLinkResponse) Size 

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

func (*ResolveLabelLinkResponse) String 

func (this *ResolveLabelLinkResponse) String() string

func (*ResolveLabelLinkResponse) Unmarshal 

func (m *ResolveLabelLinkResponse) Unmarshal(dAtA []byte) error

func (*ResolveLabelLinkResponse) UnmarshalJSON 

func (msg *ResolveLabelLinkResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*ResolveLabelLinkResponse) XXX_DiscardUnknown 

func (m *ResolveLabelLinkResponse) XXX_DiscardUnknown()

func (*ResolveLabelLinkResponse) XXX_Marshal 

func (m *ResolveLabelLinkResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResolveLabelLinkResponse) XXX_Merge 

func (m *ResolveLabelLinkResponse) XXX_Merge(src proto.Message)

func (*ResolveLabelLinkResponse) XXX_Size 

func (m *ResolveLabelLinkResponse) XXX_Size() int

func (*ResolveLabelLinkResponse) XXX_Unmarshal 

func (m *ResolveLabelLinkResponse) XXX_Unmarshal(b []byte) error

type Response 

type Response struct {
	Error   string    `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Code    int32     `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
	Headers []*Header `protobuf:"bytes,3,rep,name=headers,proto3" json:"headers,omitempty"`
}

func (*Response) Descriptor 

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

func (*Response) Equal 

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

func (*Response) GetCode 

func (m *Response) GetCode() int32

func (*Response) GetError 

func (m *Response) GetError() string

func (*Response) GetHeaders 

func (m *Response) GetHeaders() []*Header

func (*Response) GoString 

func (this *Response) GoString() string

func (*Response) Marshal 

func (m *Response) Marshal() (dAtA []byte, err error)

func (*Response) MarshalJSON 

func (msg *Response) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Response) MarshalTo 

func (m *Response) MarshalTo(dAtA []byte) (int, error)

func (*Response) MarshalToSizedBuffer 

func (m *Response) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) Size 

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

func (*Response) String 

func (this *Response) String() string

func (*Response) Unmarshal 

func (m *Response) Unmarshal(dAtA []byte) error

func (*Response) UnmarshalJSON 

func (msg *Response) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Response) XXX_Merge 

func (m *Response) XXX_Merge(src proto.Message)

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

func (m *Response) XXX_Unmarshal(b []byte) error

type Service 

type Service struct {
	Id       *ULID     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Hub      *ULID     `protobuf:"bytes,2,opt,name=hub,proto3" json:"hub,omitempty"`
	Type     string    `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Labels   *LabelSet `protobuf:"bytes,4,opt,name=labels,proto3" json:"labels,omitempty"`
	Metadata []*KVPair `protobuf:"bytes,5,rep,name=metadata,proto3" json:"metadata,omitempty"`
}

func (*Service) Descriptor 

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

func (*Service) Equal 

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

func (*Service) GetHub 

func (m *Service) GetHub() *ULID

func (*Service) GetId 

func (m *Service) GetId() *ULID

func (*Service) GetLabels 

func (m *Service) GetLabels() *LabelSet

func (*Service) GetMetadata 

func (m *Service) GetMetadata() []*KVPair

func (*Service) GetType 

func (m *Service) GetType() string

func (*Service) GoString 

func (this *Service) GoString() string

func (*Service) Marshal 

func (m *Service) Marshal() (dAtA []byte, err error)

func (*Service) MarshalJSON 

func (msg *Service) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Service) MarshalTo 

func (m *Service) MarshalTo(dAtA []byte) (int, error)

func (*Service) MarshalToSizedBuffer 

func (m *Service) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) Reset 

func (m *Service) Reset()

func (*Service) Size 

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

func (*Service) String 

func (this *Service) String() string

func (*Service) Unmarshal 

func (m *Service) Unmarshal(dAtA []byte) error

func (*Service) UnmarshalJSON 

func (msg *Service) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Service) XXX_DiscardUnknown 

func (m *Service) XXX_DiscardUnknown()

func (*Service) XXX_Marshal 

func (m *Service) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Service) XXX_Merge 

func (m *Service) XXX_Merge(src proto.Message)

func (*Service) XXX_Size 

func (m *Service) XXX_Size() int

func (*Service) XXX_Unmarshal 

func (m *Service) XXX_Unmarshal(b []byte) error

type ServiceInfo 

type ServiceInfo struct {
	// A short identifier for this service instance
	ServiceId *ULID `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	// A type identifier for the kind of service this instance is
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// These labels are used to identify this specific service instance
	Labels   *LabelSet `protobuf:"bytes,3,opt,name=labels,proto3" json:"labels,omitempty"`
	Metadata []*KVPair `protobuf:"bytes,4,rep,name=metadata,proto3" json:"metadata,omitempty"`
}

func (*ServiceInfo) Descriptor 

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

func (*ServiceInfo) Equal 

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

func (*ServiceInfo) GetLabels 

func (m *ServiceInfo) GetLabels() *LabelSet

func (*ServiceInfo) GetMetadata 

func (m *ServiceInfo) GetMetadata() []*KVPair

func (*ServiceInfo) GetServiceId 

func (m *ServiceInfo) GetServiceId() *ULID

func (*ServiceInfo) GetType 

func (m *ServiceInfo) GetType() string

func (*ServiceInfo) GoString 

func (this *ServiceInfo) GoString() string

func (*ServiceInfo) Marshal 

func (m *ServiceInfo) Marshal() (dAtA []byte, err error)

func (*ServiceInfo) MarshalJSON 

func (msg *ServiceInfo) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ServiceInfo) MarshalTo 

func (m *ServiceInfo) MarshalTo(dAtA []byte) (int, error)

func (*ServiceInfo) MarshalToSizedBuffer 

func (m *ServiceInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceInfo) ProtoMessage 

func (*ServiceInfo) ProtoMessage()

func (*ServiceInfo) Reset 

func (m *ServiceInfo) Reset()

func (*ServiceInfo) Size 

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

func (*ServiceInfo) String 

func (this *ServiceInfo) String() string

func (*ServiceInfo) Unmarshal 

func (m *ServiceInfo) Unmarshal(dAtA []byte) error

func (*ServiceInfo) UnmarshalJSON 

func (msg *ServiceInfo) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*ServiceInfo) XXX_DiscardUnknown 

func (m *ServiceInfo) XXX_DiscardUnknown()

func (*ServiceInfo) XXX_Marshal 

func (m *ServiceInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceInfo) XXX_Merge 

func (m *ServiceInfo) XXX_Merge(src proto.Message)

func (*ServiceInfo) XXX_Size 

func (m *ServiceInfo) XXX_Size() int

func (*ServiceInfo) XXX_Unmarshal 

func (m *ServiceInfo) XXX_Unmarshal(b []byte) error

type ServiceRequest 

type ServiceRequest struct {
	Account  *Account  `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"`
	Hub      *ULID     `protobuf:"bytes,2,opt,name=hub,proto3" json:"hub,omitempty"`
	Id       *ULID     `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	Type     string    `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	Labels   *LabelSet `protobuf:"bytes,5,opt,name=labels,proto3" json:"labels,omitempty"`
	Metadata []*KVPair `protobuf:"bytes,6,rep,name=metadata,proto3" json:"metadata,omitempty"`
}

func (*ServiceRequest) Descriptor 

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

func (*ServiceRequest) Equal 

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

func (*ServiceRequest) GetAccount 

func (m *ServiceRequest) GetAccount() *Account

func (*ServiceRequest) GetHub 

func (m *ServiceRequest) GetHub() *ULID

func (*ServiceRequest) GetId 

func (m *ServiceRequest) GetId() *ULID

func (*ServiceRequest) GetLabels 

func (m *ServiceRequest) GetLabels() *LabelSet

func (*ServiceRequest) GetMetadata 

func (m *ServiceRequest) GetMetadata() []*KVPair

func (*ServiceRequest) GetType 

func (m *ServiceRequest) GetType() string

func (*ServiceRequest) GoString 

func (this *ServiceRequest) GoString() string

func (*ServiceRequest) Marshal 

func (m *ServiceRequest) Marshal() (dAtA []byte, err error)

func (*ServiceRequest) MarshalJSON 

func (msg *ServiceRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ServiceRequest) MarshalTo 

func (m *ServiceRequest) MarshalTo(dAtA []byte) (int, error)

func (*ServiceRequest) MarshalToSizedBuffer 

func (m *ServiceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceRequest) ProtoMessage 

func (*ServiceRequest) ProtoMessage()

func (*ServiceRequest) Reset 

func (m *ServiceRequest) Reset()

func (*ServiceRequest) Size 

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

func (*ServiceRequest) String 

func (this *ServiceRequest) String() string

func (*ServiceRequest) Unmarshal 

func (m *ServiceRequest) Unmarshal(dAtA []byte) error

func (*ServiceRequest) UnmarshalJSON 

func (msg *ServiceRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*ServiceRequest) XXX_DiscardUnknown 

func (m *ServiceRequest) XXX_DiscardUnknown()

func (*ServiceRequest) XXX_Marshal 

func (m *ServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceRequest) XXX_Merge 

func (m *ServiceRequest) XXX_Merge(src proto.Message)

func (*ServiceRequest) XXX_Size 

func (m *ServiceRequest) XXX_Size() int

func (*ServiceRequest) XXX_Unmarshal 

func (m *ServiceRequest) XXX_Unmarshal(b []byte) error

type ServiceResponse 

type ServiceResponse struct {
}

func (*ServiceResponse) Descriptor 

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

func (*ServiceResponse) Equal 

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

func (*ServiceResponse) GoString 

func (this *ServiceResponse) GoString() string

func (*ServiceResponse) Marshal 

func (m *ServiceResponse) Marshal() (dAtA []byte, err error)

func (*ServiceResponse) MarshalJSON 

func (msg *ServiceResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ServiceResponse) MarshalTo 

func (m *ServiceResponse) MarshalTo(dAtA []byte) (int, error)

func (*ServiceResponse) MarshalToSizedBuffer 

func (m *ServiceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceResponse) ProtoMessage 

func (*ServiceResponse) ProtoMessage()

func (*ServiceResponse) Reset 

func (m *ServiceResponse) Reset()

func (*ServiceResponse) Size 

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

func (*ServiceResponse) String 

func (this *ServiceResponse) String() string

func (*ServiceResponse) Unmarshal 

func (m *ServiceResponse) Unmarshal(dAtA []byte) error

func (*ServiceResponse) UnmarshalJSON 

func (msg *ServiceResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*ServiceResponse) XXX_DiscardUnknown 

func (m *ServiceResponse) XXX_DiscardUnknown()

func (*ServiceResponse) XXX_Marshal 

func (m *ServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceResponse) XXX_Merge 

func (m *ServiceResponse) XXX_Merge(src proto.Message)

func (*ServiceResponse) XXX_Size 

func (m *ServiceResponse) XXX_Size() int

func (*ServiceResponse) XXX_Unmarshal 

func (m *ServiceResponse) XXX_Unmarshal(b []byte) error

type ServiceRoute 

type ServiceRoute struct {
	Hub    *ULID     `protobuf:"bytes,1,opt,name=hub,proto3" json:"hub,omitempty"`
	Id     *ULID     `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Type   string    `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Labels *LabelSet `protobuf:"bytes,4,opt,name=labels,proto3" json:"labels,omitempty"`
}

func (*ServiceRoute) Descriptor 

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

func (*ServiceRoute) Equal 

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

func (*ServiceRoute) GetHub 

func (m *ServiceRoute) GetHub() *ULID

func (*ServiceRoute) GetId 

func (m *ServiceRoute) GetId() *ULID

func (*ServiceRoute) GetLabels 

func (m *ServiceRoute) GetLabels() *LabelSet

func (*ServiceRoute) GetType 

func (m *ServiceRoute) GetType() string

func (*ServiceRoute) GoString 

func (this *ServiceRoute) GoString() string

func (*ServiceRoute) Marshal 

func (m *ServiceRoute) Marshal() (dAtA []byte, err error)

func (*ServiceRoute) MarshalJSON 

func (msg *ServiceRoute) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ServiceRoute) MarshalTo 

func (m *ServiceRoute) MarshalTo(dAtA []byte) (int, error)

func (*ServiceRoute) MarshalToSizedBuffer 

func (m *ServiceRoute) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceRoute) ProtoMessage 

func (*ServiceRoute) ProtoMessage()

func (*ServiceRoute) Reset 

func (m *ServiceRoute) Reset()

func (*ServiceRoute) Size 

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

func (*ServiceRoute) String 

func (this *ServiceRoute) String() string

func (*ServiceRoute) Unmarshal 

func (m *ServiceRoute) Unmarshal(dAtA []byte) error

func (*ServiceRoute) UnmarshalJSON 

func (msg *ServiceRoute) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*ServiceRoute) XXX_DiscardUnknown 

func (m *ServiceRoute) XXX_DiscardUnknown()

func (*ServiceRoute) XXX_Marshal 

func (m *ServiceRoute) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceRoute) XXX_Merge 

func (m *ServiceRoute) XXX_Merge(src proto.Message)

func (*ServiceRoute) XXX_Size 

func (m *ServiceRoute) XXX_Size() int

func (*ServiceRoute) XXX_Unmarshal 

func (m *ServiceRoute) XXX_Unmarshal(b []byte) error

type ServiceTokenRequest 

type ServiceTokenRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
}

func (*ServiceTokenRequest) Descriptor 

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

func (*ServiceTokenRequest) Equal 

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

func (*ServiceTokenRequest) GetNamespace 

func (m *ServiceTokenRequest) GetNamespace() string

func (*ServiceTokenRequest) GoString 

func (this *ServiceTokenRequest) GoString() string

func (*ServiceTokenRequest) Marshal 

func (m *ServiceTokenRequest) Marshal() (dAtA []byte, err error)

func (*ServiceTokenRequest) MarshalJSON 

func (msg *ServiceTokenRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ServiceTokenRequest) MarshalTo 

func (m *ServiceTokenRequest) MarshalTo(dAtA []byte) (int, error)

func (*ServiceTokenRequest) MarshalToSizedBuffer 

func (m *ServiceTokenRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceTokenRequest) ProtoMessage 

func (*ServiceTokenRequest) ProtoMessage()

func (*ServiceTokenRequest) Reset 

func (m *ServiceTokenRequest) Reset()

func (*ServiceTokenRequest) Size 

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

func (*ServiceTokenRequest) String 

func (this *ServiceTokenRequest) String() string

func (*ServiceTokenRequest) Unmarshal 

func (m *ServiceTokenRequest) Unmarshal(dAtA []byte) error

func (*ServiceTokenRequest) UnmarshalJSON 

func (msg *ServiceTokenRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*ServiceTokenRequest) XXX_DiscardUnknown 

func (m *ServiceTokenRequest) XXX_DiscardUnknown()

func (*ServiceTokenRequest) XXX_Marshal 

func (m *ServiceTokenRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceTokenRequest) XXX_Merge 

func (m *ServiceTokenRequest) XXX_Merge(src proto.Message)

func (*ServiceTokenRequest) XXX_Size 

func (m *ServiceTokenRequest) XXX_Size() int

func (*ServiceTokenRequest) XXX_Unmarshal 

func (m *ServiceTokenRequest) XXX_Unmarshal(b []byte) error

type ServiceTokenResponse 

type ServiceTokenResponse struct {
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
}

func (*ServiceTokenResponse) Descriptor 

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

func (*ServiceTokenResponse) Equal 

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

func (*ServiceTokenResponse) GetToken 

func (m *ServiceTokenResponse) GetToken() string

func (*ServiceTokenResponse) GoString 

func (this *ServiceTokenResponse) GoString() string

func (*ServiceTokenResponse) Marshal 

func (m *ServiceTokenResponse) Marshal() (dAtA []byte, err error)

func (*ServiceTokenResponse) MarshalJSON 

func (msg *ServiceTokenResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ServiceTokenResponse) MarshalTo 

func (m *ServiceTokenResponse) MarshalTo(dAtA []byte) (int, error)

func (*ServiceTokenResponse) MarshalToSizedBuffer 

func (m *ServiceTokenResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceTokenResponse) ProtoMessage 

func (*ServiceTokenResponse) ProtoMessage()

func (*ServiceTokenResponse) Reset 

func (m *ServiceTokenResponse) Reset()

func (*ServiceTokenResponse) Size 

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

func (*ServiceTokenResponse) String 

func (this *ServiceTokenResponse) String() string

func (*ServiceTokenResponse) Unmarshal 

func (m *ServiceTokenResponse) Unmarshal(dAtA []byte) error

func (*ServiceTokenResponse) UnmarshalJSON 

func (msg *ServiceTokenResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*ServiceTokenResponse) XXX_DiscardUnknown 

func (m *ServiceTokenResponse) XXX_DiscardUnknown()

func (*ServiceTokenResponse) XXX_Marshal 

func (m *ServiceTokenResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceTokenResponse) XXX_Merge 

func (m *ServiceTokenResponse) XXX_Merge(src proto.Message)

func (*ServiceTokenResponse) XXX_Size 

func (m *ServiceTokenResponse) XXX_Size() int

func (*ServiceTokenResponse) XXX_Unmarshal 

func (m *ServiceTokenResponse) XXX_Unmarshal(b []byte) error

type SessionIdentification 

type SessionIdentification struct {
	ServiceId  *ULID  `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	ProtocolId string `protobuf:"bytes,2,opt,name=protocol_id,json=protocolId,proto3" json:"protocol_id,omitempty"`
}

func (*SessionIdentification) Descriptor 

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

func (*SessionIdentification) Equal 

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

func (*SessionIdentification) GetProtocolId 

func (m *SessionIdentification) GetProtocolId() string

func (*SessionIdentification) GetServiceId 

func (m *SessionIdentification) GetServiceId() *ULID

func (*SessionIdentification) GoString 

func (this *SessionIdentification) GoString() string

func (*SessionIdentification) Marshal 

func (m *SessionIdentification) Marshal() (dAtA []byte, err error)

func (*SessionIdentification) MarshalJSON 

func (msg *SessionIdentification) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*SessionIdentification) MarshalTo 

func (m *SessionIdentification) MarshalTo(dAtA []byte) (int, error)

func (*SessionIdentification) MarshalToSizedBuffer 

func (m *SessionIdentification) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SessionIdentification) ProtoMessage 

func (*SessionIdentification) ProtoMessage()

func (*SessionIdentification) Reset 

func (m *SessionIdentification) Reset()

func (*SessionIdentification) Size 

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

func (*SessionIdentification) String 

func (this *SessionIdentification) String() string

func (*SessionIdentification) Unmarshal 

func (m *SessionIdentification) Unmarshal(dAtA []byte) error

func (*SessionIdentification) UnmarshalJSON 

func (msg *SessionIdentification) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*SessionIdentification) XXX_DiscardUnknown 

func (m *SessionIdentification) XXX_DiscardUnknown()

func (*SessionIdentification) XXX_Marshal 

func (m *SessionIdentification) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SessionIdentification) XXX_Merge 

func (m *SessionIdentification) XXX_Merge(src proto.Message)

func (*SessionIdentification) XXX_Size 

func (m *SessionIdentification) XXX_Size() int

func (*SessionIdentification) XXX_Unmarshal 

func (m *SessionIdentification) XXX_Unmarshal(b []byte) error

type Signature 

type Signature struct {
	Signature []byte            `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty"`
	SigType   Signature_SigType `protobuf:"varint,2,opt,name=sig_type,json=sigType,proto3,enum=pb.Signature_SigType" json:"sig_type,omitempty"`
	KeyId     string            `protobuf:"bytes,3,opt,name=key_id,json=keyId,proto3" json:"key_id,omitempty"`
	Headers   *Headers          `protobuf:"bytes,4,opt,name=headers,proto3" json:"headers,omitempty"`
}

func (*Signature) Descriptor 

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

func (*Signature) Equal 

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

func (*Signature) GetHeaders 

func (m *Signature) GetHeaders() *Headers

func (*Signature) GetKeyId 

func (m *Signature) GetKeyId() string

func (*Signature) GetSigType 

func (m *Signature) GetSigType() Signature_SigType

func (*Signature) GetSignature 

func (m *Signature) GetSignature() []byte

func (*Signature) GoString 

func (this *Signature) GoString() string

func (*Signature) Marshal 

func (m *Signature) Marshal() (dAtA []byte, err error)

func (*Signature) MarshalJSON 

func (msg *Signature) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Signature) MarshalTo 

func (m *Signature) MarshalTo(dAtA []byte) (int, error)

func (*Signature) MarshalToSizedBuffer 

func (m *Signature) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Signature) ProtoMessage 

func (*Signature) ProtoMessage()

func (*Signature) Reset 

func (m *Signature) Reset()

func (*Signature) Size 

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

func (*Signature) String 

func (this *Signature) String() string

func (*Signature) Unmarshal 

func (m *Signature) Unmarshal(dAtA []byte) error

func (*Signature) UnmarshalJSON 

func (msg *Signature) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Signature) XXX_DiscardUnknown 

func (m *Signature) XXX_DiscardUnknown()

func (*Signature) XXX_Marshal 

func (m *Signature) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Signature) XXX_Merge 

func (m *Signature) XXX_Merge(src proto.Message)

func (*Signature) XXX_Size 

func (m *Signature) XXX_Size() int

func (*Signature) XXX_Unmarshal 

func (m *Signature) XXX_Unmarshal(b []byte) error

type Signature_SigType 

type Signature_SigType int32
const (
	BLAKE2HMAC Signature_SigType = 0
	ED25519    Signature_SigType = 1
	EXTERNAL   Signature_SigType = 2
)

func (Signature_SigType) EnumDescriptor 

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

func (Signature_SigType) String 

func (x Signature_SigType) String() string

type Timestamp 

type Timestamp struct {
	Sec  uint64 `protobuf:"varint,1,opt,name=sec,proto3" json:"sec,omitempty"`
	Nsec uint64 `protobuf:"varint,2,opt,name=nsec,proto3" json:"nsec,omitempty"`
}

func NewTimestamp 

func NewTimestamp(t time.Time) *Timestamp

func TimestampFromDuration 

func TimestampFromDuration(dur time.Duration) *Timestamp

func (*Timestamp) Descriptor 

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

func (*Timestamp) Equal 

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

func (*Timestamp) GetNsec 

func (m *Timestamp) GetNsec() uint64

func (*Timestamp) GetSec 

func (m *Timestamp) GetSec() uint64

func (*Timestamp) GoString 

func (this *Timestamp) GoString() string

func (*Timestamp) Marshal 

func (m *Timestamp) Marshal() (dAtA []byte, err error)

func (*Timestamp) MarshalJSON 

func (msg *Timestamp) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Timestamp) MarshalTo 

func (m *Timestamp) MarshalTo(dAtA []byte) (int, error)

func (*Timestamp) MarshalToSizedBuffer 

func (m *Timestamp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Timestamp) ProtoMessage 

func (*Timestamp) ProtoMessage()

func (*Timestamp) Reset 

func (m *Timestamp) Reset()

func (*Timestamp) Size 

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

func (*Timestamp) String 

func (this *Timestamp) String() string

func (*Timestamp) Time 

func (t *Timestamp) Time() time.Time

func (*Timestamp) ToDuration 

func (t *Timestamp) ToDuration() time.Duration

func (*Timestamp) Unmarshal 

func (m *Timestamp) Unmarshal(dAtA []byte) error

func (*Timestamp) UnmarshalJSON 

func (msg *Timestamp) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Timestamp) XXX_DiscardUnknown 

func (m *Timestamp) XXX_DiscardUnknown()

func (*Timestamp) XXX_Marshal 

func (m *Timestamp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Timestamp) XXX_Merge 

func (m *Timestamp) XXX_Merge(src proto.Message)

func (*Timestamp) XXX_Size 

func (m *Timestamp) XXX_Size() int

func (*Timestamp) XXX_Unmarshal 

func (m *Timestamp) XXX_Unmarshal(b []byte) error

type Token 

type Token struct {
	Body       []byte       `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	Metadata   *Headers     `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Signatures []*Signature `protobuf:"bytes,3,rep,name=signatures,proto3" json:"signatures,omitempty"`
}

func (*Token) Descriptor 

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

func (*Token) Equal 

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

func (*Token) GetBody 

func (m *Token) GetBody() []byte

func (*Token) GetMetadata 

func (m *Token) GetMetadata() *Headers

func (*Token) GetSignatures 

func (m *Token) GetSignatures() []*Signature

func (*Token) GoString 

func (this *Token) GoString() string

func (*Token) Marshal 

func (m *Token) Marshal() (dAtA []byte, err error)

func (*Token) MarshalJSON 

func (msg *Token) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Token) MarshalTo 

func (m *Token) MarshalTo(dAtA []byte) (int, error)

func (*Token) MarshalToSizedBuffer 

func (m *Token) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Token) ProtoMessage 

func (*Token) ProtoMessage()

func (*Token) Reset 

func (m *Token) Reset()

func (*Token) Size 

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

func (*Token) String 

func (this *Token) String() string

func (*Token) Unmarshal 

func (m *Token) Unmarshal(dAtA []byte) error

func (*Token) UnmarshalJSON 

func (msg *Token) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Token) XXX_DiscardUnknown 

func (m *Token) XXX_DiscardUnknown()

func (*Token) XXX_Marshal 

func (m *Token) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Token) XXX_Merge 

func (m *Token) XXX_Merge(src proto.Message)

func (*Token) XXX_Size 

func (m *Token) XXX_Size() int

func (*Token) XXX_Unmarshal 

func (m *Token) XXX_Unmarshal(b []byte) error

type TokenCapability 

type TokenCapability struct {
	Capability Capability `protobuf:"varint,1,opt,name=capability,proto3,enum=pb.Capability" json:"capability,omitempty"`
	Value      string     `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*TokenCapability) Descriptor 

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

func (*TokenCapability) Equal 

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

func (*TokenCapability) GetCapability 

func (m *TokenCapability) GetCapability() Capability

func (*TokenCapability) GetValue 

func (m *TokenCapability) GetValue() string

func (*TokenCapability) GoString 

func (this *TokenCapability) GoString() string

func (*TokenCapability) Marshal 

func (m *TokenCapability) Marshal() (dAtA []byte, err error)

func (*TokenCapability) MarshalJSON 

func (msg *TokenCapability) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*TokenCapability) MarshalTo 

func (m *TokenCapability) MarshalTo(dAtA []byte) (int, error)

func (*TokenCapability) MarshalToSizedBuffer 

func (m *TokenCapability) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TokenCapability) ProtoMessage 

func (*TokenCapability) ProtoMessage()

func (*TokenCapability) Reset 

func (m *TokenCapability) Reset()

func (*TokenCapability) Size 

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

func (*TokenCapability) String 

func (this *TokenCapability) String() string

func (*TokenCapability) Unmarshal 

func (m *TokenCapability) Unmarshal(dAtA []byte) error

func (*TokenCapability) UnmarshalJSON 

func (msg *TokenCapability) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*TokenCapability) XXX_DiscardUnknown 

func (m *TokenCapability) XXX_DiscardUnknown()

func (*TokenCapability) XXX_Marshal 

func (m *TokenCapability) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TokenCapability) XXX_Merge 

func (m *TokenCapability) XXX_Merge(src proto.Message)

func (*TokenCapability) XXX_Size 

func (m *TokenCapability) XXX_Size() int

func (*TokenCapability) XXX_Unmarshal 

func (m *TokenCapability) XXX_Unmarshal(b []byte) error

type TokenInfo 

type TokenInfo struct {
	PublicKey []byte `protobuf:"bytes,1,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
}

func (*TokenInfo) Descriptor 

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

func (*TokenInfo) Equal 

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

func (*TokenInfo) GetPublicKey 

func (m *TokenInfo) GetPublicKey() []byte

func (*TokenInfo) GoString 

func (this *TokenInfo) GoString() string

func (*TokenInfo) Marshal 

func (m *TokenInfo) Marshal() (dAtA []byte, err error)

func (*TokenInfo) MarshalJSON 

func (msg *TokenInfo) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*TokenInfo) MarshalTo 

func (m *TokenInfo) MarshalTo(dAtA []byte) (int, error)

func (*TokenInfo) MarshalToSizedBuffer 

func (m *TokenInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TokenInfo) ProtoMessage 

func (*TokenInfo) ProtoMessage()

func (*TokenInfo) Reset 

func (m *TokenInfo) Reset()

func (*TokenInfo) Size 

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

func (*TokenInfo) String 

func (this *TokenInfo) String() string

func (*TokenInfo) Unmarshal 

func (m *TokenInfo) Unmarshal(dAtA []byte) error

func (*TokenInfo) UnmarshalJSON 

func (msg *TokenInfo) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*TokenInfo) XXX_DiscardUnknown 

func (m *TokenInfo) XXX_DiscardUnknown()

func (*TokenInfo) XXX_Marshal 

func (m *TokenInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TokenInfo) XXX_Merge 

func (m *TokenInfo) XXX_Merge(src proto.Message)

func (*TokenInfo) XXX_Size 

func (m *TokenInfo) XXX_Size() int

func (*TokenInfo) XXX_Unmarshal 

func (m *TokenInfo) XXX_Unmarshal(b []byte) error

type TokenRole 

type TokenRole int32
const (
	AGENT  TokenRole = 0
	HUB    TokenRole = 1
	MANAGE TokenRole = 2
)

func (TokenRole) EnumDescriptor 

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

func (TokenRole) String 

func (x TokenRole) String() string

type Token_Body 

type Token_Body struct {
	Role         TokenRole         `protobuf:"varint,1,opt,name=role,proto3,enum=pb.TokenRole" json:"role,omitempty"`
	Id           *ULID             `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Account      *Account          `protobuf:"bytes,3,opt,name=account,proto3" json:"account,omitempty"`
	ValidUntil   *Timestamp        `protobuf:"bytes,4,opt,name=valid_until,json=validUntil,proto3" json:"valid_until,omitempty"`
	Capabilities []TokenCapability `protobuf:"bytes,5,rep,name=capabilities,proto3" json:"capabilities"`
	Additional   *Headers          `protobuf:"bytes,10,opt,name=additional,proto3" json:"additional,omitempty"`
}

func (*Token_Body) Descriptor 

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

func (*Token_Body) Equal 

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

func (*Token_Body) GetAccount 

func (m *Token_Body) GetAccount() *Account

func (*Token_Body) GetAdditional 

func (m *Token_Body) GetAdditional() *Headers

func (*Token_Body) GetCapabilities 

func (m *Token_Body) GetCapabilities() []TokenCapability

func (*Token_Body) GetId 

func (m *Token_Body) GetId() *ULID

func (*Token_Body) GetRole 

func (m *Token_Body) GetRole() TokenRole

func (*Token_Body) GetValidUntil 

func (m *Token_Body) GetValidUntil() *Timestamp

func (*Token_Body) GoString 

func (this *Token_Body) GoString() string

func (*Token_Body) Marshal 

func (m *Token_Body) Marshal() (dAtA []byte, err error)

func (*Token_Body) MarshalJSON 

func (msg *Token_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Token_Body) MarshalTo 

func (m *Token_Body) MarshalTo(dAtA []byte) (int, error)

func (*Token_Body) MarshalToSizedBuffer 

func (m *Token_Body) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Token_Body) ProtoMessage 

func (*Token_Body) ProtoMessage()

func (*Token_Body) Reset 

func (m *Token_Body) Reset()

func (*Token_Body) Size 

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

func (*Token_Body) String 

func (this *Token_Body) String() string

func (*Token_Body) Unmarshal 

func (m *Token_Body) Unmarshal(dAtA []byte) error

func (*Token_Body) UnmarshalJSON 

func (msg *Token_Body) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Token_Body) XXX_DiscardUnknown 

func (m *Token_Body) XXX_DiscardUnknown()

func (*Token_Body) XXX_Marshal 

func (m *Token_Body) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Token_Body) XXX_Merge 

func (m *Token_Body) XXX_Merge(src proto.Message)

func (*Token_Body) XXX_Size 

func (m *Token_Body) XXX_Size() int

func (*Token_Body) XXX_Unmarshal 

func (m *Token_Body) XXX_Unmarshal(b []byte) error

type ULID 

type ULID struct {
	Timestamp uint64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Entropy   []byte `protobuf:"bytes,2,opt,name=entropy,proto3" json:"entropy,omitempty"`
}
var InternalAccount *ULID

Used when generating internal tokens for use by hub services

func NewULID 

func NewULID() *ULID

func ParseULID 

func ParseULID(s string) (*ULID, error)

func ULIDFromBytes 

func ULIDFromBytes(b []byte) *ULID

func (ULID) Bytes 

func (u ULID) Bytes() []byte

func (*ULID) Descriptor 

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

func (*ULID) Equal 

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

func (*ULID) GetEntropy 

func (m *ULID) GetEntropy() []byte

func (*ULID) GetTimestamp 

func (m *ULID) GetTimestamp() uint64

func (*ULID) GoString 

func (this *ULID) GoString() string

func (*ULID) Marshal 

func (m *ULID) Marshal() (dAtA []byte, err error)

func (*ULID) MarshalJSON 

func (msg *ULID) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ULID) MarshalTo 

func (m *ULID) MarshalTo(dAtA []byte) (int, error)

func (*ULID) MarshalToSizedBuffer 

func (m *ULID) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ULID) ProtoMessage 

func (*ULID) ProtoMessage()

func (*ULID) Reset 

func (m *ULID) Reset()

func (*ULID) Size 

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

func (*ULID) SpecString 

func (u *ULID) SpecString() string

func (*ULID) String 

func (u *ULID) String() string

func (*ULID) Time 

func (u *ULID) Time() time.Time

func (*ULID) Unmarshal 

func (m *ULID) Unmarshal(dAtA []byte) error

func (*ULID) UnmarshalJSON 

func (msg *ULID) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*ULID) XXX_DiscardUnknown 

func (m *ULID) XXX_DiscardUnknown()

func (*ULID) XXX_Marshal 

func (m *ULID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ULID) XXX_Merge 

func (m *ULID) XXX_Merge(src proto.Message)

func (*ULID) XXX_Size 

func (m *ULID) XXX_Size() int

func (*ULID) XXX_Unmarshal 

func (m *ULID) XXX_Unmarshal(b []byte) error

type ULIDWithDuration 

type ULIDWithDuration struct {
	Ulid   *ULID  `protobuf:"bytes,1,opt,name=ulid,proto3" json:"ulid,omitempty"`
	Elapse uint64 `protobuf:"varint,2,opt,name=elapse,proto3" json:"elapse,omitempty"`
}

func (*ULIDWithDuration) Descriptor 

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

func (*ULIDWithDuration) Equal 

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

func (*ULIDWithDuration) GetElapse 

func (m *ULIDWithDuration) GetElapse() uint64

func (*ULIDWithDuration) GetUlid 

func (m *ULIDWithDuration) GetUlid() *ULID

func (*ULIDWithDuration) GoString 

func (this *ULIDWithDuration) GoString() string

func (*ULIDWithDuration) Marshal 

func (m *ULIDWithDuration) Marshal() (dAtA []byte, err error)

func (*ULIDWithDuration) MarshalJSON 

func (msg *ULIDWithDuration) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ULIDWithDuration) MarshalTo 

func (m *ULIDWithDuration) MarshalTo(dAtA []byte) (int, error)

func (*ULIDWithDuration) MarshalToSizedBuffer 

func (m *ULIDWithDuration) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ULIDWithDuration) ProtoMessage 

func (*ULIDWithDuration) ProtoMessage()

func (*ULIDWithDuration) Reset 

func (m *ULIDWithDuration) Reset()

func (*ULIDWithDuration) Size 

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

func (*ULIDWithDuration) String 

func (this *ULIDWithDuration) String() string

func (*ULIDWithDuration) Unmarshal 

func (m *ULIDWithDuration) Unmarshal(dAtA []byte) error

func (*ULIDWithDuration) UnmarshalJSON 

func (msg *ULIDWithDuration) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*ULIDWithDuration) XXX_DiscardUnknown 

func (m *ULIDWithDuration) XXX_DiscardUnknown()

func (*ULIDWithDuration) XXX_Marshal 

func (m *ULIDWithDuration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ULIDWithDuration) XXX_Merge 

func (m *ULIDWithDuration) XXX_Merge(src proto.Message)

func (*ULIDWithDuration) XXX_Size 

func (m *ULIDWithDuration) XXX_Size() int

func (*ULIDWithDuration) XXX_Unmarshal 

func (m *ULIDWithDuration) XXX_Unmarshal(b []byte) error

type UnimplementedControlManagementServer 

type UnimplementedControlManagementServer struct {
}

UnimplementedControlManagementServer can be embedded to have forward compatible implementations.

func (*UnimplementedControlManagementServer) AddAccount 

func (*UnimplementedControlManagementServer) AddAccount(ctx context.Context, req *AddAccountRequest) (*Noop, error)
func (*UnimplementedControlManagementServer) AddLabelLink(ctx context.Context, req *AddLabelLinkRequest) (*Noop, error)

func (*UnimplementedControlManagementServer) CreateToken 

func (*UnimplementedControlManagementServer) CreateToken(ctx context.Context, req *CreateTokenRequest) (*CreateTokenResponse, error)

func (*UnimplementedControlManagementServer) GetTokenPublicKey 

func (*UnimplementedControlManagementServer) GetTokenPublicKey(ctx context.Context, req *Noop) (*TokenInfo, error)

func (*UnimplementedControlManagementServer) IssueHubToken 

func (*UnimplementedControlManagementServer) IssueHubToken(ctx context.Context, req *Noop) (*CreateTokenResponse, error)

func (*UnimplementedControlManagementServer) ListAccounts 

func (*UnimplementedControlManagementServer) ListAccounts(ctx context.Context, req *ListAccountsRequest) (*ListAccountsResponse, error)

func (*UnimplementedControlManagementServer) Register 

func (*UnimplementedControlManagementServer) Register(ctx context.Context, req *ControlRegister) (*ControlToken, error)
func (*UnimplementedControlManagementServer) RemoveLabelLink(ctx context.Context, req *RemoveLabelLinkRequest) (*Noop, error)

type UnimplementedControlServicesServer 

type UnimplementedControlServicesServer struct {
}

UnimplementedControlServicesServer can be embedded to have forward compatible implementations.

func (*UnimplementedControlServicesServer) AddService 

func (*UnimplementedControlServicesServer) AddService(ctx context.Context, req *ServiceRequest) (*ServiceResponse, error)

func (*UnimplementedControlServicesServer) AllHubs 

func (*UnimplementedControlServicesServer) AllHubs(ctx context.Context, req *Noop) (*ListOfHubs, error)

func (*UnimplementedControlServicesServer) FetchConfig 

func (*UnimplementedControlServicesServer) FetchConfig(ctx context.Context, req *ConfigRequest) (*ConfigResponse, error)

func (*UnimplementedControlServicesServer) HubDisconnect 

func (*UnimplementedControlServicesServer) HubDisconnect(ctx context.Context, req *HubDisconnectRequest) (*Noop, error)

func (*UnimplementedControlServicesServer) ListServices 

func (*UnimplementedControlServicesServer) ListServices(ctx context.Context, req *ListServicesRequest) (*ListServicesResponse, error)

func (*UnimplementedControlServicesServer) RemoveService 

func (*UnimplementedControlServicesServer) RemoveService(ctx context.Context, req *ServiceRequest) (*ServiceResponse, error)

func (*UnimplementedControlServicesServer) RequestServiceToken 

func (*UnimplementedControlServicesServer) RequestServiceToken(ctx context.Context, req *ServiceTokenRequest) (*ServiceTokenResponse, error)

func (*UnimplementedControlServicesServer) StreamActivity 

func (*UnimplementedControlServicesServer) StreamActivity(srv ControlServices_StreamActivityServer) error

func (*UnimplementedControlServicesServer) SyncHub 

func (*UnimplementedControlServicesServer) SyncHub(ctx context.Context, req *HubSync) (*HubSyncResponse, error)

type UnimplementedEdgeServicesServer 

type UnimplementedEdgeServicesServer struct {
}

UnimplementedEdgeServicesServer can be embedded to have forward compatible implementations.

func (*UnimplementedEdgeServicesServer) LookupEndpoints 

func (*UnimplementedEdgeServicesServer) LookupEndpoints(ctx context.Context, req *LookupEndpointsRequest) (*LookupEndpointsResponse, error)
func (*UnimplementedEdgeServicesServer) ResolveLabelLink(ctx context.Context, req *ResolveLabelLinkRequest) (*ResolveLabelLinkResponse, error)

type UnimplementedFlowTopReporterServer 

type UnimplementedFlowTopReporterServer struct {
}

UnimplementedFlowTopReporterServer can be embedded to have forward compatible implementations.

func (*UnimplementedFlowTopReporterServer) CurrentFlowTop 

func (*UnimplementedFlowTopReporterServer) CurrentFlowTop(ctx context.Context, req *FlowTopRequest) (*FlowTopSnapshot, error)

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.