util

package
v0.8.2-rc1 Latest Latest
Warning

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

 Go to latest Published: Feb 14, 2023 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrUnsupportedProtocolScheme = errors.New("unsupported protocol scheme")

Functions

func BindContext added in v0.5.4 

func BindContext[A any](ctx context.Context, f func(context.Context) A) func() A

func BindContext2 added in v0.5.4 

func BindContext2[A, B any](ctx context.Context, f func(context.Context) (A, B)) func() (A, B)

func DecodeStruct added in v0.4.1 

func DecodeStruct[T any](input interface{}) (*T, error)

func DeepCopy added in v0.4.1 

func DeepCopy[T any](in *T) *T

func DeepCopyInto added in v0.4.1 

func DeepCopyInto[T any](out, in *T)

func DialProtocol added in v0.5.4 

func DialProtocol(ctx context.Context, addr string) (net.Conn, error)

func GenerateRandomString added in v0.3.1 

func GenerateRandomString(length int) []byte

func Indexed added in v0.6.0 

func Indexed[T any, U any](f func(T) U) func(T, int) U

Used with lo.Map to wrap functions that do not take an index argument

func IsInterfaceNil added in v0.5.4 

func IsInterfaceNil(i interface{}) bool

func LoadClientMTLSConfig added in v0.4.1 

func LoadClientMTLSConfig(certs *v1beta1.MTLSSpec) (*tls.Config, error)

func LoadServingCertBundle added in v0.4.1 

func LoadServingCertBundle(certsSpec v1beta1.CertsSpec) (*tls.Certificate, *x509.CertPool, error)

func Must added in v0.4.1 

func Must[T any](t T, err ...error) T

func NewProtocolListener added in v0.4.1 

func NewProtocolListener(addr string) (net.Listener, error)

func ParsePEMEncodedCert added in v0.4.1 

func ParsePEMEncodedCert(data []byte) (*x509.Certificate, error)

func ParsePEMEncodedCertChain added in v0.4.1 

func ParsePEMEncodedCertChain(chain []byte) ([]*x509.Certificate, error)

func ProtoClone added in v0.5.4 

func ProtoClone[T proto.Message](msg T) T

func ReadString added in v0.6.0 

func ReadString(r io.Reader) string

func RemoveFirstOccurence added in v0.7.0 

func RemoveFirstOccurence[S ~[]T, T comparable](items S, remove T) S

func ReplaceFirstOccurrence added in v0.7.0 

func ReplaceFirstOccurrence[S ~[]T, T comparable](items S, old T, new T) S

func ServeHandler added in v0.6.0 

func ServeHandler(ctx context.Context, handler http.Handler, listener net.Listener) error

ServeHandler serves a http.Handler with the given listener. If the context is canceled, the server will be closed.

func StatusCode added in v0.5.4 

func StatusCode(err error) codes.Code

Like status.Code(), but supports wrapped errors.

func StatusError added in v0.5.4 

func StatusError(code codes.Code) error

func WaitAll added in v0.6.0 

func WaitAll(ctx context.Context, ca context.CancelFunc, channels ...<-chan error) error

WaitAll waits for all the given channels to be closed, under the following rules: 1. The lifetime of the task represented by each channel is directly tied to the provided context. 2. If a task exits with an error before the context is canceled, the context should be canceled. 3. If a task exits successfully, the context should not be canceled and other tasks should continue to run.

Types

type ClientStreamWithContext added in v0.5.4 

type ClientStreamWithContext struct {
	Stream grpc.ClientStream
	Ctx    context.Context
}

func (*ClientStreamWithContext) CloseSend added in v0.5.4 

func (s *ClientStreamWithContext) CloseSend() error

func (*ClientStreamWithContext) Context added in v0.5.4 

func (s *ClientStreamWithContext) Context() context.Context

func (*ClientStreamWithContext) Header added in v0.5.4 

func (s *ClientStreamWithContext) Header() (metadata.MD, error)

func (*ClientStreamWithContext) RecvMsg added in v0.5.4 

func (s *ClientStreamWithContext) RecvMsg(m interface{}) error

func (*ClientStreamWithContext) SendMsg added in v0.5.4 

func (s *ClientStreamWithContext) SendMsg(m interface{}) error

func (*ClientStreamWithContext) Trailer added in v0.5.4 

func (s *ClientStreamWithContext) Trailer() metadata.MD

type DelimiterCodec added in v0.4.1 

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

Implements rbac.Codec

func NewDelimiterCodec added in v0.4.1 

func NewDelimiterCodec(key string, delimiter string) DelimiterCodec

func (DelimiterCodec) Decode added in v0.4.1 

func (d DelimiterCodec) Decode(s string) []string

func (DelimiterCodec) Encode added in v0.4.1 

func (d DelimiterCodec) Encode(ids []string) string

func (DelimiterCodec) Key added in v0.4.1 

func (d DelimiterCodec) Key() string

type Initializer added in v0.6.0 

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

func (*Initializer) InitOnce added in v0.6.0 

func (i *Initializer) InitOnce(f func())

func (*Initializer) Initialized added in v0.6.0 

func (i *Initializer) Initialized() bool

func (*Initializer) WaitForInit added in v0.6.0 

func (i *Initializer) WaitForInit()

func (*Initializer) WaitForInitContext added in v0.6.0 

func (i *Initializer) WaitForInitContext(ctx context.Context) error

type LockMap added in v0.5.4 

type LockMap[K comparable, L sync.Locker] interface {
	Get(key K) L
	Delete(key K)
}

func NewLockMap added in v0.5.4 

func NewLockMap[K comparable, L locker[T], T any]() LockMap[K, L]

type ServerStreamWithContext added in v0.5.4 

type ServerStreamWithContext struct {
	Stream grpc.ServerStream
	Ctx    context.Context
}

func (*ServerStreamWithContext) Context added in v0.5.4 

func (s *ServerStreamWithContext) Context() context.Context

func (*ServerStreamWithContext) RecvMsg added in v0.5.4 

func (s *ServerStreamWithContext) RecvMsg(m interface{}) error

func (*ServerStreamWithContext) SendHeader added in v0.5.4 

func (s *ServerStreamWithContext) SendHeader(md metadata.MD) error

func (*ServerStreamWithContext) SendMsg added in v0.5.4 

func (s *ServerStreamWithContext) SendMsg(m interface{}) error

func (*ServerStreamWithContext) SetHeader added in v0.5.4 

func (s *ServerStreamWithContext) SetHeader(md metadata.MD) error

func (*ServerStreamWithContext) SetTrailer added in v0.5.4 

func (s *ServerStreamWithContext) SetTrailer(md metadata.MD)

type ServicePack added in v0.5.4 

type ServicePack[T any] struct {
	// contains filtered or unexported fields
}

func PackService added in v0.5.4 

func PackService[T any](desc *grpc.ServiceDesc, impl T) ServicePack[T]

func (ServicePack[T]) Unpack added in v0.5.4 

func (s ServicePack[T]) Unpack() (*grpc.ServiceDesc, any)

type ServicePackInterface added in v0.6.0 

type ServicePackInterface interface {
	Unpack() (*grpc.ServiceDesc, any)
}

Source Files

View all Source files

Directories

Path Synopsis
provider
Package for abstracting agent downstream updates and notifying upstream
 Package for abstracting agent downstream updates and notifying upstream

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.