pb

package
Version: v0.0.0-...-b598ae0 Latest Latest
Warning

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

Go to latest
Published: Feb 7, 2019 License: GPL-3.0 Imports: 14 Imported by: 0

Documentation

Overview

Package pb is a generated protocol buffer package.

It is generated from these files:

pb/addressbook.proto
pb/matchmaking.proto
pb/messaging.proto
pb/platform.proto
pb/publisher.proto
pb/storage.proto

It has these top-level messages:

Peer
DNPeerRecord
DNAddressbook
RPCUpsertPeerRequest
RPCUpsertPeerResponse
RPCGetPeerIdsRequest
RPCGetPeerIdsResponse
RPCGetPeerRequest
RPCGetPeerResponse
Session
DNSessionStore
DNSessionsRecord
DNSessionsResponse
DNSessionsRequest
DNSessionidsResponse
DNSessionidsRequest
RPCUpsertSessionRequest
RPCUpsertSessionResponse
RPCDeleteSessionRequest
RPCDeleteSessionResponse
RPCGetSessionIdsByDetailsRequest
RPCGetSessionIdsByPeerIdsRequest
RPCGetSessionIdsResponse
RPCGetSessionRequest
RPCGetSessionResponse
DNDirectMessageResponse
DNDirectMessageRequest
RPCReceiveDirectMessageRequest
RPCDirectMessage
Empty
RPCHealthRequest
RPCHealthReply
PublisherDefinition
DNPublisherRecord
RPCPublishPublisherUpdateRequest
RPCPublishPublisherUpdateResponse
RPCGetPublisherFileRequest
RPCGetPublisherFileResponse
GetPublisherDefinitionRequest
LoadPublisherDefinitionRequest
RPCWritePeerFileRequest
RPCWritePeerFileResponse
RPCGetPeerFileRequest
RPCGetPeerFileResponse

Package pb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source
var CONSTRAINT version.Constraints
View Source
var VERSION *version.Version

Functions

func RegisterDecentralizerHandler

func RegisterDecentralizerHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterDecentralizerHandler registers the http handlers for service Decentralizer to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterDecentralizerHandlerClient

func RegisterDecentralizerHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DecentralizerClient) error

RegisterDecentralizerHandler registers the http handlers for service Decentralizer to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "DecentralizerClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "DecentralizerClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "DecentralizerClient" to call the correct interceptors.

func RegisterDecentralizerHandlerFromEndpoint

func RegisterDecentralizerHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterDecentralizerHandlerFromEndpoint is same as RegisterDecentralizerHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterDecentralizerServer

func RegisterDecentralizerServer(s *grpc.Server, srv DecentralizerServer)

Types

type DNAddressbook

type DNAddressbook struct {
	Peers []*Peer `protobuf:"bytes,1,rep,name=peers" json:"peers,omitempty"`
}

func (*DNAddressbook) Descriptor

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

func (*DNAddressbook) GetPeers

func (m *DNAddressbook) GetPeers() []*Peer

func (*DNAddressbook) ProtoMessage

func (*DNAddressbook) ProtoMessage()

func (*DNAddressbook) Reset

func (m *DNAddressbook) Reset()

func (*DNAddressbook) String

func (m *DNAddressbook) String() string

type DNDirectMessageRequest

type DNDirectMessageRequest struct {
	Channel uint32 `protobuf:"varint,1,opt,name=channel" json:"channel,omitempty"`
	Message []byte `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
}

func (*DNDirectMessageRequest) Descriptor

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

func (*DNDirectMessageRequest) GetChannel

func (m *DNDirectMessageRequest) GetChannel() uint32

func (*DNDirectMessageRequest) GetMessage

func (m *DNDirectMessageRequest) GetMessage() []byte

func (*DNDirectMessageRequest) ProtoMessage

func (*DNDirectMessageRequest) ProtoMessage()

func (*DNDirectMessageRequest) Reset

func (m *DNDirectMessageRequest) Reset()

func (*DNDirectMessageRequest) String

func (m *DNDirectMessageRequest) String() string

type DNDirectMessageResponse

type DNDirectMessageResponse struct {
	Delivered bool `protobuf:"varint,1,opt,name=delivered" json:"delivered,omitempty"`
}

DN messages

func (*DNDirectMessageResponse) Descriptor

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

func (*DNDirectMessageResponse) GetDelivered

func (m *DNDirectMessageResponse) GetDelivered() bool

func (*DNDirectMessageResponse) ProtoMessage

func (*DNDirectMessageResponse) ProtoMessage()

func (*DNDirectMessageResponse) Reset

func (m *DNDirectMessageResponse) Reset()

func (*DNDirectMessageResponse) String

func (m *DNDirectMessageResponse) String() string

type DNPeerRecord

type DNPeerRecord struct {
	Peer *Peer `protobuf:"bytes,2,opt,name=peer" json:"peer,omitempty"`
}

func (*DNPeerRecord) Descriptor

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

func (*DNPeerRecord) GetPeer

func (m *DNPeerRecord) GetPeer() *Peer

func (*DNPeerRecord) ProtoMessage

func (*DNPeerRecord) ProtoMessage()

func (*DNPeerRecord) Reset

func (m *DNPeerRecord) Reset()

func (*DNPeerRecord) String

func (m *DNPeerRecord) String() string

type DNPublisherRecord

type DNPublisherRecord struct {
	Signature  []byte `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty"`
	Path       string `protobuf:"bytes,2,opt,name=path" json:"path,omitempty"`
	Definition []byte `protobuf:"bytes,3,opt,name=definition,proto3" json:"definition,omitempty"`
}

