rendezvous_pb

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Jun 19, 2023 License: MIT Imports: 5 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRendezvous        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRendezvous          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRendezvous = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Message_MessageType_name = map[int32]string{
	0:   "REGISTER",
	1:   "REGISTER_RESPONSE",
	2:   "UNREGISTER",
	3:   "DISCOVER",
	4:   "DISCOVER_RESPONSE",
	100: "DISCOVER_SUBSCRIBE",
	101: "DISCOVER_SUBSCRIBE_RESPONSE",
}
View Source 
var Message_MessageType_value = map[string]int32{
	"REGISTER":                    0,
	"REGISTER_RESPONSE":           1,
	"UNREGISTER":                  2,
	"DISCOVER":                    3,
	"DISCOVER_RESPONSE":           4,
	"DISCOVER_SUBSCRIBE":          100,
	"DISCOVER_SUBSCRIBE_RESPONSE": 101,
}
View Source 
var Message_ResponseStatus_name = map[int32]string{
	0:   "OK",
	100: "E_INVALID_NAMESPACE",
	101: "E_INVALID_PEER_INFO",
	102: "E_INVALID_TTL",
	103: "E_INVALID_COOKIE",
	200: "E_NOT_AUTHORIZED",
	300: "E_INTERNAL_ERROR",
	400: "E_UNAVAILABLE",
}
View Source 
var Message_ResponseStatus_value = map[string]int32{
	"OK":                  0,
	"E_INVALID_NAMESPACE": 100,
	"E_INVALID_PEER_INFO": 101,
	"E_INVALID_TTL":       102,
	"E_INVALID_COOKIE":    103,
	"E_NOT_AUTHORIZED":    200,
	"E_INTERNAL_ERROR":    300,
	"E_UNAVAILABLE":       400,
}

Functions

This section is empty.

Types

type Message 

type Message struct {
	Type                      Message_MessageType                `protobuf:"varint,1,opt,name=type,proto3,enum=rendezvous.pb.Message_MessageType" json:"type,omitempty"`
	Register                  *Message_Register                  `protobuf:"bytes,2,opt,name=register,proto3" json:"register,omitempty"`
	RegisterResponse          *Message_RegisterResponse          `protobuf:"bytes,3,opt,name=registerResponse,proto3" json:"registerResponse,omitempty"`
	Unregister                *Message_Unregister                `protobuf:"bytes,4,opt,name=unregister,proto3" json:"unregister,omitempty"`
	Discover                  *Message_Discover                  `protobuf:"bytes,5,opt,name=discover,proto3" json:"discover,omitempty"`
	DiscoverResponse          *Message_DiscoverResponse          `protobuf:"bytes,6,opt,name=discoverResponse,proto3" json:"discoverResponse,omitempty"`
	DiscoverSubscribe         *Message_DiscoverSubscribe         `protobuf:"bytes,100,opt,name=discoverSubscribe,proto3" json:"discoverSubscribe,omitempty"`
	DiscoverSubscribeResponse *Message_DiscoverSubscribeResponse `protobuf:"bytes,101,opt,name=discoverSubscribeResponse,proto3" json:"discoverSubscribeResponse,omitempty"`
	XXX_NoUnkeyedLiteral      struct{}                           `json:"-"`
	XXX_unrecognized          []byte                             `json:"-"`
	XXX_sizecache             int32                              `json:"-"`
}

func (*Message) Descriptor 

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

func (*Message) GetDiscover 

func (m *Message) GetDiscover() *Message_Discover

func (*Message) GetDiscoverResponse 

func (m *Message) GetDiscoverResponse() *Message_DiscoverResponse

func (*Message) GetDiscoverSubscribe 

func (m *Message) GetDiscoverSubscribe() *Message_DiscoverSubscribe

func (*Message) GetDiscoverSubscribeResponse 

func (m *Message) GetDiscoverSubscribeResponse() *Message_DiscoverSubscribeResponse

func (*Message) GetRegister 

func (m *Message) GetRegister() *Message_Register

func (*Message) GetRegisterResponse 

func (m *Message) GetRegisterResponse() *Message_RegisterResponse

func (*Message) GetType 

func (m *Message) GetType() Message_MessageType

func (*Message) GetUnregister 

func (m *Message) GetUnregister() *Message_Unregister

func (*Message) Marshal 

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

func (*Message) MarshalTo 

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

func (*Message) MarshalToSizedBuffer 

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

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) Size 

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

func (*Message) String 

func (m *Message) String() string

func (*Message) Unmarshal 

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

func (*Message) XXX_DiscardUnknown 

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal 

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

