services

package

v0.0.0-...-54cae78 Latest Latest Go to latest Published: Jul 27, 2020 License: MIT Imports: 25 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/videa-tv/grpc-client-cli

Documentation ¶

Index ¶

Variables
func DiagContext() context.Context
func DiagStreamClientInterceptor() grpc.StreamClientInterceptor
func DiagUnaryClientInterceptor() grpc.UnaryClientInterceptor
func IsTemporary(err error) bool
func MetadataStreamInterceptor(md map[string][]string) grpc.StreamClientInterceptor
func MetadataUnaryInterceptor(md map[string][]string) grpc.UnaryClientInterceptor
type ConnectionOptions
- func NewConnectionOpts(target string) (*ConnectionOptions, error)
type DiagInfo
- func ExtractDiagInfo(ctx context.Context) *DiagInfo
type FieldWalker
- func NewFieldWalker() *FieldWalker
- func (fw *FieldWalker) Walk(md *desc.MessageDescriptor, walkFn func(*desc.FieldDescriptor))
type GrpcConnFactory
- func NewGrpcConnFactory() *GrpcConnFactory
- func (f *GrpcConnFactory) Close() error
- func (f *GrpcConnFactory) CloseConn(target string) error
- func (f *GrpcConnFactory) GetConn(target string, opts ...grpc.DialOption) (*grpc.ClientConn, error)
- func (f *GrpcConnFactory) GetConnContext(ctx context.Context, target string, opts ...grpc.DialOption) (*grpc.ClientConn, error)
type ServiceCaller
- func NewServiceCaller(connFact *GrpcConnFactory) *ServiceCaller
- func (sc *ServiceCaller) CallJSON(ctx context.Context, serviceTarget string, methodDesc *desc.MethodDescriptor, ...) ([]byte, error)
- func (sc *ServiceCaller) CallServerStream(ctx context.Context, serviceTarget string, methodDesc *desc.MethodDescriptor, ...) (chan []byte, chan error)
type ServiceMeta
type ServiceMetaData
- func NewServiceMetaData(connFact *GrpcConnFactory) *ServiceMetaData
- func (s *ServiceMetaData) GetFileDescriptor(target, serviceName string) (*desc.FileDescriptor, error)
- func (s *ServiceMetaData) GetMethodDescriptor(target, service, methodName string) (*desc.MethodDescriptor, error)
- func (s *ServiceMetaData) GetOutputMessageDescriptor(target, service, methodName string) (*desc.MessageDescriptor, error)
- func (s *ServiceMetaData) GetOutputMessageDescriptorParse(target, fullMethodName string) (*desc.MessageDescriptor, error)
- func (s *ServiceMetaData) GetServiceMetaDataList(target string, deadline int) ([]*ServiceMeta, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrNotFound = errors.New("grpc element not found")
)

Functions ¶

func DiagContext ¶

func DiagContext() context.Context

func DiagStreamClientInterceptor ¶

func DiagStreamClientInterceptor() grpc.StreamClientInterceptor

func DiagUnaryClientInterceptor ¶

func DiagUnaryClientInterceptor() grpc.UnaryClientInterceptor

func IsTemporary ¶

func IsTemporary(err error) bool

IsTemporary returns true if err is temporary.

func MetadataStreamInterceptor ¶

func MetadataStreamInterceptor(md map[string][]string) grpc.StreamClientInterceptor

func MetadataUnaryInterceptor ¶

func MetadataUnaryInterceptor(md map[string][]string) grpc.UnaryClientInterceptor

Types ¶

type ConnectionOptions ¶

type ConnectionOptions struct {
	Host      string
	Authority string
	Metadata  map[string][]string
}

func NewConnectionOpts ¶

func NewConnectionOpts(target string) (*ConnectionOptions, error)

type DiagInfo ¶

type DiagInfo struct {
	Duration time.Duration
	RespSize int
	ReqSize  int
}

func ExtractDiagInfo ¶

func ExtractDiagInfo(ctx context.Context) *DiagInfo

type FieldWalker ¶

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

FieldWalker walks fields message fields tree calling func for every field

func NewFieldWalker ¶

func NewFieldWalker() *FieldWalker

func (*FieldWalker) Walk ¶

func (fw *FieldWalker) Walk(md *desc.MessageDescriptor, walkFn func(*desc.FieldDescriptor))

type GrpcConnFactory ¶

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

func NewGrpcConnFactory ¶

func NewGrpcConnFactory() *GrpcConnFactory

func (*GrpcConnFactory) Close ¶

func (f *GrpcConnFactory) Close() error

func (*GrpcConnFactory) CloseConn ¶

func (f *GrpcConnFactory) CloseConn(target string) error

func (*GrpcConnFactory) GetConn ¶

func (f *GrpcConnFactory) GetConn(target string, opts ...grpc.DialOption) (*grpc.ClientConn, error)

func (*GrpcConnFactory) GetConnContext ¶

func (f *GrpcConnFactory) GetConnContext(ctx context.Context, target string, opts ...grpc.DialOption) (*grpc.ClientConn, error)

type ServiceCaller ¶

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

func NewServiceCaller ¶

func NewServiceCaller(connFact *GrpcConnFactory) *ServiceCaller

func (*ServiceCaller) CallJSON ¶

func (sc *ServiceCaller) CallJSON(ctx context.Context, serviceTarget string, methodDesc *desc.MethodDescriptor, reqJSON []byte, callOpts ...grpc.CallOption) ([]byte, error)

func (*ServiceCaller) CallServerStream ¶

func (sc *ServiceCaller) CallServerStream(ctx context.Context, serviceTarget string, methodDesc *desc.MethodDescriptor, reqJSON []byte, callOpts ...grpc.CallOption) (chan []byte, chan error)

type ServiceMeta ¶

type ServiceMeta struct {
	Name    string
	Methods []*desc.MethodDescriptor
	File    *desc.FileDescriptor
}

type ServiceMetaData ¶

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

func NewServiceMetaData ¶

func NewServiceMetaData(connFact *GrpcConnFactory) *ServiceMetaData

func (*ServiceMetaData) GetFileDescriptor ¶

func (s *ServiceMetaData) GetFileDescriptor(target, serviceName string) (*desc.FileDescriptor, error)

func (*ServiceMetaData) GetMethodDescriptor ¶

func (s *ServiceMetaData) GetMethodDescriptor(target, service, methodName string) (*desc.MethodDescriptor, error)

func (*ServiceMetaData) GetOutputMessageDescriptor ¶

func (s *ServiceMetaData) GetOutputMessageDescriptor(target, service, methodName string) (*desc.MessageDescriptor, error)

func (*ServiceMetaData) GetOutputMessageDescriptorParse ¶

func (s *ServiceMetaData) GetOutputMessageDescriptorParse(target, fullMethodName string) (*desc.MessageDescriptor, error)

func (*ServiceMetaData) GetServiceMetaDataList ¶

func (s *ServiceMetaData) GetServiceMetaDataList(target string, deadline int) ([]*ServiceMeta, error)

Source Files ¶

View all Source files

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