Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NormalizeMethod ¶
NormalizeMethod - приводит метод к стандартному виду '/package.Service/Call' из 'package.Service.Call'.
Types ¶
type CachedFetcher ¶
type CachedFetcher struct {
// contains filtered or unexported fields
}
func NewCachedFetcher ¶
func NewCachedFetcher(next Fetcher) *CachedFetcher
func (*CachedFetcher) Fetch ¶
func (f *CachedFetcher) Fetch(ctx context.Context) (DynamicMessagesStore, error)
type DynamicMessagesStore ¶
type DynamicMessagesStore interface {
// must return nil if not found
Get(methodName []byte) (message *dynamic.Message, release func())
}
func NewDynamicMessagesStore ¶
func NewDynamicMessagesStore(descriptors []*desc.MethodDescriptor) DynamicMessagesStore
type ErrFetcher ¶
type ErrFetcher struct {
// contains filtered or unexported fields
}
func NewErrFetcher ¶
func NewErrFetcher(err error) *ErrFetcher
func (*ErrFetcher) Fetch ¶
func (f *ErrFetcher) Fetch(context.Context) (DynamicMessagesStore, error)
type LocalFetcher ¶
type LocalFetcher struct {
// contains filtered or unexported fields
}
func NewLocalFetcher ¶
func NewLocalFetcher(filenames, importPaths []string) LocalFetcher
func (LocalFetcher) Fetch ¶
func (f LocalFetcher) Fetch(context.Context) (DynamicMessagesStore, error)
type RemoteFetcher ¶
type RemoteFetcher struct {
// contains filtered or unexported fields
}
func NewRemoteFetcher ¶
func NewRemoteFetcher(conn *grpc.ClientConn) *RemoteFetcher
func (*RemoteFetcher) Fetch ¶
func (f *RemoteFetcher) Fetch(ctx context.Context) (DynamicMessagesStore, error)
func (*RemoteFetcher) Warnings ¶
func (f *RemoteFetcher) Warnings() []string
type WarnLogger ¶
type WarnLogger interface {
Println(string)
}
Source Files
Click to show internal directories.
Click to hide internal directories.