func (*DNPublisherRecord) Descriptor

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

func (*DNPublisherRecord) GetDefinition

func (m *DNPublisherRecord) GetDefinition() []byte

func (*DNPublisherRecord) GetPath

func (m *DNPublisherRecord) GetPath() string

func (*DNPublisherRecord) GetSignature

func (m *DNPublisherRecord) GetSignature() []byte

func (*DNPublisherRecord) ProtoMessage

func (*DNPublisherRecord) ProtoMessage()

func (*DNPublisherRecord) Reset

func (m *DNPublisherRecord) Reset()

func (*DNPublisherRecord) String

func (m *DNPublisherRecord) String() string

type DNSessionStore

type DNSessionStore struct {
	Sessions []*Session `protobuf:"bytes,1,rep,name=sessions" json:"sessions,omitempty"`
}

DN messages

func (*DNSessionStore) Descriptor

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

func (*DNSessionStore) GetSessions

func (m *DNSessionStore) GetSessions() []*Session

func (*DNSessionStore) ProtoMessage

func (*DNSessionStore) ProtoMessage()

func (*DNSessionStore) Reset

func (m *DNSessionStore) Reset()

func (*DNSessionStore) String

func (m *DNSessionStore) String() string

type DNSessionidsRequest

type DNSessionidsRequest struct {
	Type uint64 `protobuf:"varint,1,opt,name=type" json:"type,omitempty"`
}

func (*DNSessionidsRequest) Descriptor

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

func (*DNSessionidsRequest) GetType

func (m *DNSessionidsRequest) GetType() uint64

func (*DNSessionidsRequest) ProtoMessage

func (*DNSessionidsRequest) ProtoMessage()

func (*DNSessionidsRequest) Reset

func (m *DNSessionidsRequest) Reset()

func (*DNSessionidsRequest) String

func (m *DNSessionidsRequest) String() string

type DNSessionidsResponse

type DNSessionidsResponse struct {
	SessionIds []uint64 `protobuf:"varint,1,rep,packed,name=sessionIds" json:"sessionIds,omitempty"`
}

func (*DNSessionidsResponse) Descriptor

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

func (*DNSessionidsResponse) GetSessionIds

func (m *DNSessionidsResponse) GetSessionIds() []uint64

func (*DNSessionidsResponse) ProtoMessage

func (*DNSessionidsResponse) ProtoMessage()

func (*DNSessionidsResponse) Reset

func (m *DNSessionidsResponse) Reset()

func (*DNSessionidsResponse) String

func (m *DNSessionidsResponse) String() string

type DNSessionsRecord

type DNSessionsRecord struct {
	Published uint64     `protobuf:"varint,1,opt,name=published" json:"published,omitempty"`
	Results   []*Session `protobuf:"bytes,2,rep,name=results" json:"results,omitempty"`
}

func (*DNSessionsRecord) Descriptor

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

func (*DNSessionsRecord) GetPublished

func (m *DNSessionsRecord) GetPublished() uint64

func (*DNSessionsRecord) GetResults

func (m *DNSessionsRecord) GetResults() []*Session

func (*DNSessionsRecord) ProtoMessage

func (*DNSessionsRecord) ProtoMessage()

func (*DNSessionsRecord) Reset

func (m *DNSessionsRecord) Reset()

func (*DNSessionsRecord) String

func (m *DNSessionsRecord) String() string

type DNSessionsRequest

type DNSessionsRequest struct {
	Type       uint64   `protobuf:"varint,1,opt,name=type" json:"type,omitempty"`
	SessionIds []uint64 `protobuf:"varint,2,rep,packed,name=sessionIds" json:"sessionIds,omitempty"`
}

func (*DNSessionsRequest) Descriptor

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

func (*DNSessionsRequest) GetSessionIds

func (m *DNSessionsRequest) GetSessionIds() []uint64

func (*DNSessionsRequest) GetType

func (m *DNSessionsRequest) GetType() uint64

func (*DNSessionsRequest) ProtoMessage

func (*DNSessionsRequest) ProtoMessage()

func (*DNSessionsRequest) Reset

func (m *DNSessionsRequest) Reset()

func (*DNSessionsRequest) String

func (m *DNSessionsRequest) String() string

type DNSessionsResponse

type DNSessionsResponse struct {
	Results []*Session `protobuf:"bytes,1,rep,name=results" json:"results,omitempty"`
}

func (*DNSessionsResponse) Descriptor

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

func (*DNSessionsResponse) GetResults

func (m *DNSessionsResponse) GetResults() []*Session

func (*DNSessionsResponse) ProtoMessage

func (*DNSessionsResponse) ProtoMessage()

func (*DNSessionsResponse) Reset

func (m *DNSessionsResponse) Reset()

func (*DNSessionsResponse) String

func (m *DNSessionsResponse) String() string

type DecentralizerClient