func (*Message) XXX_Merge 

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

func (*Message) XXX_Size 

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal 

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

type Message_Discover 

type Message_Discover struct {
	Ns                   string   `protobuf:"bytes,1,opt,name=ns,proto3" json:"ns,omitempty"`
	Limit                int64    `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	Cookie               []byte   `protobuf:"bytes,3,opt,name=cookie,proto3" json:"cookie,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Message_Discover) Descriptor 

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

func (*Message_Discover) GetCookie 

func (m *Message_Discover) GetCookie() []byte

func (*Message_Discover) GetLimit 

func (m *Message_Discover) GetLimit() int64

func (*Message_Discover) GetNs 

func (m *Message_Discover) GetNs() string

func (*Message_Discover) Marshal 

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

func (*Message_Discover) MarshalTo 

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

func (*Message_Discover) MarshalToSizedBuffer 

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

func (*Message_Discover) ProtoMessage 

func (*Message_Discover) ProtoMessage()

func (*Message_Discover) Reset 

func (m *Message_Discover) Reset()

func (*Message_Discover) Size 

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

func (*Message_Discover) String 

func (m *Message_Discover) String() string

func (*Message_Discover) Unmarshal 

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

func (*Message_Discover) XXX_DiscardUnknown 

func (m *Message_Discover) XXX_DiscardUnknown()

func (*Message_Discover) XXX_Marshal 

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

func (*Message_Discover) XXX_Merge 

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

func (*Message_Discover) XXX_Size 

func (m *Message_Discover) XXX_Size() int

func (*Message_Discover) XXX_Unmarshal 

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

type Message_DiscoverResponse 

type Message_DiscoverResponse struct {
	Registrations        []*Message_Register    `protobuf:"bytes,1,rep,name=registrations,proto3" json:"registrations,omitempty"`
	Cookie               []byte                 `protobuf:"bytes,2,opt,name=cookie,proto3" json:"cookie,omitempty"`
	Status               Message_ResponseStatus `protobuf:"varint,3,opt,name=status,proto3,enum=rendezvous.pb.Message_ResponseStatus" json:"status,omitempty"`
	StatusText           string                 `protobuf:"bytes,4,opt,name=statusText,proto3" json:"statusText,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*Message_DiscoverResponse) Descriptor 

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

func (*Message_DiscoverResponse) GetCookie 

func (m *Message_DiscoverResponse) GetCookie() []byte

func (*Message_DiscoverResponse) GetRegistrations 

func (m *Message_DiscoverResponse) GetRegistrations() []*Message_Register

func (*Message_DiscoverResponse) GetStatus 

func (m *Message_DiscoverResponse) GetStatus() Message_ResponseStatus

func (*Message_DiscoverResponse) GetStatusText 

func (m *Message_DiscoverResponse) GetStatusText() string

func (*Message_DiscoverResponse) Marshal 

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

func (*Message_DiscoverResponse) MarshalTo 

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

func (*Message_DiscoverResponse) MarshalToSizedBuffer 

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

func (*Message_DiscoverResponse) ProtoMessage 

func (*Message_DiscoverResponse) ProtoMessage()

func (*Message_DiscoverResponse) Reset 

func (m *Message_DiscoverResponse) Reset()

func (*Message_DiscoverResponse) Size 

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

func (*Message_DiscoverResponse) String 

func (m *Message_DiscoverResponse) String() string

func (*Message_DiscoverResponse) Unmarshal 

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

func (*Message_DiscoverResponse) XXX_DiscardUnknown 

func (m *Message_DiscoverResponse) XXX_DiscardUnknown()

func (*Message_DiscoverResponse) XXX_Marshal 

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

func (*Message_DiscoverResponse) XXX_Merge 

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

func (*Message_DiscoverResponse) XXX_Size 

func (m *Message_DiscoverResponse) XXX_Size() int

func (*Message_DiscoverResponse) XXX_Unmarshal 

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

type Message_DiscoverSubscribe 

type Message_DiscoverSubscribe struct {
	SupportedSubscriptionTypes []string `` /* 141-byte string literal not displayed */
	Ns                         string   `protobuf:"bytes,2,opt,name=ns,proto3" json:"ns,omitempty"`
	XXX_NoUnkeyedLiteral       struct{} `json:"-"`
	XXX_unrecognized           []byte   `json:"-"`
	XXX_sizecache              int32    `json:"-"`
}

func (*Message_DiscoverSubscribe) Descriptor 

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

func (*Message_DiscoverSubscribe) GetNs 

func (m *Message_DiscoverSubscribe) GetNs() string

func (*Message_DiscoverSubscribe) GetSupportedSubscriptionTypes 

func (m *Message_DiscoverSubscribe) GetSupportedSubscriptionTypes() []string

func (*Message_DiscoverSubscribe) Marshal 

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

func (*Message_DiscoverSubscribe) MarshalTo 

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

func (*Message_DiscoverSubscribe) MarshalToSizedBuffer 

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

func (*Message_DiscoverSubscribe) ProtoMessage 

func (*Message_DiscoverSubscribe) ProtoMessage()

func (*Message_DiscoverSubscribe) Reset 

func (m *Message_DiscoverSubscribe) Reset()

func (*Message_DiscoverSubscribe) Size 

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

func (*Message_DiscoverSubscribe) String 

func (m *Message_DiscoverSubscribe) String() string

func (*Message_DiscoverSubscribe) Unmarshal 

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

func (*Message_DiscoverSubscribe) XXX_DiscardUnknown 

func (m *Message_DiscoverSubscribe) XXX_DiscardUnknown()

func (*Message_DiscoverSubscribe) XXX_Marshal 

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

func (*Message_DiscoverSubscribe) XXX_Merge 

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

func (*Message_DiscoverSubscribe) XXX_Size 

func (m *Message_DiscoverSubscribe) XXX_Size() int

func (*Message_DiscoverSubscribe) XXX_Unmarshal 

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

type Message_DiscoverSubscribeResponse 

type Message_DiscoverSubscribeResponse struct {
	SubscriptionType     string                 `protobuf:"bytes,1,opt,name=subscription_type,json=subscriptionType,proto3" json:"subscription_type,omitempty"`
	SubscriptionDetails  string                 `protobuf:"bytes,2,opt,name=subscription_details,json=subscriptionDetails,proto3" json:"subscription_details,omitempty"`
	Status               Message_ResponseStatus `protobuf:"varint,3,opt,name=status,proto3,enum=rendezvous.pb.Message_ResponseStatus" json:"status,omitempty"`
	StatusText           string                 `protobuf:"bytes,4,opt,name=statusText,proto3" json:"statusText,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*Message_DiscoverSubscribeResponse) Descriptor 

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

func (*Message_DiscoverSubscribeResponse) GetStatus 

func (m *Message_DiscoverSubscribeResponse) GetStatus() Message_ResponseStatus

func (*Message_DiscoverSubscribeResponse) GetStatusText 

func (m *Message_DiscoverSubscribeResponse) GetStatusText() string

func (*Message_DiscoverSubscribeResponse) GetSubscriptionDetails 

func (m *Message_DiscoverSubscribeResponse) GetSubscriptionDetails() string

func (*Message_DiscoverSubscribeResponse) GetSubscriptionType 

func (m *Message_DiscoverSubscribeResponse) GetSubscriptionType() string

func (*Message_DiscoverSubscribeResponse) Marshal 

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

func (*Message_DiscoverSubscribeResponse) MarshalTo 

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

func (*Message_DiscoverSubscribeResponse) MarshalToSizedBuffer 

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

func (*Message_DiscoverSubscribeResponse) ProtoMessage 

func (*Message_DiscoverSubscribeResponse) ProtoMessage()

func (*Message_DiscoverSubscribeResponse) Reset 

func (m *Message_DiscoverSubscribeResponse) Reset()

func (*Message_DiscoverSubscribeResponse) Size 

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

func (*Message_DiscoverSubscribeResponse) String 

func (m *Message_DiscoverSubscribeResponse) String() string

func (*Message_DiscoverSubscribeResponse) Unmarshal 

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

func (*Message_DiscoverSubscribeResponse) XXX_DiscardUnknown 

func (m *Message_DiscoverSubscribeResponse) XXX_DiscardUnknown()

func (*Message_DiscoverSubscribeResponse) XXX_Marshal 

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

func (*Message_DiscoverSubscribeResponse) XXX_Merge 

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

func (*Message_DiscoverSubscribeResponse) XXX_Size 

func (m *Message_DiscoverSubscribeResponse) XXX_Size() int

func (*Message_DiscoverSubscribeResponse) XXX_Unmarshal 

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

type Message_MessageType 

type Message_MessageType int32
const (
	Message_REGISTER                    Message_MessageType = 0
	Message_REGISTER_RESPONSE           Message_MessageType = 1
	Message_UNREGISTER                  Message_MessageType = 2
	Message_DISCOVER                    Message_MessageType = 3
	Message_DISCOVER_RESPONSE           Message_MessageType = 4
	Message_DISCOVER_SUBSCRIBE          Message_MessageType = 100
	Message_DISCOVER_SUBSCRIBE_RESPONSE Message_MessageType = 101
)

func (Message_MessageType) EnumDescriptor 

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

func (Message_MessageType) String 

func (x Message_MessageType) String() string

type Message_PeerInfo 

type Message_PeerInfo struct {
	Id                   []byte   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Addrs                [][]byte `protobuf:"bytes,2,rep,name=addrs,proto3" json:"addrs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Message_PeerInfo) Descriptor 

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

func (*Message_PeerInfo) GetAddrs 

func (m *Message_PeerInfo) GetAddrs() [][]byte

func (*Message_PeerInfo) GetId 

func (m *Message_PeerInfo) GetId() []byte

func (*Message_PeerInfo) Marshal 

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

func (*Message_PeerInfo) MarshalTo 

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

func (*Message_PeerInfo) MarshalToSizedBuffer 

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

func (*Message_PeerInfo) ProtoMessage 

func (*Message_PeerInfo) ProtoMessage()

func (*Message_PeerInfo) Reset 

func (m *Message_PeerInfo) Reset()

func (*Message_PeerInfo) Size 

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

func (*Message_PeerInfo) String 

func (m *Message_PeerInfo) String() string

func (*Message_PeerInfo) Unmarshal 

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

func (*Message_PeerInfo) XXX_DiscardUnknown 

func (m *Message_PeerInfo) XXX_DiscardUnknown()

func (*Message_PeerInfo) XXX_Marshal 

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

func (*Message_PeerInfo) XXX_Merge 

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

func (*Message_PeerInfo) XXX_Size 

func (m *Message_PeerInfo) XXX_Size() int

func (*Message_PeerInfo) XXX_Unmarshal 

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

type Message_Register 

type Message_Register struct {
	Ns                   string            `protobuf:"bytes,1,opt,name=ns,proto3" json:"ns,omitempty"`
	Peer                 *Message_PeerInfo `protobuf:"bytes,2,opt,name=peer,proto3" json:"peer,omitempty"`
	Ttl                  int64             `protobuf:"varint,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Message_Register) Descriptor 

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

func (*Message_Register) GetNs 

func (m *Message_Register) GetNs() string

func (*Message_Register) GetPeer 

func (m *Message_Register) GetPeer() *Message_PeerInfo

func (*Message_Register) GetTtl 

func (m *Message_Register) GetTtl() int64

func (*Message_Register) Marshal 

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

func (*Message_Register) MarshalTo 

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

func (*Message_Register) MarshalToSizedBuffer 

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

func (*Message_Register) ProtoMessage 

func (*Message_Register) ProtoMessage()

func (*Message_Register) Reset 

func (m *Message_Register) Reset()

func (*Message_Register) Size 

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

func (*Message_Register) String 

func (m *Message_Register) String() string

func (*Message_Register) Unmarshal 

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

func (*Message_Register) XXX_DiscardUnknown 

func (m *Message_Register) XXX_DiscardUnknown()

func (*Message_Register) XXX_Marshal 

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

func (*Message_Register) XXX_Merge 

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

func (*Message_Register) XXX_Size 

func (m *Message_Register) XXX_Size() int

func (*Message_Register) XXX_Unmarshal 

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

type Message_RegisterResponse 

type Message_RegisterResponse struct {
	Status               Message_ResponseStatus `protobuf:"varint,1,opt,name=status,proto3,enum=rendezvous.pb.Message_ResponseStatus" json:"status,omitempty"`
	StatusText           string                 `protobuf:"bytes,2,opt,name=statusText,proto3" json:"statusText,omitempty"`
	Ttl                  int64                  `protobuf:"varint,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*Message_RegisterResponse) Descriptor 

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

func (*Message_RegisterResponse) GetStatus 

func (m *Message_RegisterResponse) GetStatus() Message_ResponseStatus

func (*Message_RegisterResponse) GetStatusText 

func (m *Message_RegisterResponse) GetStatusText() string

func (*Message_RegisterResponse) GetTtl 

func (m *Message_RegisterResponse) GetTtl() int64

func (*Message_RegisterResponse) Marshal 

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

func (*Message_RegisterResponse) MarshalTo 

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

func (*Message_RegisterResponse) MarshalToSizedBuffer 

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

func (*Message_RegisterResponse) ProtoMessage 

func (*Message_RegisterResponse) ProtoMessage()

func (*Message_RegisterResponse) Reset 

func (m *Message_RegisterResponse) Reset()

func (*Message_RegisterResponse) Size 

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

func (*Message_RegisterResponse) String 

func (m *Message_RegisterResponse) String() string

func (*Message_RegisterResponse) Unmarshal 

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

func (*Message_RegisterResponse) XXX_DiscardUnknown 

func (m *Message_RegisterResponse) XXX_DiscardUnknown()

func (*Message_RegisterResponse) XXX_Marshal 

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

func (*Message_RegisterResponse) XXX_Merge 

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

func (*Message_RegisterResponse) XXX_Size 

func (m *Message_RegisterResponse) XXX_Size() int

func (*Message_RegisterResponse) XXX_Unmarshal 

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

type Message_ResponseStatus 

type Message_ResponseStatus int32
const (
	Message_OK                  Message_ResponseStatus = 0
	Message_E_INVALID_NAMESPACE Message_ResponseStatus = 100
	Message_E_INVALID_PEER_INFO Message_ResponseStatus = 101
	Message_E_INVALID_TTL       Message_ResponseStatus = 102
	Message_E_INVALID_COOKIE    Message_ResponseStatus = 103
	Message_E_NOT_AUTHORIZED    Message_ResponseStatus = 200
	Message_E_INTERNAL_ERROR    Message_ResponseStatus = 300
	Message_E_UNAVAILABLE       Message_ResponseStatus = 400
)

func (Message_ResponseStatus) EnumDescriptor 

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

func (Message_ResponseStatus) String 

func (x Message_ResponseStatus) String() string

type Message_Unregister 

type Message_Unregister struct {
	Ns                   string   `protobuf:"bytes,1,opt,name=ns,proto3" json:"ns,omitempty"`
	Id                   []byte   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Message_Unregister) Descriptor 

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

func (*Message_Unregister) GetId 

func (m *Message_Unregister) GetId() []byte

func (*Message_Unregister) GetNs 

func (m *Message_Unregister) GetNs() string

func (*Message_Unregister) Marshal 

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

func (*Message_Unregister) MarshalTo 

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

func (*Message_Unregister) MarshalToSizedBuffer 

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

func (*Message_Unregister) ProtoMessage 

func (*Message_Unregister) ProtoMessage()

func (*Message_Unregister) Reset 

func (m *Message_Unregister) Reset()

func (*Message_Unregister) Size 

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

func (*Message_Unregister) String 

func (m *Message_Unregister) String() string

func (*Message_Unregister) Unmarshal 

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

func (*Message_Unregister) XXX_DiscardUnknown 

func (m *Message_Unregister) XXX_DiscardUnknown()

func (*Message_Unregister) XXX_Marshal 

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

func (*Message_Unregister) XXX_Merge 

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

func (*Message_Unregister) XXX_Size 

func (m *Message_Unregister) XXX_Size() int

func (*Message_Unregister) XXX_Unmarshal 

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

type RegistrationRecord 

type RegistrationRecord struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Addrs                [][]byte `protobuf:"bytes,2,rep,name=addrs,proto3" json:"addrs,omitempty"`
	Ns                   string   `protobuf:"bytes,3,opt,name=ns,proto3" json:"ns,omitempty"`
	Ttl                  int64    `protobuf:"varint,4,opt,name=ttl,proto3" json:"ttl,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegistrationRecord) Descriptor 

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

func (*RegistrationRecord) GetAddrs 

func (m *RegistrationRecord) GetAddrs() [][]byte

func (*RegistrationRecord) GetId 

func (m *RegistrationRecord) GetId() string

func (*RegistrationRecord) GetNs 

func (m *RegistrationRecord) GetNs() string

func (*RegistrationRecord) GetTtl 

func (m *RegistrationRecord) GetTtl() int64

func (*RegistrationRecord) Marshal 

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

func (*RegistrationRecord) MarshalTo 

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

func (*RegistrationRecord) MarshalToSizedBuffer 

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

func (*RegistrationRecord) ProtoMessage 

func (*RegistrationRecord) ProtoMessage()

func (*RegistrationRecord) Reset 

func (m *RegistrationRecord) Reset()

func (*RegistrationRecord) Size 

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

func (*RegistrationRecord) String 

func (m *RegistrationRecord) String() string

func (*RegistrationRecord) Unmarshal 

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

func (*RegistrationRecord) XXX_DiscardUnknown 

func (m *RegistrationRecord) XXX_DiscardUnknown()

func (*RegistrationRecord) XXX_Marshal 

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

func (*RegistrationRecord) XXX_Merge 

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

func (*RegistrationRecord) XXX_Size 

func (m *RegistrationRecord) XXX_Size() int

func (*RegistrationRecord) XXX_Unmarshal 

func (m *RegistrationRecord) XXX_Unmarshal(b []byte) 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.