pb

package
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 

func (m *GetPublisherDefinitionRequest) String() 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 

func (m *LoadPublisherDefinitionRequest) String() 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 (m *RPCGetSessionIdsByDetailsRequest) GetKey() string

func (*RPCGetSessionIdsByDetailsRequest) GetType 

func (m *RPCGetSessionIdsByDetailsRequest) GetType() uint64

func (*RPCGetSessionIdsByDetailsRequest) GetValue 

func (m *RPCGetSessionIdsByDetailsRequest) GetValue() string

func (*RPCGetSessionIdsByDetailsRequest) ProtoMessage 

func (*RPCGetSessionIdsByDetailsRequest) ProtoMessage()

func (*RPCGetSessionIdsByDetailsRequest) Reset 

func (m *RPCGetSessionIdsByDetailsRequest) Reset()

func (*RPCGetSessionIdsByDetailsRequest) String 

func (m *RPCGetSessionIdsByDetailsRequest) String() 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 (m *RPCGetSessionIdsByPeerIdsRequest) Reset()

func (*RPCGetSessionIdsByPeerIdsRequest) String 

func (m *RPCGetSessionIdsByPeerIdsRequest) String() 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 (m *RPCPublishPublisherUpdateRequest) GetDefinition() *PublisherDefinition

func (*RPCPublishPublisherUpdateRequest) ProtoMessage 

func (*RPCPublishPublisherUpdateRequest) ProtoMessage()

func (*RPCPublishPublisherUpdateRequest) Reset 

func (m *RPCPublishPublisherUpdateRequest) Reset()

func (*RPCPublishPublisherUpdateRequest) String 

func (m *RPCPublishPublisherUpdateRequest) String() 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 (m *RPCPublishPublisherUpdateResponse) Reset()

func (*RPCPublishPublisherUpdateResponse) String 

func (m *RPCPublishPublisherUpdateResponse) String() 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 

func (m *RPCReceiveDirectMessageRequest) String() 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

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.