type DecentralizerClient interface {
	//
	// Platform
	//
	// Get health of decentralizer.
	GetHealth(ctx context.Context, in *RPCHealthRequest, opts ...grpc.CallOption) (*RPCHealthReply, error)
	//
	// Matchmaking
	//
	// Create or update a session. Takes session info, returns session id.
	UpsertSession(ctx context.Context, in *RPCUpsertSessionRequest, opts ...grpc.CallOption) (*RPCUpsertSessionResponse, error)
	// Delete a session. Takes session id, returns bool informing if the deletion was a success
	DeleteSession(ctx context.Context, in *RPCDeleteSessionRequest, opts ...grpc.CallOption) (*RPCDeleteSessionResponse, error)
	// Get session ids. Takes session type, and a key and value to filter the sessions by details. If left empty this filter will not apply and all will be fetched.
	GetSessionIdsByDetails(ctx context.Context, in *RPCGetSessionIdsByDetailsRequest, opts ...grpc.CallOption) (*RPCGetSessionIdsResponse, error)
	// Get session ids. Takes peer ids. Returns session ids
	GetSessionIdsByPeerIds(ctx context.Context, in *RPCGetSessionIdsByPeerIdsRequest, opts ...grpc.CallOption) (*RPCGetSessionIdsResponse, error)
	// Get an individual session. Takes session id and returns session info.
	GetSession(ctx context.Context, in *RPCGetSessionRequest, opts ...grpc.CallOption) (*RPCGetSessionResponse, error)
	//
	// Address book
	//
	// Create or update a peer. Takes peer info, returns if it was a success.
	UpsertPeer(ctx context.Context, in *RPCUpsertPeerRequest, opts ...grpc.CallOption) (*RPCUpsertPeerResponse, error)
	// Get peer ids. takes a key and value to filter the peers by details. If left empty this filter will not apply and all will be fetched.
	GetPeerIds(ctx context.Context, in *RPCGetPeerIdsRequest, opts ...grpc.CallOption) (*RPCGetPeerIdsResponse, error)
	// Get an individual peer. Takes either a peer id or decentralizer id and returns the peer info.
	GetPeer(ctx context.Context, in *RPCGetPeerRequest, opts ...grpc.CallOption) (*RPCGetPeerResponse, error)
	//
	// Storage
	//
	// Write a peer file. Takes a file name and the data it should save.
	WritePeerFile(ctx context.Context, in *RPCWritePeerFileRequest, opts ...grpc.CallOption) (*RPCWritePeerFileResponse, error)
	// Get a peer file. Takes a file name, returns the file.
	GetPeerFile(ctx context.Context, in *RPCGetPeerFileRequest, opts ...grpc.CallOption) (*RPCGetPeerFileResponse, error)
	//
	// Messaging
	//
	// Send another peer a direct message. Takes a peer id and the data it should send
	SendDirectMessage(ctx context.Context, in *RPCDirectMessage, opts ...grpc.CallOption) (*Empty, error)
	ReceiveDirectMessage(ctx context.Context, in *RPCReceiveDirectMessageRequest, opts ...grpc.CallOption) (Decentralizer_ReceiveDirectMessageClient, error)
	//
	// Publisher
	//
	// Load a publisher definition. Will not work if its older!
	ReadPublisherDefinition(ctx context.Context, in *LoadPublisherDefinitionRequest, opts ...grpc.CallOption) (*Empty, error)
	// Signs a new publisher update. (Only if you have the private key!)
	PublishPublisherUpdate(ctx context.Context, in *RPCPublishPublisherUpdateRequest, opts ...grpc.CallOption) (*RPCPublishPublisherUpdateResponse, error)
	// Get the full publisher definition
	GetPublisherDefinition(ctx context.Context, in *GetPublisherDefinitionRequest, opts ...grpc.CallOption) (*PublisherDefinition, error)
	// Get a publisher file.
	GetPublisherFile(ctx context.Context, in *RPCGetPublisherFileRequest, opts ...grpc.CallOption) (*RPCGetPublisherFileResponse, error)
}

func NewDecentralizerClient

func NewDecentralizerClient(cc *grpc.ClientConn) DecentralizerClient

type DecentralizerServer

type DecentralizerServer interface {
	//
	// Platform
	//
	// Get health of decentralizer.
	GetHealth(context.Context, *RPCHealthRequest) (*RPCHealthReply, error)
	//
	// Matchmaking
	//
	// Create or update a session. Takes session info, returns session id.
	UpsertSession(context.Context, *RPCUpsertSessionRequest) (*RPCUpsertSessionResponse, error)
	// Delete a session. Takes session id, returns bool informing if the deletion was a success
	DeleteSession(context.Context, *RPCDeleteSessionRequest) (*RPCDeleteSessionResponse, error)
	// Get session ids. Takes session type, and a key and value to filter the sessions by details. If left empty this filter will not apply and all will be fetched.
	GetSessionIdsByDetails(context.Context, *RPCGetSessionIdsByDetailsRequest) (*RPCGetSessionIdsResponse, error)
	// Get session ids. Takes peer ids. Returns session ids
	GetSessionIdsByPeerIds(context.Context, *RPCGetSessionIdsByPeerIdsRequest) (*RPCGetSessionIdsResponse, error)
	// Get an individual session. Takes session id and returns session info.
	GetSession(context.Context, *RPCGetSessionRequest) (*RPCGetSessionResponse, error)
	//
	// Address book
	//
	// Create or update a peer. Takes peer info, returns if it was a success.
	UpsertPeer(context.Context, *RPCUpsertPeerRequest) (*RPCUpsertPeerResponse, error)
	// Get peer ids. takes a key and value to filter the peers by details. If left empty this filter will not apply and all will be fetched.
	GetPeerIds(context.Context, *RPCGetPeerIdsRequest) (*RPCGetPeerIdsResponse, error)
	// Get an individual peer. Takes either a peer id or decentralizer id and returns the peer info.
	GetPeer(context.Context, *RPCGetPeerRequest) (*RPCGetPeerResponse, error)
	//
	// Storage
	//
	// Write a peer file. Takes a file name and the data it should save.
	WritePeerFile(context.Context, *RPCWritePeerFileRequest) (*RPCWritePeerFileResponse, error)
	// Get a peer file. Takes a file name, returns the file.
	GetPeerFile(context.Context, *RPCGetPeerFileRequest) (*RPCGetPeerFileResponse, error)
	//
	// Messaging
	//
	// Send another peer a direct message. Takes a peer id and the data it should send
	SendDirectMessage(context.Context, *RPCDirectMessage) (*Empty, error)
	ReceiveDirectMessage(*RPCReceiveDirectMessageRequest, Decentralizer_ReceiveDirectMessageServer) error
	//
	// Publisher
	//
	// Load a publisher definition. Will not work if its older!
	ReadPublisherDefinition(context.Context, *LoadPublisherDefinitionRequest) (*Empty, error)
	// Signs a new publisher update. (Only if you have the private key!)
	PublishPublisherUpdate(context.Context, *RPCPublishPublisherUpdateRequest) (*RPCPublishPublisherUpdateResponse, error)
	// Get the full publisher definition
	GetPublisherDefinition(context.Context, *GetPublisherDefinitionRequest) (*PublisherDefinition, error)
	// Get a publisher file.
	GetPublisherFile(context.Context, *RPCGetPublisherFileRequest) (*RPCGetPublisherFileResponse, error)
}

