util

Documentation

Index

• func CheckedCast[To, From Int](v From) (To, error)
• func DedupRegistrationEntries(entries []*common.RegistrationEntry) []*common.RegistrationEntry
• func EqualsSelectors(a, b []*common.Selector) bool
• func GetSHA256Digest(path string, limit int64) (string, error)
• func GetTargetName(addr net.Addr) (string, error)
• func GetUnixAddr(name string) *net.UnixAddr
• func GetUnixAddrWithAbsPath(path string) (*net.UnixAddr, error)
• func GetWorkloadAPIClientOption(addr net.Addr) (workloadapi.ClientOption, error)
• func LoadCertPool(path string) (*x509.CertPool, error)
• func LoadCertificates(path string) ([]*x509.Certificate, error)
• func MakeCSR(privateKey any, spiffeID spiffeid.ID) ([]byte, error)
• func MakeCSRWithoutURISAN(privateKey any) ([]byte, error)
• func MustCast[To, From Int](v From) To
• func NewCertPool(certs ...*x509.Certificate) *x509.CertPool
• func NewGRPCClient(target string, options ...grpc.DialOption) (*grpc.ClientConn, error)
• func RunTasks(ctx context.Context, tasks ...func(context.Context) error) error
• func SortRegistrationEntries(entries []*common.RegistrationEntry)
• func SortSelectors(selectors []*common.Selector)
• func SortTypesEntries(entries []*types.Entry)
• func SortTypesSelectors(selectors []*types.Selector)
• type Int

Functions

func CheckedCast

func CheckedCast[To, From Int](v From) (To, error)

func DedupRegistrationEntries

func DedupRegistrationEntries(entries []*common.RegistrationEntry) []*common.RegistrationEntry

func EqualsSelectors

func EqualsSelectors(a, b []*common.Selector) bool

func GetSHA256Digest

func GetSHA256Digest(path string, limit int64) (string, error)

GetSHA256Digest calculates the sha256 digest of a file specified by path. If the size of the file exceeds the provided limit, the hash will not be calculated and an error will be returned instead.

func GetTargetName

func GetTargetName(addr net.Addr) (string, error)

GetTargetName gets the fully qualified, self-contained name used for gRPC channel construction. Supported networks are unix and tcp. Unix paths must be absolute.

func GetUnixAddr

func GetUnixAddr(name string) *net.UnixAddr

func GetUnixAddrWithAbsPath

func GetUnixAddrWithAbsPath(path string) (*net.UnixAddr, error)

GetUnixAddr returns a unix address with the designated path. Path is converted to an absolute path when constructing the returned unix domain socket address.

func GetWorkloadAPIClientOption

func GetWorkloadAPIClientOption(addr net.Addr) (workloadapi.ClientOption, error)

func LoadCertPool

func LoadCertPool(path string) (*x509.CertPool, error)

LoadCertPool loads one or more certificates into an *x509.CertPool from a PEM file on disk.

func LoadCertificates

func LoadCertificates(path string) ([]*x509.Certificate, error)

LoadCertificates loads one or more certificates into an []*x509.Certificate from a PEM file on disk.

func MakeCSR

func MakeCSR(privateKey any, spiffeID spiffeid.ID) ([]byte, error)

func MakeCSRWithoutURISAN

func MakeCSRWithoutURISAN(privateKey any) ([]byte, error)

func MustCast

func MustCast[To, From Int](v From) To

func NewCertPool

func NewCertPool(certs ...*x509.Certificate) *x509.CertPool

NewCertPool creates a new *x509.CertPool based on the certificates given as parameters.

func NewGRPCClient

func NewGRPCClient(target string, options ...grpc.DialOption) (*grpc.ClientConn, error)

func RunTasks

func RunTasks(ctx context.Context, tasks ...func(context.Context) error) error

RunTasks executes all the provided functions concurrently and waits for them all to complete. If a function returns an error, all other functions are canceled (i.e. the context they are passed is canceled) and the error is returned. If all functions finish to completion successfully, RunTasks returns nil. If the context passed to RunTasks is canceled then each function is canceled and RunTasks returns ctx.Err(). Tasks passed to RunTasks MUST support cancellation via the provided context for RunTasks to work properly.

func SortRegistrationEntries

func SortRegistrationEntries(entries []*common.RegistrationEntry)

func SortSelectors

func SortSelectors(selectors []*common.Selector)

func SortTypesEntries

func SortTypesEntries(entries []*types.Entry)

func SortTypesSelectors

func SortTypesSelectors(selectors []*types.Selector)

Types

type Int

type Int interface {
	~int | ~int8 | ~int16 | ~int32 | ~int64 | ~uint | ~uint8 | ~uint16 | ~uint32 | ~uint64
}