signaling_client

package module
v0.0.0-...-82e3b92 Latest Latest
Warning

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

Go to latest
Published: Oct 6, 2023 License: MIT Imports: 14 Imported by: 4

README

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (

	// 3: error
	ErrorLevel int32 = 3
)

Functions

func Debugf

func Debugf(format string, args ...interface{})

func Errorf

func Errorf(format string, args ...interface{})

func GenerateCallId

func GenerateCallId() string

GenerateCallId 生成一个唯一的callId

func Infof

func Infof(format string, args ...interface{})

func Warnf

func Warnf(format string, args ...interface{})

Types

type CallRequest

type CallRequest struct {
	//对端id
	PeerId string `json:"peerId"`
	//请求id
	CallId string `json:"callId"`
	//请求方法
	Method string `json:"method"`
	//请求携带的数据
	Data []byte `json:"data"`
}

func (*CallRequest) FromBytes

func (r *CallRequest) FromBytes(data []byte) error

func (*CallRequest) ToBytes

func (r *CallRequest) ToBytes() []byte

type CallResponse

type CallResponse struct {
	//请求id
	CallId string `json:"callId"`
	//请求方法
	Method string `json:"method"`
	//响应状态
	Status CallResponseCode `json:"status"`
	//响应携带的数据
	Data []byte `json:"data"`
}

func (*CallResponse) FromBytes

func (r *CallResponse) FromBytes(msg []byte) error

func (*CallResponse) ToBytes

func (r *CallResponse) ToBytes() []byte

type CallResponseCode