type Decentralizer_ReceiveDirectMessageClient

type Decentralizer_ReceiveDirectMessageClient interface {
	Recv() (*RPCDirectMessage, error)
	grpc.ClientStream
}

type Decentralizer_ReceiveDirectMessageServer

type Decentralizer_ReceiveDirectMessageServer interface {
	Send(*RPCDirectMessage) error
	grpc.ServerStream
}

type Empty

type Empty struct {
}

func (*Empty) Descriptor

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

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) Reset

func (m *Empty) Reset()

func (*Empty) String

func (m *Empty) String() string

type GetPublisherDefinitionRequest

type GetPublisherDefinitionRequest struct {
}

func (*GetPublisherDefinitionRequest) Descriptor

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

func (*GetPublisherDefinitionRequest) ProtoMessage

func (*GetPublisherDefinitionRequest) ProtoMessage()

func (*GetPublisherDefinitionRequest) Reset

func (m *GetPublisherDefinitionRequest) Reset()

func (*GetPublisherDefinitionRequest) String

type LoadPublisherDefinitionRequest

type LoadPublisherDefinitionRequest struct {
	Definition []byte `protobuf:"bytes,1,opt,name=definition,proto3" json:"definition,omitempty"`
}

func (*LoadPublisherDefinitionRequest) Descriptor

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

func (*LoadPublisherDefinitionRequest) GetDefinition

func (m *LoadPublisherDefinitionRequest) GetDefinition() []byte

func (*LoadPublisherDefinitionRequest) ProtoMessage

func (*LoadPublisherDefinitionRequest) ProtoMessage()

func (*LoadPublisherDefinitionRequest) Reset

func (m *LoadPublisherDefinitionRequest) Reset()

func (*LoadPublisherDefinitionRequest) String

type Peer

type Peer struct {
	Published uint64 `protobuf:"varint,1,opt,name=published" json:"published,omitempty"`
	// If pId == "self". We'll resolve it to our peerId.
	PId     string            `protobuf:"bytes,2,opt,name=pId" json:"pId,omitempty"`
	DnId    uint64            `protobuf:"varint,3,opt,name=dnId" json:"dnId,omitempty"`
	Details map[string]string `` /* 134-byte string literal not displayed */
}

func (*Peer) Descriptor

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

func (*Peer) GetDetails

func (m *Peer) GetDetails() map[string]string

func (*Peer) GetDnId

func (m *Peer) GetDnId() uint64

func (*Peer) GetPId

func (m *Peer) GetPId() string

func (*Peer) GetPublished

func (m *Peer) GetPublished() uint64

func (*Peer) ProtoMessage

func (*Peer) ProtoMessage()

func (*Peer) Reset

func (m *Peer) Reset()

func (*Peer) String

func (m *Peer) String() string

type PublisherDefinition

type PublisherDefinition struct {
	Published uint64            `protobuf:"varint,1,opt,name=published" json:"published,omitempty"`
	Files     map[string][]byte `` /* 137-byte string literal not displayed */
	Links     map[string]string `` /* 130-byte string literal not displayed */
	Details   map[string]string `` /* 134-byte string literal not displayed */
	Status    bool              `protobuf:"varint,5,opt,name=status" json:"status,omitempty"`
}

DN

func (*PublisherDefinition) Descriptor

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

func (*PublisherDefinition) GetDetails

func (m *PublisherDefinition) GetDetails() map[string]string

func (*PublisherDefinition) GetFiles

func (m *PublisherDefinition) GetFiles() map[string][]byte
func (m *PublisherDefinition) GetLinks() map[string]string

func (*PublisherDefinition) GetPublished

func (m *PublisherDefinition) GetPublished() uint64

func (*PublisherDefinition) GetStatus

func (m *PublisherDefinition) GetStatus() bool

func (*PublisherDefinition) ProtoMessage

func (*PublisherDefinition) ProtoMessage()

func (*PublisherDefinition) Reset

func (m *PublisherDefinition) Reset()

func (*PublisherDefinition) String

func (m *PublisherDefinition) String() string

type RPCDeleteSessionRequest

type RPCDeleteSessionRequest struct {
	SessionId uint64 `protobuf:"varint,1,opt,name=sessionId" json:"sessionId,omitempty"`
}

