import "github.com/smallnest/rpcx/share"
const ( // DefaultRPCPath is used by ServeHTTP. DefaultRPCPath = "/_rpcx_" // AuthKey is used in metadata. AuthKey = "__AUTH" // ServerTimeout timeout value passed from client to control timeout of server ServerTimeout = "__ServerTimeout" // OpentracingSpanServerKey key in service context OpentracingSpanServerKey = "opentracing_span_server_key" // OpentracingSpanClientKey key in client context OpentracingSpanClientKey = "opentracing_span_client_key" // OpencensusSpanServerKey key in service context OpencensusSpanServerKey = "opencensus_span_server_key" // OpencensusSpanClientKey key in client context OpencensusSpanClientKey = "opencensus_span_client_key" // OpencensusSpanRequestKey span key in request meta OpencensusSpanRequestKey = "opencensus_span_request_key" // SendFileServiceName file transfer service. SendFileServiceName = "_filetransfer" )
var ( // Codecs are codecs supported by rpcx. You can add customized codecs in Codecs. Codecs = map[protocol.SerializeType]codec.Codec{ protocol.SerializeNone: &codec.ByteCodec{}, protocol.JSON: &codec.JSONCodec{}, protocol.ProtoBuffer: &codec.PBCodec{}, protocol.MsgPack: &codec.MsgpackCodec{}, protocol.Thrift: &codec.ThriftCodec{}, } )
var ReqMetaDataKey = ContextKey("__req_metadata")
ReqMetaDataKey is used to set metatdata in context of requests.
var ResMetaDataKey = ContextKey("__res_metadata")
ResMetaDataKey is used to set metatdata in context of responses.
GetOpencensusSpanContextFromContext get opencensus.trace.SpanContext from context.Context.
func GetSpanContextFromContext(ctx context.Context) (opentracing.SpanContext, error)
GetSpanContextFromContext get opentracing.SpanContext from context.Context.
func RegisterCodec(t protocol.SerializeType, c codec.Codec)
RegisterCodec register customized codec.
Context is a rpcx customized Context that can contains multiple values.
ContextKey defines key type in context.
DownloadFileArgs args from clients.
type FileTransferArgs struct { FileName string `json:"file_name,omitempty"` FileSize int64 `json:"file_size,omitempty"` Meta map[string]string `json:"meta,omitempty"` }
FileTransferArgs args from clients.
type FileTransferReply struct { Token []byte `json:"token,omitempty"` Addr string `json:"addr,omitempty"` }
FileTransferReply response to token and addr to clients.
Package share imports 8 packages (graph) and is imported by 28 packages. Updated 2021-01-04. Refresh now. Tools for package owners.