grpcutils

Documentation

Index

• Constants
• Variables
• func BuildAlreadyExistsGrpcError(msg string) error
• func BuildErrorForUUID(ID types.UniqueID, name string, err error) error
• func BuildInternalGrpcError(msg string) error
• func BuildInvalidArgumentGrpcError(fieldName string, desc string) (error, error)
• func BuildNotFoundGrpcError(msg string) error
• type GrpcConfig
  • func (c *GrpcConfig) MTLSEnabled() bool
• type GrpcProvider
• type GrpcServer

Constants

const (
	ReadinessProbeService = "chroma-readiness"
)

Variables

var Default = &defaultProvider{}

Functions

func BuildAlreadyExistsGrpcError

func BuildAlreadyExistsGrpcError(msg string) error

func BuildErrorForUUID

func BuildErrorForUUID(ID types.UniqueID, name string, err error) error

func BuildInternalGrpcError

func BuildInternalGrpcError(msg string) error

func BuildInvalidArgumentGrpcError

func BuildInvalidArgumentGrpcError(fieldName string, desc string) (error, error)

func BuildNotFoundGrpcError

func BuildNotFoundGrpcError(msg string) error

Types

type GrpcConfig

type GrpcConfig struct {
	// BindAddress is the address to bind the GRPC server to.
	BindAddress string

	// GRPC mTLS config
	CertPath string
	KeyPath  string
	CAPath   string
}

func (*GrpcConfig) MTLSEnabled

func (c *GrpcConfig) MTLSEnabled() bool

type GrpcProvider

type GrpcProvider interface {
	StartGrpcServer(name string, grpcConfig *GrpcConfig, registerFunc func(grpc.ServiceRegistrar)) (GrpcServer, error)
}

type GrpcServer

type GrpcServer interface {
	io.Closer

	Port() int
}