Delete

func (*RPCDeleteSessionRequest) Descriptor

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

func (*RPCDeleteSessionRequest) GetSessionId

func (m *RPCDeleteSessionRequest) GetSessionId() uint64

func (*RPCDeleteSessionRequest) ProtoMessage

func (*RPCDeleteSessionRequest) ProtoMessage()

func (*RPCDeleteSessionRequest) Reset

func (m *RPCDeleteSessionRequest) Reset()

func (*RPCDeleteSessionRequest) String

func (m *RPCDeleteSessionRequest) String() string

type RPCDeleteSessionResponse

type RPCDeleteSessionResponse struct {
	Result bool `protobuf:"varint,1,opt,name=result" json:"result,omitempty"`
}

func (*RPCDeleteSessionResponse) Descriptor

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

func (*RPCDeleteSessionResponse) GetResult

func (m *RPCDeleteSessionResponse) GetResult() bool

func (*RPCDeleteSessionResponse) ProtoMessage

func (*RPCDeleteSessionResponse) ProtoMessage()

func (*RPCDeleteSessionResponse) Reset

func (m *RPCDeleteSessionResponse) Reset()

func (*RPCDeleteSessionResponse) String

func (m *RPCDeleteSessionResponse) String() string

type RPCDirectMessage

type RPCDirectMessage struct {
	Channel uint32 `protobuf:"varint,1,opt,name=channel" json:"channel,omitempty"`
	PId     string `protobuf:"bytes,2,opt,name=pId" json:"pId,omitempty"`
	Message []byte `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
}

func (*RPCDirectMessage) Descriptor

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

func (*RPCDirectMessage) GetChannel

func (m *RPCDirectMessage) GetChannel() uint32

func (*RPCDirectMessage) GetMessage

func (m *RPCDirectMessage) GetMessage() []byte

func (*RPCDirectMessage) GetPId

func (m *RPCDirectMessage) GetPId() string

func (*RPCDirectMessage) ProtoMessage

func (*RPCDirectMessage) ProtoMessage()

func (*RPCDirectMessage) Reset

func (m *RPCDirectMessage) Reset()

func (*RPCDirectMessage) String

func (m *RPCDirectMessage) String() string

type RPCGetPeerFileRequest

type RPCGetPeerFileRequest struct {
	PId  string `protobuf:"bytes,1,opt,name=pId" json:"pId,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
}

func (*RPCGetPeerFileRequest) Descriptor

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

func (*RPCGetPeerFileRequest) GetName

func (m *RPCGetPeerFileRequest) GetName() string

func (*RPCGetPeerFileRequest) GetPId

func (m *RPCGetPeerFileRequest) GetPId() string

func (*RPCGetPeerFileRequest) ProtoMessage

func (*RPCGetPeerFileRequest) ProtoMessage()

func (*RPCGetPeerFileRequest) Reset

func (m *RPCGetPeerFileRequest) Reset()

func (*RPCGetPeerFileRequest) String

func (m *RPCGetPeerFileRequest) String() string

type RPCGetPeerFileResponse

type RPCGetPeerFileResponse struct {
	File []byte `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
}

func (*RPCGetPeerFileResponse) Descriptor

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

func (*RPCGetPeerFileResponse) GetFile

func (m *RPCGetPeerFileResponse) GetFile() []byte

func (*RPCGetPeerFileResponse) ProtoMessage

func (*RPCGetPeerFileResponse) ProtoMessage()

func (*RPCGetPeerFileResponse) Reset

func (m *RPCGetPeerFileResponse) Reset()

func (*RPCGetPeerFileResponse) String

func (m *RPCGetPeerFileResponse) String() string

type RPCGetPeerIdsRequest

type RPCGetPeerIdsRequest struct {
	// Key in the details map
	Key string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	// Value in the details map.
	Value string `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
}

Get peer ids

func (*RPCGetPeerIdsRequest) Descriptor

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

func (*RPCGetPeerIdsRequest) GetKey

func (m *RPCGetPeerIdsRequest) GetKey() string

func (*RPCGetPeerIdsRequest) GetValue

func (m *RPCGetPeerIdsRequest) GetValue() string

func (*RPCGetPeerIdsRequest) ProtoMessage

func (*RPCGetPeerIdsRequest) ProtoMessage()

func (*RPCGetPeerIdsRequest) Reset

func (m *RPCGetPeerIdsRequest) Reset()

func (*RPCGetPeerIdsRequest) String

func (m *RPCGetPeerIdsRequest) String() string

type RPCGetPeerIdsResponse

type RPCGetPeerIdsResponse struct {
	PeerIds []string `protobuf:"bytes,1,rep,name=peerIds" json:"peerIds,omitempty"`
}

func (*RPCGetPeerIdsResponse) Descriptor

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

func (*RPCGetPeerIdsResponse) GetPeerIds

func (m *RPCGetPeerIdsResponse) GetPeerIds() []string

func (*RPCGetPeerIdsResponse) ProtoMessage

func (*RPCGetPeerIdsResponse) ProtoMessage()

func (*RPCGetPeerIdsResponse) Reset

func (m *RPCGetPeerIdsResponse) Reset()

func (*RPCGetPeerIdsResponse) String

func (m *RPCGetPeerIdsResponse) String() string

type RPCGetPeerRequest