type CallResponseCode uint32
const (
	// CodeOK is returned on success.
	CodeOK CallResponseCode = 0

	// CodeCanceled indicates the operation was canceled (typically by the caller).
	//
	// The gRPC framework will generate this error code when cancellation
	// is requested.
	CodeCanceled CallResponseCode = 1

	// CodeUnknown error. An example of where this error may be returned is
	// if a Status value received from another address space belongs to
	// an error-space that is not known in this address space. Also
	// errors raised by APIs that do not return enough error information
	// may be converted to this error.
	//
	// The gRPC framework will generate this error code in the above two
	// mentioned cases.
	CodeUnknown CallResponseCode = 2

	// CodeInvalidArgument indicates client specified an invalid argument.
	// Note that this differs from FailedPrecondition. It indicates arguments
	// that are problematic regardless of the state of the system
	// (e.g., a malformed file name).
	//
	// This error code will not be generated by the gRPC framework.
	CodeInvalidArgument CallResponseCode = 3

	// CodeDeadlineExceeded means operation expired before completion.
	// For operations that change the state of the system, this error may be
	// returned even if the operation has completed successfully. For
	// example, a successful response from a server could have been delayed
	// long enough for the deadline to expire.
	//
	// The gRPC framework will generate this error code when the deadline is
	// exceeded.
	CodeDeadlineExceeded CallResponseCode = 4

	// CodeNotFound means some requested entity (e.g., file or directory) was
	// not found.
	//
	// This error code will not be generated by the gRPC framework.
	CodeNotFound CallResponseCode = 5

	// CodeAlreadyExists means an attempt to create an entity failed because one
	// already exists.
	//
	// This error code will not be generated by the gRPC framework.
	CodeAlreadyExists CallResponseCode = 6

	// CodePermissionDenied indicates the caller does not have permission to
	// execute the specified operation. It must not be used for rejections
	// caused by exhausting some resource (use ResourceExhausted
	// instead for those errors). It must not be
	// used if the caller cannot be identified (use Unauthenticated
	// instead for those errors).
	//
	// This error code will not be generated by the gRPC core framework,
	// but expect authentication middleware to use it.
	CodePermissionDenied CallResponseCode = 7

	// CodeResourceExhausted indicates some resource has been exhausted, perhaps
	// a per-user quota, or perhaps the entire file system is out of space.
	//
	// This error code will be generated by the gRPC framework in
	// out-of-memory and server overload situations, or when a message is
	// larger than the configured maximum size.
	CodeResourceExhausted CallResponseCode = 8

	// CodeFailedPrecondition indicates operation was rejected because the
	// system is not in a state required for the operation's execution.
	// For example, directory to be deleted may be non-empty, an rmdir
	// operation is applied to a non-directory, etc.
	//
	// A litmus test that may help a service implementor in deciding
	// between FailedPrecondition, Aborted, and Unavailable:
	//  (a) Use Unavailable if the client can retry just the failing call.
	//  (b) Use Aborted if the client should retry at a higher-level
	//      (e.g., restarting a read-modify-write sequence).
	//  (c) Use FailedPrecondition if the client should not retry until
	//      the system state has been explicitly fixed. E.g., if an "rmdir"
	//      fails because the directory is non-empty, FailedPrecondition
	//      should be returned since the client should not retry unless
	//      they have first fixed up the directory by deleting files from it.
	//  (d) Use FailedPrecondition if the client performs conditional
	//      REST Get/Update/Delete on a resource and the resource on the
	//      server does not match the condition. E.g., conflicting
	//      read-modify-write on the same resource.
	//
	// This error code will not be generated by the gRPC framework.
	CodeFailedPrecondition CallResponseCode = 9

	// CodeAborted indicates the operation was aborted, typically due to a
	// concurrency issue like sequencer check failures, transaction aborts,
	// etc.
	//
	// See litmus test above for deciding between FailedPrecondition,
	// Aborted, and Unavailable.
	//
	// This error code will not be generated by the gRPC framework.
	CodeAborted CallResponseCode = 10

	// CodeOutOfRange means operation was attempted past the valid range.
	// E.g., seeking or reading past end of file.
	//
	// Unlike InvalidArgument, this error indicates a problem that may
	// be fixed if the system state changes. For example, a 32-bit file
	// system will generate InvalidArgument if asked to read at an
	// offset that is not in the range [0,2^32-1], but it will generate
	// OutOfRange if asked to read from an offset past the current
	// file size.
	//
	// There is a fair bit of overlap between FailedPrecondition and
	// OutOfRange. We recommend using OutOfRange (the more specific
	// error) when it applies so that callers who are iterating through
	// a space can easily look for an OutOfRange error to detect when
	// they are done.
	//
	// This error code will not be generated by the gRPC framework.
	CodeOutOfRange CallResponseCode = 11

	// CodeUnimplemented indicates operation is not implemented or not
	// supported/enabled in this service.
	//
	// This error code will be generated by the gRPC framework. Most
	// commonly, you will see this error code when a method implementation
	// is missing on the server. It can also be generated for unknown
	// compression algorithms or a disagreement as to whether an RPC should
	// be streaming.
	CodeUnimplemented CallResponseCode = 12

	// CodeInternal errors. Means some invariants expected by underlying
	// system has been broken. If you see one of these errors,
	// something is very broken.
	//
	// This error code will be generated by the gRPC framework in several
	// internal error conditions.
	CodeInternal CallResponseCode = 13

	// CodeUnavailable indicates the service is currently unavailable.
	// This is a most likely a transient condition and may be corrected
	// by retrying with a backoff. Note that it is not always safe to retry
	// non-idempotent operations.
	//
	// See litmus test above for deciding between FailedPrecondition,
	// Aborted, and Unavailable.
	//
	// This error code will be generated by the gRPC framework during
	// abrupt shutdown of a server process or network connection.
	CodeUnavailable CallResponseCode = 14

	// CodeDataLoss indicates unrecoverable data loss or corruption.
	//
	// This error code will not be generated by the gRPC framework.
	CodeDataLoss CallResponseCode = 15

	// CodeUnauthenticated indicates the request does not have valid
	// authentication credentials for the operation.
	//
	// The gRPC framework will generate this error code when the
	// authentication metadata is invalid or a Credentials callback fails,
	// but also expect authentication middleware to generate it.
	CodeUnauthenticated CallResponseCode = 16
)

func (CallResponseCode) String

func (c CallResponseCode) String() string

type Config

type Config struct {
	PeerId   string
	Endpoint string
	LogLevel string // debug, info, warn, error
}

func (*Config) Url

func (c *Config) Url() string

type HttpConnection

type HttpConnection struct {
	// contains filtered or unexported fields
}

func NewHttpConnection

func NewHttpConnection(c *Config) *HttpConnection

func (*HttpConnection) Call

func (c *HttpConnection) Call(ctx context.Context, request *CallRequest) *CallResponse

type MethodHandler

type MethodHandler func(request *CallRequest) *CallResponse

type ServerConnection

type ServerConnection struct {
	// contains filtered or unexported fields
}

func RegisterPeer

func RegisterPeer(c *Config, methodHandlers map[string]MethodHandler) *ServerConnection

func (*ServerConnection) Call

func (c *ServerConnection) Call(ctx context.Context, request *CallRequest) *CallResponse

Directories

Path Synopsis
examples
httpcalling Module
peercalling Module
peerserver Module

Jump to

Keyboard shortcuts

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