type RPCGetPeerRequest struct {
	// If pId == "self". We'll resolve it to our peerId.
	// Either one must be filled in. If both are specified. preference goes to pId
	PId  string `protobuf:"bytes,1,opt,name=pId" json:"pId,omitempty"`
	DnId uint64 `protobuf:"varint,2,opt,name=dnId" json:"dnId,omitempty"`
}

Get individual peer

func (*RPCGetPeerRequest) Descriptor

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

func (*RPCGetPeerRequest) GetDnId

func (m *RPCGetPeerRequest) GetDnId() uint64

func (*RPCGetPeerRequest) GetPId

func (m *RPCGetPeerRequest) GetPId() string

func (*RPCGetPeerRequest) ProtoMessage

func (*RPCGetPeerRequest) ProtoMessage()

func (*RPCGetPeerRequest) Reset

func (m *RPCGetPeerRequest) Reset()

func (*RPCGetPeerRequest) String

func (m *RPCGetPeerRequest) String() string

type RPCGetPeerResponse

type RPCGetPeerResponse struct {
	Peer *Peer `protobuf:"bytes,1,opt,name=peer" json:"peer,omitempty"`
}

func (*RPCGetPeerResponse) Descriptor

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

func (*RPCGetPeerResponse) GetPeer

func (m *RPCGetPeerResponse) GetPeer() *Peer

func (*RPCGetPeerResponse) ProtoMessage

func (*RPCGetPeerResponse) ProtoMessage()

func (*RPCGetPeerResponse) Reset

func (m *RPCGetPeerResponse) Reset()

func (*RPCGetPeerResponse) String

func (m *RPCGetPeerResponse) String() string

type RPCGetPublisherFileRequest

type RPCGetPublisherFileRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
}

func (*RPCGetPublisherFileRequest) Descriptor

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

func (*RPCGetPublisherFileRequest) GetName

func (m *RPCGetPublisherFileRequest) GetName() string

func (*RPCGetPublisherFileRequest) ProtoMessage

func (*RPCGetPublisherFileRequest) ProtoMessage()

func (*RPCGetPublisherFileRequest) Reset

func (m *RPCGetPublisherFileRequest) Reset()

func (*RPCGetPublisherFileRequest) String

func (m *RPCGetPublisherFileRequest) String() string

type RPCGetPublisherFileResponse

type RPCGetPublisherFileResponse struct {
	File []byte `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
}

func (*RPCGetPublisherFileResponse) Descriptor

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

func (*RPCGetPublisherFileResponse) GetFile

func (m *RPCGetPublisherFileResponse) GetFile() []byte

func (*RPCGetPublisherFileResponse) ProtoMessage

func (*RPCGetPublisherFileResponse) ProtoMessage()

func (*RPCGetPublisherFileResponse) Reset

func (m *RPCGetPublisherFileResponse) Reset()

func (*RPCGetPublisherFileResponse) String

func (m *RPCGetPublisherFileResponse) String() string

type RPCGetSessionIdsByDetailsRequest

type RPCGetSessionIdsByDetailsRequest struct {
	Type  uint64 `protobuf:"varint,1,opt,name=type" json:"type,omitempty"`
	Key   string `protobuf:"bytes,2,opt,name=key" json:"key,omitempty"`
	Value string `protobuf:"bytes,3,opt,name=value" json:"value,omitempty"`
}

Get session ids

func (*RPCGetSessionIdsByDetailsRequest) Descriptor

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

func (*RPCGetSessionIdsByDetailsRequest) GetKey

func (*RPCGetSessionIdsByDetailsRequest) GetType

func (*RPCGetSessionIdsByDetailsRequest) GetValue

func (*RPCGetSessionIdsByDetailsRequest) ProtoMessage

func (*RPCGetSessionIdsByDetailsRequest) ProtoMessage()

func (*RPCGetSessionIdsByDetailsRequest) Reset

func (*RPCGetSessionIdsByDetailsRequest) String

type RPCGetSessionIdsByPeerIdsRequest

type RPCGetSessionIdsByPeerIdsRequest struct {
	PeerIds []string `protobuf:"bytes,1,rep,name=peerIds" json:"peerIds,omitempty"`
}

func (*RPCGetSessionIdsByPeerIdsRequest) Descriptor

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

func (*RPCGetSessionIdsByPeerIdsRequest) GetPeerIds

func (m *RPCGetSessionIdsByPeerIdsRequest) GetPeerIds() []string

func (*RPCGetSessionIdsByPeerIdsRequest) ProtoMessage

func (*RPCGetSessionIdsByPeerIdsRequest) ProtoMessage()

func (*RPCGetSessionIdsByPeerIdsRequest) Reset

func (*RPCGetSessionIdsByPeerIdsRequest) String

type RPCGetSessionIdsResponse

type RPCGetSessionIdsResponse struct {
	SessionIds []uint64 `protobuf:"varint,1,rep,packed,name=sessionIds" json:"sessionIds,omitempty"`
}

func (*RPCGetSessionIdsResponse) Descriptor

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

func (*RPCGetSessionIdsResponse) GetSessionIds

func (m *RPCGetSessionIdsResponse) GetSessionIds() []uint64

func (*RPCGetSessionIdsResponse) ProtoMessage

func (*RPCGetSessionIdsResponse) ProtoMessage()

func (*RPCGetSessionIdsResponse) Reset

func (m *RPCGetSessionIdsResponse) Reset()

func (*RPCGetSessionIdsResponse) String

func (m *RPCGetSessionIdsResponse) String() string

type RPCGetSessionRequest

type RPCGetSessionRequest struct {
	SessionId uint64 `protobuf:"varint,1,opt,name=sessionId" json:"sessionId,omitempty"`
}

Fetch an individual session

func (*RPCGetSessionRequest) Descriptor

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

func (*RPCGetSessionRequest) GetSessionId

func (m *RPCGetSessionRequest) GetSessionId() uint64

func (*RPCGetSessionRequest) ProtoMessage

func (*RPCGetSessionRequest) ProtoMessage()

func (*RPCGetSessionRequest) Reset

func (m *RPCGetSessionRequest) Reset()

func (*RPCGetSessionRequest) String

func (m *RPCGetSessionRequest) String() string

type RPCGetSessionResponse

type RPCGetSessionResponse struct {
	Session *Session `protobuf:"bytes,1,opt,name=session" json:"session,omitempty"`
}

func (*RPCGetSessionResponse) Descriptor

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

func (*RPCGetSessionResponse) GetSession

func (m *RPCGetSessionResponse) GetSession() *Session

func (*RPCGetSessionResponse) ProtoMessage

func (*RPCGetSessionResponse) ProtoMessage()

func (*RPCGetSessionResponse) Reset

func (m *RPCGetSessionResponse) Reset()

func (*RPCGetSessionResponse) String

func (m *RPCGetSessionResponse) String() string

type RPCHealthReply

type RPCHealthReply struct {
	Ready          bool   `protobuf:"varint,1,opt,name=ready" json:"ready,omitempty"`
	Message        string `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"`
	BasePath       string `protobuf:"bytes,3,opt,name=basePath" json:"basePath,omitempty"`
	NumConnections uint32 `protobuf:"varint,4,opt,name=numConnections" json:"numConnections,omitempty"`
}

func (*RPCHealthReply) Descriptor

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

func (*RPCHealthReply) GetBasePath

func (m *RPCHealthReply) GetBasePath() string

func (*RPCHealthReply) GetMessage

func (m *RPCHealthReply) GetMessage() string

func (*RPCHealthReply) GetNumConnections

func (m *RPCHealthReply) GetNumConnections() uint32

func (*RPCHealthReply) GetReady

func (m *RPCHealthReply) GetReady() bool

func (*RPCHealthReply) ProtoMessage

func (*RPCHealthReply) ProtoMessage()

func (*RPCHealthReply) Reset

func (m *RPCHealthReply) Reset()

func (*RPCHealthReply) String

func (m *RPCHealthReply) String() string

type RPCHealthRequest

type RPCHealthRequest struct {
	WaitForMinConnections bool `protobuf:"varint,1,opt,name=waitForMinConnections" json:"waitForMinConnections,omitempty"`
}

func (*RPCHealthRequest) Descriptor

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

func (*RPCHealthRequest) GetWaitForMinConnections

func (m *RPCHealthRequest) GetWaitForMinConnections() bool

func (*RPCHealthRequest) ProtoMessage

func (*RPCHealthRequest) ProtoMessage()

func (*RPCHealthRequest) Reset

func (m *RPCHealthRequest) Reset()

func (*RPCHealthRequest) String

func (m *RPCHealthRequest) String() string

type RPCPublishPublisherUpdateRequest

type RPCPublishPublisherUpdateRequest struct {
	Definition *PublisherDefinition `protobuf:"bytes,1,opt,name=definition" json:"definition,omitempty"`
}

RPC

func (*RPCPublishPublisherUpdateRequest) Descriptor

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

func (*RPCPublishPublisherUpdateRequest) GetDefinition

func (*RPCPublishPublisherUpdateRequest) ProtoMessage

func (*RPCPublishPublisherUpdateRequest) ProtoMessage()

func (*RPCPublishPublisherUpdateRequest) Reset

func (*RPCPublishPublisherUpdateRequest) String

type RPCPublishPublisherUpdateResponse

type RPCPublishPublisherUpdateResponse struct {
	Definition []byte `protobuf:"bytes,1,opt,name=definition,proto3" json:"definition,omitempty"`
}

func (*RPCPublishPublisherUpdateResponse) Descriptor

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

func (*RPCPublishPublisherUpdateResponse) GetDefinition

func (m *RPCPublishPublisherUpdateResponse) GetDefinition() []byte

func (*RPCPublishPublisherUpdateResponse) ProtoMessage

func (*RPCPublishPublisherUpdateResponse) ProtoMessage()

func (*RPCPublishPublisherUpdateResponse) Reset

func (*RPCPublishPublisherUpdateResponse) String

type RPCReceiveDirectMessageRequest

type RPCReceiveDirectMessageRequest struct {
	Channel uint32 `protobuf:"varint,1,opt,name=channel" json:"channel,omitempty"`
}

RPC messages

func (*RPCReceiveDirectMessageRequest) Descriptor

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

func (*RPCReceiveDirectMessageRequest) GetChannel

func (m *RPCReceiveDirectMessageRequest) GetChannel() uint32

func (*RPCReceiveDirectMessageRequest) ProtoMessage

func (*RPCReceiveDirectMessageRequest) ProtoMessage()

func (*RPCReceiveDirectMessageRequest) Reset

func (m *RPCReceiveDirectMessageRequest) Reset()

func (*RPCReceiveDirectMessageRequest) String

type RPCUpsertPeerRequest

type RPCUpsertPeerRequest struct {
	Peer *Peer `protobuf:"bytes,1,opt,name=peer" json:"peer,omitempty"`
}

upsert

func (*RPCUpsertPeerRequest) Descriptor

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

func (*RPCUpsertPeerRequest) GetPeer

func (m *RPCUpsertPeerRequest) GetPeer() *Peer

func (*RPCUpsertPeerRequest) ProtoMessage

func (*RPCUpsertPeerRequest) ProtoMessage()

func (*RPCUpsertPeerRequest) Reset

func (m *RPCUpsertPeerRequest) Reset()

func (*RPCUpsertPeerRequest) String

func (m *RPCUpsertPeerRequest) String() string

type RPCUpsertPeerResponse

type RPCUpsertPeerResponse struct {
}

func (*RPCUpsertPeerResponse) Descriptor

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

func (*RPCUpsertPeerResponse) ProtoMessage

func (*RPCUpsertPeerResponse) ProtoMessage()

func (*RPCUpsertPeerResponse) Reset

func (m *RPCUpsertPeerResponse) Reset()

func (*RPCUpsertPeerResponse) String

func (m *RPCUpsertPeerResponse) String() string

type RPCUpsertSessionRequest

type RPCUpsertSessionRequest struct {
	Session *Session `protobuf:"bytes,1,opt,name=session" json:"session,omitempty"`
}

Upsert

func (*RPCUpsertSessionRequest) Descriptor

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

func (*RPCUpsertSessionRequest) GetSession

func (m *RPCUpsertSessionRequest) GetSession() *Session

func (*RPCUpsertSessionRequest) ProtoMessage

func (*RPCUpsertSessionRequest) ProtoMessage()

func (*RPCUpsertSessionRequest) Reset

func (m *RPCUpsertSessionRequest) Reset()

func (*RPCUpsertSessionRequest) String

func (m *RPCUpsertSessionRequest) String() string

type RPCUpsertSessionResponse

type RPCUpsertSessionResponse struct {
	SessionId uint64 `protobuf:"varint,1,opt,name=sessionId" json:"sessionId,omitempty"`
}

func (*RPCUpsertSessionResponse) Descriptor

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

func (*RPCUpsertSessionResponse) GetSessionId

func (m *RPCUpsertSessionResponse) GetSessionId() uint64

func (*RPCUpsertSessionResponse) ProtoMessage

func (*RPCUpsertSessionResponse) ProtoMessage()

func (*RPCUpsertSessionResponse) Reset

func (m *RPCUpsertSessionResponse) Reset()

func (*RPCUpsertSessionResponse) String

func (m *RPCUpsertSessionResponse) String() string

type RPCWritePeerFileRequest

type RPCWritePeerFileRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	File []byte `protobuf:"bytes,2,opt,name=file,proto3" json:"file,omitempty"`
}

RPC

func (*RPCWritePeerFileRequest) Descriptor

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

func (*RPCWritePeerFileRequest) GetFile

func (m *RPCWritePeerFileRequest) GetFile() []byte

func (*RPCWritePeerFileRequest) GetName

func (m *RPCWritePeerFileRequest) GetName() string

func (*RPCWritePeerFileRequest) ProtoMessage

func (*RPCWritePeerFileRequest) ProtoMessage()

func (*RPCWritePeerFileRequest) Reset

func (m *RPCWritePeerFileRequest) Reset()

func (*RPCWritePeerFileRequest) String

func (m *RPCWritePeerFileRequest) String() string

type RPCWritePeerFileResponse

type RPCWritePeerFileResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success" json:"success,omitempty"`
}

func (*RPCWritePeerFileResponse) Descriptor

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

func (*RPCWritePeerFileResponse) GetSuccess

func (m *RPCWritePeerFileResponse) GetSuccess() bool

func (*RPCWritePeerFileResponse) ProtoMessage

func (*RPCWritePeerFileResponse) ProtoMessage()

func (*RPCWritePeerFileResponse) Reset

func (m *RPCWritePeerFileResponse) Reset()

func (*RPCWritePeerFileResponse) String

func (m *RPCWritePeerFileResponse) String() string

type Session

type Session struct {
	PId       string            `protobuf:"bytes,1,opt,name=pId" json:"pId,omitempty"`
	DnId      uint64            `protobuf:"varint,2,opt,name=dnId" json:"dnId,omitempty"`
	SessionId uint64            `protobuf:"varint,3,opt,name=sessionId" json:"sessionId,omitempty"`
	Type      uint64            `protobuf:"varint,4,opt,name=type" json:"type,omitempty"`
	Name      string            `protobuf:"bytes,5,opt,name=name" json:"name,omitempty"`
	Address   uint32            `protobuf:"varint,6,opt,name=address" json:"address,omitempty"`
	Port      uint32            `protobuf:"varint,7,opt,name=port" json:"port,omitempty"`
	Details   map[string]string `` /* 134-byte string literal not displayed */
	Published uint64            `protobuf:"varint,9,opt,name=published" json:"published,omitempty"`
}

func (*Session) Descriptor

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

func (*Session) GetAddress

func (m *Session) GetAddress() uint32

func (*Session) GetDetails

func (m *Session) GetDetails() map[string]string

func (*Session) GetDnId

func (m *Session) GetDnId() uint64

func (*Session) GetName

func (m *Session) GetName() string

func (*Session) GetPId

func (m *Session) GetPId() string

func (*Session) GetPort

func (m *Session) GetPort() uint32

func (*Session) GetPublished

func (m *Session) GetPublished() uint64

func (*Session) GetSessionId

func (m *Session) GetSessionId() uint64

func (*Session) GetType

func (m *Session) GetType() uint64

func (*Session) ProtoMessage

func (*Session) ProtoMessage()

func (*Session) Reset

func (m *Session) Reset()

func (*Session) String

func (m *Session) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL