resources

package

Go to main page

Versions in this module

v0

v0.1.148

Dec 4, 2024

v0.1.147

Dec 4, 2024

v0.1.146

Dec 4, 2024

v0.1.145

Dec 4, 2024

v0.1.144

Nov 15, 2024

Changes in this version

type ServiceIdentity

+ func (s *ServiceIdentity) Proto() (*basev0.ServiceIdentity, error)

v0.1.143

Oct 30, 2024

v0.1.142

Oct 30, 2024

v0.1.141

Oct 30, 2024

Changes in this version

+ func ConfigurationValue(_ context.Context, confInfo *basev0.ConfigurationInformation, key string) (string, error)

+ func Match(s, other string) bool

+ func SplitPublicNetworkMappings(ctx context.Context, mappings []*basev0.NetworkMapping) ([]*basev0.NetworkMapping, []*basev0.NetworkMapping, error)

type EndpointAccess

+ Endpoint *basev0.Endpoint

+ NetworkInstance *basev0.NetworkInstance

type EnvironmentVariableManager

+ func (holder *EnvironmentVariableManager) AddEnvironmentVariable(ctx context.Context, key string, value string)

+ type EnvironmentVariableOption func(*EnvironmentVariableOptions)

+ func WithNonPublicEnvironmentVariablePrefix(prefix string) EnvironmentVariableOption

+ func WithPublicEnvironmentVariablePrefix(prefix string) EnvironmentVariableOption

+ type EnvironmentVariableOptions struct

v0.1.140

Oct 8, 2024

v0.1.139

Oct 7, 2024

Changes in this version

type Workspace

+ Path string

v0.1.138

Jul 28, 2024

v0.1.137

Jul 28, 2024

Changes in this version

type Module

+ func LoadModuleFromCurrentPath(ctx context.Context) (*Module, error)

v0.1.136

Jul 28, 2024

v0.1.135

Jul 28, 2024

v0.1.134

Jul 28, 2024

Changes in this version

type Service

+ func LoadServiceFromCurrentPath(ctx context.Context) (*Service, error)

v0.1.133

Jul 27, 2024

Changes in this version

+ func Method(item spec.PathItem) string

+ func RouteKey(path string, method string) string

type EnvironmentVariable

+ func ConfigurationAsRawEnvironmentVariables(conf *basev0.Configuration) []*EnvironmentVariable

type EnvironmentVariableManager

+ func (holder *EnvironmentVariableManager) AddRawConfigurations(_ context.Context, configurations ...*basev0.Configuration) error

v0.1.132

Jul 19, 2024

v0.1.131

Jul 18, 2024

Changes in this version

+ func RuntimeContextFromEnv() *basev0.RuntimeContext

v0.1.130

Jul 17, 2024

v0.1.129

Jul 17, 2024

v0.1.128

Jul 17, 2024

Changes in this version

+ func LoadModuleAndServiceFromCurrentPath(ctx context.Context) (*Module, *Service, error)

type Module

+ func LoadModuleFromDir(ctx context.Context, dir string) (*Module, error)

v0.1.127

Jul 17, 2024

Changes in this version

+ func FilterConfigurationInformation(_ context.Context, name string, infos ...*basev0.ConfigurationInformation) (*basev0.ConfigurationInformation, error)

+ type MustServiceUnique struct

+ func WithUnique(s *Service) *MustServiceUnique

+ func (m *MustServiceUnique) Unique() string

type Service

+ func (s *Service) MustUnique() string

+ func (s *Service) WithModule(mod string)

type ServiceIdentity

+ func (s *ServiceIdentity) BaseEndpoint(name string) *Endpoint

+ func (s *ServiceIdentity) UniqueWithWorkspace(workspace string) string

+ func (s *ServiceIdentity) UniqueWithWorkspaceAndScope(workspace string, scope string) string

type Workspace

+ func (workspace *Workspace) FindUniqueModuleServiceByName(ctx context.Context, name string) (*Service, *Module, error)

v0.1.126

Jul 14, 2024

Changes in this version

+ func GetConfigurationInformation(ctx context.Context, conf *basev0.Configuration, name string) (*basev0.ConfigurationInformation, error)

v0.1.125

Jul 13, 2024

v0.1.124

Jul 13, 2024

v0.1.123

Jul 8, 2024

Changes in this version

+ func FilterNetworkInstance(_ context.Context, instances []*basev0.NetworkInstance, ...) *basev0.NetworkInstance

+ func FindWorkspaceConfiguration(_ context.Context, confs []*basev0.Configuration, name string) (*basev0.Configuration, error)

type EndpointReference

+ func (e *EndpointReference) GetAPI() string

type Environment

+ NamingScope string

type Service

+ WorkspaceConfigurationDependencies []string

+ func (s *Service) UniqueWithWorspaceAndScope(workspace string, scope string) string

v0.1.122

Jul 4, 2024

Changes in this version

+ const FixturePrefix

type EnvironmentVariable

+ func FixtureAsEnvironmentVariable(fixture string) *EnvironmentVariable

type EnvironmentVariableManager

+ func (holder *EnvironmentVariableManager) SetFixture(fixture string)

v0.1.121

Jul 4, 2024

Changes in this version

+ func FindGRPCEndpointFromService(ctx context.Context, service *ServiceDependency, endpoints []*basev0.Endpoint) (*basev0.Endpoint, error)

type EndpointReference

+ Api string

+ func (e *EndpointReference) API() string

v0.1.118

Jul 3, 2024

v0.1.117

Jul 2, 2024

v0.1.116

Jul 1, 2024

Changes in this version

+ type ModuleWithCase struct

+ Name shared.Case

+ func ToModuleWithCase(svc *Service) *ModuleWithCase

v0.1.115

Jul 1, 2024

v0.1.114

Jul 1, 2024

Changes in this version

+ func FindServiceConfiguration(_ context.Context, confs []*basev0.Configuration, ...) (*basev0.Configuration, error)

type EnvironmentVariable

+ func ParseEnv(env string) *EnvironmentVariable

v0.1.113

Jun 1, 2024

v0.1.112

May 23, 2024

v0.1.111

May 23, 2024

v0.1.110

May 22, 2024

v0.1.109

May 21, 2024

Changes in this version

+ func AgentBase(ctx context.Context) string

+ func FindConfigDir() (*string, error)

+ func ValidateRuntimeContext(rc string) error

type ServiceIdentity

+ RelativeToWorkspace string

+ WorkspacePath string

type Workspace

+ func (workspace *Workspace) RelativeDir(service *Service) (string, error)

v0.1.107

May 20, 2024

v0.1.106

May 18, 2024

v0.1.105

May 18, 2024

v0.1.104

May 18, 2024

v0.1.103

May 18, 2024

v0.1.102

May 16, 2024

v0.1.101

May 16, 2024

v0.1.100

May 16, 2024

v0.1.99

May 15, 2024

v0.1.98

May 15, 2024

v0.1.97

May 15, 2024

v0.1.96

May 15, 2024

v0.1.95

May 15, 2024

Changes in this version

type RestRouteAccess

+ func ExtractRestRoutes(ctx context.Context, mappings []*basev0.NetworkMapping, ...) ([]*RestRouteAccess, error)

v0.1.94

May 13, 2024

v0.1.93

May 13, 2024

Changes in this version

+ func MakeEndpointAccessSummary(endointAccess *EndpointAccess) string

+ func MakeManyEndpointAccessSummary(endointAccess []*EndpointAccess) string

+ func MakeNetworkInstanceSummary(instance *basev0.NetworkInstance) string

type EnvironmentVariableManager

+ func (holder *EnvironmentVariableManager) Endpoints() []*EndpointAccess

v0.1.92

May 13, 2024

v0.1.91

May 13, 2024

v0.1.90

May 11, 2024

v0.1.89

May 11, 2024

Changes in this version

+ const AGENT

+ const AgentConfigurationName

+ const BuilderServiceAgent

+ const ConfigurationWorkspace

+ const ENDPOINT

+ const EndpointPrefix

+ const EnvironmentPrefix

+ const GRPCRouteFileSuffix

+ const MODULE

+ const ModuleConfigurationName

+ const ModuleKind

+ const ModulePrefix

+ const NetworkAccessContainer

+ const NetworkAccessNative

+ const NetworkAccessPublic

+ const RestRouteFileSuffix

+ const RestRoutePrefix

+ const RunningPrefix

+ const RuntimeContextContainer

+ const RuntimeContextFree

+ const RuntimeContextNative

+ const RuntimeContextPrefix

+ const RuntimeServiceAgent

+ const SERVICE

+ const ServiceAgent

+ const ServiceConfigurationName

+ const ServiceConfigurationPrefix

+ const ServicePrefix

+ const ServiceSecretConfigurationPrefix

+ const VersionPrefix

+ const WORKSPACE

+ const WorkspaceConfigurationName

+ const WorkspaceConfigurationPrefix

+ const WorkspacePrefix

+ const WorkspaceSecretConfigurationPrefix

+ func APIString(api *basev0.API) string

+ func CodeflyDir() string

+ func ConfigurationEnvironmentKeyPrefix(conf *basev0.Configuration) string

+ func ConfigurationFile[C Configuration]() string

+ func ConfigurationHash(conf *basev0.Configuration) string

+ func ConfigurationInformationHash(info *basev0.ConfigurationInformation) string

+ func ConfigurationInformationsHash(infos ...*basev0.ConfigurationInformation) (string, error)

+ func ConfigurationsHash(confs ...*basev0.Configuration) string

+ func ConvertHTTPMethodToProto(m HTTPMethod) basev0.HTTPMethod

+ func ConvertSpec(spec map[string]any) (*basev0.Specs, error)

+ func ConvertToAnyPb(value any) (*anypb.Any, error)

+ func EndpointAsEnvironmentVariableKey(info *EndpointInformation) string

+ func EndpointAsEnvironmentVariableKeyBase(info *EndpointInformation) string

+ func EndpointDestination(e *basev0.Endpoint) string

+ func EndpointHash(ctx context.Context, endpoints ...*basev0.Endpoint) (string, error)

+ func EndpointRestAPI(endpoint *basev0.Endpoint) *basev0.RestAPI

+ func EnvironmentVariableAsStrings(envs []EnvironmentVariable) []string

+ func ExistsAtDir[C Configuration](dir string) bool

+ func ExtendDomain(domain string, extension string) string

+ func ExtractConfiguration(configurations []*basev0.Configuration, runtimeContext *basev0.RuntimeContext) (*basev0.Configuration, error)

+ func FilePathForGRPC(ctx context.Context, dir string, unique string, name string) (string, error)

+ func FilePathForRest(ctx context.Context, dir string, unique string, routePath string) (string, error)

+ func FilterConfigurations(configurations []*basev0.Configuration, runtimeContext *basev0.RuntimeContext) []*basev0.Configuration

+ func FindConfigurationValue(conf *basev0.Configuration, name string, key string) (string, error)

+ func FindConfigurations(configurations []*basev0.Configuration, runtime *basev0.RuntimeContext) []*basev0.Configuration

+ func FindEndpointForGRPCRoute(ctx context.Context, endpoints []*basev0.Endpoint, route *GRPCRoute) *basev0.Endpoint

+ func FindEndpointForRestRoute(ctx context.Context, endpoints []*basev0.Endpoint, route *RestRouteGroup) *basev0.Endpoint

+ func FindGRPCEndpoint(ctx context.Context, endpoints []*basev0.Endpoint) (*basev0.Endpoint, error)

+ func FindHTTPEndpoint(ctx context.Context, endpoints []*basev0.Endpoint) (*basev0.Endpoint, error)

+ func FindNetworkInstanceInNetworkMappings(_ context.Context, mappings []*basev0.NetworkMapping, ...) (*basev0.NetworkInstance, error)

+ func FindNetworkMapping(_ context.Context, mappings []*basev0.NetworkMapping, ...) (*basev0.NetworkMapping, error)

+ func FindRestEndpoint(ctx context.Context, endpoints []*basev0.Endpoint) (*basev0.Endpoint, error)

+ func FindTCPEndpoint(ctx context.Context, endpoints []*basev0.Endpoint) (*basev0.Endpoint, error)

+ func FindTCPEndpointWithName(ctx context.Context, name string, endpoints []*basev0.Endpoint) (*basev0.Endpoint, error)

+ func FindUp[C Configuration](ctx context.Context) (*string, error)

+ func FindValueInEnvironmentVariables(ctx context.Context, key string, envs []string) (string, error)

+ func FromAnyPb[T any](v *anypb.Any) (*T, error)

+ func GetConfigurationValue(ctx context.Context, conf *basev0.Configuration, name string, key string) (string, error)

+ func GroupKey(endpoint *basev0.Endpoint, group *basev0.RestRouteGroup) string

+ func HasConfigurationInformation(_ context.Context, conf *basev0.Configuration, name string) bool

+ func HasPublicEndpoints(endpoints []*basev0.Endpoint) bool

+ func Hash(data []byte) string

+ func HashString(s string) string

+ func HomeDir() (string, error)

+ func InPartialMode() bool

+ func Init(ctx context.Context) (bool, error)

+ func IsGRPC(_ context.Context, endpoint *basev0.Endpoint) *basev0.GrpcAPI

+ func IsHTTP(_ context.Context, endpoint *basev0.Endpoint) *basev0.HttpAPI

+ func IsLocal(environment *basev0.Environment) bool

+ func IsRest(_ context.Context, endpoint *basev0.Endpoint) *basev0.RestAPI

+ func IsTCP(_ context.Context, endpoint *basev0.Endpoint) *basev0.TcpAPI

+ func Light(e *basev0.Endpoint) *basev0.Endpoint

+ func LightAPI(api *basev0.API) *basev0.API

+ func LoadFromBytes[C Configuration](content []byte) (*C, error)

+ func LoadFromDir[C Configuration](ctx context.Context, dir string) (*C, error)

+ func LoadFromFs[C Configuration](fs shared.FileSystem) (*C, error)

+ func LoadFromPath[C Configuration](ctx context.Context, p string) (*C, error)

+ func LoadGrpcAPI(_ context.Context, f *string) (*basev0.GrpcAPI, error)

+ func LoadHTTPAPI(_ context.Context) (*basev0.HttpAPI, error)

+ func LoadRestAPI(ctx context.Context, f *string) (*basev0.RestAPI, error)

+ func LoadSpec(ctx context.Context, content []byte, obj any) error

+ func LoadTCPAPI(_ context.Context) (*basev0.TcpAPI, error)

+ func LocalizeNetworkMapping(mappings []*basev0.NetworkMapping, hostname string) []*basev0.NetworkMapping

+ func MakeConfigurationInformationSummary(info *basev0.ConfigurationInformation) string

+ func MakeConfigurationSummary(conf *basev0.Configuration) string

+ func MakeConfigurationValueSummary(value *basev0.ConfigurationValue) string

+ func MakeDNSSummary(dns *basev0.DNS) string

+ func MakeEndpointSummary(endpoint *basev0.Endpoint) string

+ func MakeManyConfigurationSummary(confs []*basev0.Configuration) string

+ func MakeManyDNSSummary(dns []*basev0.DNS) string

+ func MakeManyNetworkMappingSummary(mappings []*basev0.NetworkMapping) string

+ func MakeManyServicesSummary(services []*Service) string

+ func MakeNetworkMappingSummary(mapping *basev0.NetworkMapping) string

+ func ModuleMode() bool

+ func NameToKey(name string) string

+ func NetworkAccessFromRuntimeContext(runtimeContext *basev0.RuntimeContext) *basev0.NetworkAccess

+ func NetworkInstanceSummary(value *basev0.NetworkInstance) string

+ func NetworkMappingHash(networkMappings ...*basev0.NetworkMapping) string

+ func NewAPI(_ context.Context, endpoint *Endpoint, api *basev0.API) (*basev0.Endpoint, error)

+ func NewContainerNetworkAccess() *basev0.NetworkAccess

+ func NewHTTPNetworkInstance(hostname string, port uint16, secured bool) *basev0.NetworkInstance

+ func NewNativeNetworkAccess() *basev0.NetworkAccess

+ func NewNetworkInstance(hostname string, port uint16) *basev0.NetworkInstance

+ func NewPublicNetworkAccess() *basev0.NetworkAccess

+ func NewRuntimeContext(runtimeContext string) (*basev0.RuntimeContext, error)

+ func NewRuntimeContextContainer() *basev0.RuntimeContext

+ func NewRuntimeContextFree() *basev0.RuntimeContext

+ func NewRuntimeContextNative() *basev0.RuntimeContext

+ func OverridePath(defaultPath string, path string) *string

+ func ParseOpenAPI(spec []byte) (*openapispec.Swagger, error)

+ func Path[C Configuration](ctx context.Context, dir string) (string, error)

+ func PortFromAddress(address string) (uint16, error)

+ func ReferenceMatch(entry string, name string) bool

+ func RegisterAgent(kind AgentKind, protoKind basev0.Agent_Kind)

+ func RestRouteEnvironmentVariableKey(info *EndpointInformation, route *basev0.RestRoute) string

+ func RestRoutes(rest *basev0.RestAPI) string

+ func RuntimeContextFromInstance(instance *basev0.NetworkInstance) *basev0.RuntimeContext

+ func RuntimeContexts() []string

+ func SaveToDir[C Configuration](ctx context.Context, c *C, dir string) error

+ func SerializeSpec(ctx context.Context, spec any) ([]byte, error)

+ func ServiceConfigurationEnvironmentKeyPrefixFromUnique(unique string) string

+ func ServiceConfigurationKey(service *Service, name string, key string) string

+ func ServiceConfigurationKeyFromUnique(unique string, name string, key string) string

+ func ServiceSecretConfigurationEnvironmentKeyPrefixFromUnique(unique string) string

+ func ServiceSecretConfigurationKey(service *Service, name string, key string) string

+ func ServiceSecretConfigurationKeyFromUnique(unique string, name string, key string) string

+ func ServiceUnique(app string, service string) string

+ func ServiceUniqueFromEndpoint(endpoint *basev0.Endpoint) string

+ func SetMode(m Mode)

+ func ToGrpcAPI(grpc *basev0.GrpcAPI) *basev0.API

+ func ToHTTPAPI(http *basev0.HttpAPI) *basev0.API

+ func ToOrganizationName(svc string) string

+ func ToOrganizationSourceVersionControl(name string) string

+ func ToRestAPI(rest *basev0.RestAPI) *basev0.API

+ func ToTCPAPI(tcp *basev0.TcpAPI) *basev0.API

+ func TypeName[C Configuration]() string

+ func UniqueToKey(origin string) string

+ func ValidOrganization(org *basev0.Organization) error

+ func Validate(req proto.Message) error

+ func ValidateAgent(agent *basev0.Agent) error

+ func ValidateDomain()

+ type Agent struct

+ Kind AgentKind

+ Name string

+ Publisher string

+ Version string

+ var CLI *Agent

+ func AgentFromProto(agent *basev0.Agent) *Agent

+ func LoadAgent(ctx context.Context, action *basev0.Agent) (*Agent, error)

+ func ParseAgent(ctx context.Context, k AgentKind, s string) (*Agent, error)

+ func (p *Agent) AsResource() *wool.Resource

+ func (p *Agent) Identifier() string

+ func (p *Agent) IsService() bool

+ func (p *Agent) Key(kind AgentKind, unique string) string

+ func (p *Agent) Of(kind AgentKind) *Agent

+ func (p *Agent) Patch() (*Agent, error)

+ func (p *Agent) Path() (string, error)

+ func (p *Agent) Proto() *basev0.Agent

+ func (p *Agent) String() string

+ func (p *Agent) Unique() string

+ type AgentKind string

+ func AgentKindFromProto(kind basev0.Agent_Kind) (*AgentKind, error)

+ type ClientEntry struct

+ APIs []string

+ Name string

+ func (c *ClientEntry) Validate() error

+ type Configuration interface

+ type DockerImage struct

+ Name string

+ Repository string

+ Tag string

+ func NewDockerImage(s string) *DockerImage

+ func (image *DockerImage) FullName() string

+ type Endpoint struct

+ API string

+ Description string

+ Module string

+ Name string

+ Service string

+ Visibility string

+ func EndpointFromProto(e *basev0.Endpoint) *Endpoint

+ func FromProtoEndpoints(es ...*basev0.Endpoint) ([]*Endpoint, error)

+ func (endpoint *Endpoint) AsReference() *EndpointReference

+ func (endpoint *Endpoint) Information() *EndpointInformation

+ func (endpoint *Endpoint) Proto() (*basev0.Endpoint, error)

+ func (endpoint *Endpoint) ServiceUnique() string

+ func (endpoint *Endpoint) Unique() string

+ type EndpointAccess struct

+ type EndpointInformation struct

+ API string

+ Module string

+ Name string

+ Service string

+ func EndpointInformationFromProto(endpoint *basev0.Endpoint) *EndpointInformation

+ func ParseEndpoint(unique string) (*EndpointInformation, error)

+ func (endpoint *EndpointInformation) Identifier() string

+ func (endpoint *EndpointInformation) UnknownAPI() bool

+ type EndpointReference struct

+ Name string

+ type EndpointSummary struct

+ Count int

+ Uniques []string

+ func MakeManyEndpointSummary(endpoints []*basev0.Endpoint) EndpointSummary

+ type Environment struct

+ Description string

+ Name string

+ func EnvironmentFromProto(env *basev0.Environment) *Environment

+ func LocalEnvironment() *Environment

+ func (env *Environment) Local() bool

+ func (env *Environment) Proto() (*basev0.Environment, error)

+ type EnvironmentExistsError struct

+ func (err *EnvironmentExistsError) Error() string

+ type EnvironmentReference struct

+ Name string

+ func (ref *EnvironmentReference) String() string

+ type EnvironmentVariable struct

+ Key string

+ Value any

+ func AsRestRouteEnvironmentVariable(ctx context.Context, endpoint *basev0.Endpoint) []EnvironmentVariable

+ func ConfigurationAsEnvironmentVariables(conf *basev0.Configuration, secret bool) []EnvironmentVariable

+ func EndpointAsEnvironmentVariable(endpoint *basev0.Endpoint, instance *basev0.NetworkInstance) EnvironmentVariable

+ func Env(key string, value any) EnvironmentVariable

+ func EnvironmentAsEnvironmentVariable(env *basev0.Environment) EnvironmentVariable

+ func ModuleAsEnvironmentVariable(module string) EnvironmentVariable

+ func RestRoutesAsEnvironmentVariable(endpoint *basev0.Endpoint, route *basev0.RestRoute) EnvironmentVariable

+ func RuntimeContextAsEnvironmentVariable(runtimeContext *basev0.RuntimeContext) EnvironmentVariable

+ func ServiceAsEnvironmentVariable(service string) EnvironmentVariable

+ func VersionAsEnvironmentVariable(version string) EnvironmentVariable

+ func WorkspaceAsEnvironmentVariable(workspace string) EnvironmentVariable

+ func (v EnvironmentVariable) String() string

+ func (v EnvironmentVariable) ValueAsEncodedString() string

+ func (v EnvironmentVariable) ValueAsString() string

+ type EnvironmentVariableManager struct

+ func NewEnvironmentVariableManager() *EnvironmentVariableManager

+ func (holder *EnvironmentVariableManager) AddConfigurations(configurations ...*basev0.Configuration) error

+ func (holder *EnvironmentVariableManager) AddEndpoints(ctx context.Context, mappings []*basev0.NetworkMapping, ...) error

+ func (holder *EnvironmentVariableManager) AddRestRoutes(ctx context.Context, mappings []*basev0.NetworkMapping, ...) error

+ func (holder *EnvironmentVariableManager) All() []EnvironmentVariable

+ func (holder *EnvironmentVariableManager) Configurations() []EnvironmentVariable

+ func (holder *EnvironmentVariableManager) Secrets() []EnvironmentVariable

+ func (holder *EnvironmentVariableManager) SetEnvironment(environment *basev0.Environment)

+ func (holder *EnvironmentVariableManager) SetIdentity(identity *basev0.ServiceIdentity)

+ func (holder *EnvironmentVariableManager) SetRunning(b bool)

+ func (holder *EnvironmentVariableManager) SetRuntimeContext(runtimeContext *basev0.RuntimeContext)

+ type ExtendedGRPCRoute struct

+ Extension T

+ func LoadExtendedGRPCRoute[T any](ctx context.Context, p string) (*ExtendedGRPCRoute[T], error)

+ func (g *ExtendedGRPCRoute[T]) Save(ctx context.Context, dir string) error

+ type ExtendedGRPCRouteLoader struct

+ func NewExtendedGRPCRouteLoader[T any](ctx context.Context, dir string) (*ExtendedGRPCRouteLoader[T], error)

+ func (loader *ExtendedGRPCRouteLoader[T]) Add(route *ExtendedGRPCRoute[T])

+ func (loader *ExtendedGRPCRouteLoader[T]) All() []*ExtendedGRPCRoute[T]

+ func (loader *ExtendedGRPCRouteLoader[T]) Load(ctx context.Context) error

+ func (loader *ExtendedGRPCRouteLoader[T]) Save(ctx context.Context) error

+ type ExtendedRestRoute struct

+ Extension T

+ func NewExtendedRestRoute[T any](rest RestRoute, value T) *ExtendedRestRoute[T]

+ type ExtendedRestRouteGroup struct

+ Module string

+ Path string

+ Routes []*ExtendedRestRoute[T]

+ Service string

+ func LoadExtendedRestRouteGroup[T any](ctx context.Context, p string) (*ExtendedRestRouteGroup[T], error)

+ func (g *ExtendedRestRouteGroup[T]) Add(route ExtendedRestRoute[T])

+ func (g *ExtendedRestRouteGroup[T]) Save(ctx context.Context, dir string) error

+ func (g *ExtendedRestRouteGroup[T]) ServiceUnique() string

+ type ExtendedRouteLoader struct

+ func NewExtendedRestRouteLoader[T any](ctx context.Context, dir string) (*ExtendedRouteLoader[T], error)

+ func (loader *ExtendedRouteLoader[T]) AddGroup(group *ExtendedRestRouteGroup[T])

+ func (loader *ExtendedRouteLoader[T]) All() []*ExtendedRestRoute[T]

+ func (loader *ExtendedRouteLoader[T]) GroupFor(unique string, routePath string) *ExtendedRestRouteGroup[T]

+ func (loader *ExtendedRouteLoader[T]) Groups() []*ExtendedRestRouteGroup[T]

+ func (loader *ExtendedRouteLoader[T]) GroupsFor(unique string) []*ExtendedRestRouteGroup[T]

+ func (loader *ExtendedRouteLoader[T]) Load(ctx context.Context) error

+ func (loader *ExtendedRouteLoader[T]) Save(ctx context.Context) error

+ type FlatLayout struct

+ func NewFlatLayout(ctx context.Context, root string, conf []byte) (*FlatLayout, error)

+ func (f FlatLayout) ModulePath(string) string

+ func (f FlatLayout) ModulesRoot() string

+ func (f FlatLayout) ServicePath(_ string, name string) string

+ func (f FlatLayout) ServicesRoot(string) string

+ type Forwarding interface

+ Forward func(r *RestRoute) (*RestRoute, error)

+ type GRPCRoute struct

+ Module string

+ Name string

+ Package string

+ Service string

+ ServiceName string

+ func DetectNewGRPCRoutesFromEndpoints(ctx context.Context, endpoints []*basev0.Endpoint, known []*GRPCRoute) []*GRPCRoute

+ func GRPCRouteFromProto(e *basev0.Endpoint, grpc *basev0.GrpcAPI, rpc *basev0.RPC) *GRPCRoute

+ func LoadGRPCRoute(ctx context.Context, p string) (*GRPCRoute, error)

+ func UnwrapGRPCRoute[T any](route *ExtendedGRPCRoute[T]) *GRPCRoute

+ func (g *GRPCRoute) Delete(ctx context.Context, dir string) error

+ func (g *GRPCRoute) Route() string

+ func (g *GRPCRoute) Save(ctx context.Context, dir string) error

+ func (g *GRPCRoute) ServiceUnique() string

+ type GRPCRouteLoader struct

+ func NewGRPCRouteLoader(ctx context.Context, dir string) (*GRPCRouteLoader, error)

+ func (loader *GRPCRouteLoader) All() []*GRPCRoute

+ func (loader *GRPCRouteLoader) Load(ctx context.Context) error

+ func (loader *GRPCRouteLoader) Save(ctx context.Context) error

+ type HTTPAPI struct

+ func (h *HTTPAPI) Proto() (*basev0.API, error)

+ type HTTPMethod string

+ const HTTPMethodDelete

+ const HTTPMethodGet

+ const HTTPMethodHead

+ const HTTPMethodOptions

+ const HTTPMethodPatch

+ const HTTPMethodPost

+ const HTTPMethodPut

+ func ConvertHTTPMethodFromProto(m basev0.HTTPMethod) HTTPMethod

+ type Hasher struct

+ func NewHasher() *Hasher

+ func (h *Hasher) Add(s string)

+ func (h *Hasher) Hash() string

+ type Layout interface

+ ModulePath func(name string) string

+ ModulesRoot func() string

+ ServicePath func(module string, name string) string

+ ServicesRoot func(module string) string

+ func NewLayout(ctx context.Context, root string, kind string, conf []byte) (Layout, error)

+ type LayoutKind = string

+ const LayoutKindFlat

+ const LayoutKindModules

+ type Mode = string

+ const ModeModule

+ const ModePartial

+ const ModeService

+ type Module struct

+ Description string

+ Kind string

+ Name string

+ PathOverride *string

+ ServiceReferences []*ServiceReference

+ func LoadModuleFromDirUnsafe(ctx context.Context, dir string) (*Module, error)

+ func LoadModuleFromPath(ctx context.Context) (*Module, error)

+ func ReloadModule(ctx context.Context, app *Module) (*Module, error)

+ func (mod *Module) AddServiceReference(_ context.Context, ref *ServiceReference) error

+ func (mod *Module) DeleteService(ctx context.Context, name string) error

+ func (mod *Module) DeleteServiceDependencies(ctx context.Context, ref *ServiceReference) error

+ func (mod *Module) Dir() string

+ func (mod *Module) ExistsService(ctx context.Context, name string) bool

+ func (mod *Module) GetServiceReferences(name string) (*ServiceReference, error)

+ func (mod *Module) LoadServiceFromName(ctx context.Context, name string) (*Service, error)

+ func (mod *Module) LoadServiceFromReference(ctx context.Context, ref *ServiceReference) (*Service, error)

+ func (mod *Module) LoadServices(ctx context.Context) ([]*Service, error)

+ func (mod *Module) NewService(ctx context.Context, action *actionsv0.AddService) (*Service, error)

+ func (mod *Module) Proto() *basev0.Module

+ func (mod *Module) PublicEndpoints(ctx context.Context) ([]*basev0.Endpoint, error)

+ func (mod *Module) Reference() *ModuleReference

+ func (mod *Module) Save(ctx context.Context) error

+ func (mod *Module) SaveToDir(ctx context.Context, dir string) error

+ func (mod *Module) ServicePath(_ context.Context, ref *ServiceReference) string

+ func (mod *Module) Unique() string

+ func (mod *Module) Validate() error

+ func (mod *Module) WithDir(dir string)

+ type ModuleReference struct

+ ActiveService string

+ Name string

+ PathOverride *string

+ Services []*ServiceReference

+ func (ref *ModuleReference) AddService(_ context.Context, service *ServiceReference) error

+ func (ref *ModuleReference) GetActive(ctx context.Context) (*ServiceReference, error)

+ func (ref *ModuleReference) GetActiveService(ctx context.Context) (*ServiceReference, error)

+ func (ref *ModuleReference) GetServiceFromName(ctx context.Context, serviceName string) (*ServiceReference, error)

+ func (ref *ModuleReference) String() string

+ type ModulesLayout struct

+ func NewModulesLayout(ctx context.Context, root string, conf []byte) (*ModulesLayout, error)

+ func (f ModulesLayout) ModulePath(module string) string

+ func (f ModulesLayout) ModulesRoot() string

+ func (f ModulesLayout) ServicePath(module string, name string) string

+ func (f ModulesLayout) ServicesRoot(module string) string

+ type NetworkInstance struct

+ Address string

+ Host string

+ Hostname string

+ Port uint16

+ func DefaultNetworkInstance(api string) *NetworkInstance

+ func FindNetworkInstanceInEnvironmentVariables(ctx context.Context, endpointInfo *EndpointInformation, envs []string) (*NetworkInstance, error)

+ func ParseAddress(address string) (*NetworkInstance, error)

+ type NewModuleInput struct

+ Name string

+ type NoModuleError struct

+ func (e NoModuleError) Error() string

+ type NonUniqueServiceNameError struct

+ func (n NonUniqueServiceNameError) Error() string

+ type OpenAPICombinator struct

+ func NewOpenAPICombinator(ctx context.Context, target *Endpoint, endpoints ...*basev0.Endpoint) (*OpenAPICombinator, error)

+ func (c *OpenAPICombinator) Combine(ctx context.Context) (*basev0.Endpoint, error)

+ func (c *OpenAPICombinator) LoadEndpoints(ctx context.Context, endpoints ...*basev0.Endpoint) error

+ func (c *OpenAPICombinator) Only(unique string, path string)

+ func (c *OpenAPICombinator) WithDestination(filename string)

+ func (c *OpenAPICombinator) WithVersion(version string)

+ type Organization struct

+ ID string

+ Name string

+ func OrganizationFromProto(_ context.Context, m *basev0.Organization) (*Organization, error)

+ func (organization *Organization) Proto() *basev0.Organization

+ type Readme struct

+ Content string

+ type RestRoute struct

+ Method HTTPMethod

+ Path string

+ func RestRouteFromProto(r *basev0.RestRoute) *RestRoute

+ func UnwrapRestRoute[T any](route *ExtendedRestRoute[T]) *RestRoute

+ func (route *RestRoute) Proto() (*basev0.RestRoute, error)

+ type RestRouteAccess struct

+ type RestRouteGroup struct

+ Module string

+ Path string

+ Routes []*RestRoute

+ Service string

+ func DetectNewRoutesFromEndpoints(ctx context.Context, endpoints []*basev0.Endpoint, known []*RestRouteGroup) []*RestRouteGroup

+ func LoadRestRouteGroup(ctx context.Context, p string) (*RestRouteGroup, error)

+ func UnwrapRestRouteGroup[T any](group *ExtendedRestRouteGroup[T]) *RestRouteGroup

+ func (g *RestRouteGroup) Delete(ctx context.Context, dir string) error

+ func (g *RestRouteGroup) Save(ctx context.Context, dir string) error

+ func (g *RestRouteGroup) ServiceUnique() string

+ type RestRouteLoader struct

+ func NewRestRouteLoader(ctx context.Context, dir string) (*RestRouteLoader, error)

+ func (loader *RestRouteLoader) All() []*RestRoute

+ func (loader *RestRouteLoader) GroupFor(unique string, routePath string) *RestRouteGroup

+ func (loader *RestRouteLoader) Groups() []*RestRouteGroup

+ func (loader *RestRouteLoader) GroupsFor(unique string) []*RestRouteGroup

+ func (loader *RestRouteLoader) Load(ctx context.Context) error

+ type RouteUnique struct

+ func (r RouteUnique) String() string

+ type RunningOptions struct

+ Persistence bool

+ Quiet bool

+ type Service struct

+ Agent *Agent

+ ConfigurationDependencies []string

+ Description string

+ Endpoints []*Endpoint

+ Module string

+ Name string

+ PathOverride *string

+ ServiceDependencies []*ServiceDependency

+ Spec map[string]any

+ Version string

+ func LoadServiceFromDir(ctx context.Context, dir string) (*Service, error)

+ func LoadServiceFromPath(ctx context.Context) (*Service, error)

+ func ReloadService(ctx context.Context, service *Service) (*Service, error)

+ func (s *Service) AddDependency(ctx context.Context, requirement *Service, requiredEndpoints []*Endpoint) error

+ func (s *Service) BaseEndpoint(name string) *Endpoint

+ func (s *Service) DeleteServiceDependencies(ctx context.Context, ref *ServiceReference) error

+ func (s *Service) Dir() string

+ func (s *Service) EndpointsFromNames(endpoints []string) ([]*Endpoint, error)

+ func (s *Service) ExistsDependency(requirement *Service) (*ServiceDependency, bool)

+ func (s *Service) HasEndpoints(_ context.Context, endpoints []string) ([]string, error)

+ func (s *Service) Identity() *ServiceIdentity

+ func (s *Service) LoadEndpoints(ctx context.Context) ([]*basev0.Endpoint, error)

+ func (s *Service) LoadSettingsFromSpec(t any) error

+ func (s *Service) Local(_ context.Context, f string) string

+ func (s *Service) LocalOrNil(ctx context.Context, f string) *string

+ func (s *Service) Proto() *basev0.Service

+ func (s *Service) Reference() *ServiceReference

+ func (s *Service) Save(ctx context.Context) error

+ func (s *Service) SaveAtDir(ctx context.Context, dir string) error

+ func (s *Service) Unique() string

+ func (s *Service) UniqueWithWorspace(workspace string) string

+ func (s *Service) UpdateSpecFromSettings(spec any) error

+ func (s *Service) Validate() error

+ func (s *Service) WithDir(dir string)

+ type ServiceDependency struct

+ Endpoints []*EndpointReference

+ Module string

+ Name string

+ func (s *ServiceDependency) AsReference() *ServiceReference

+ func (s *ServiceDependency) String() string

+ func (s *ServiceDependency) Unique() string

+ func (s *ServiceDependency) UpdateEndpoints(ctx context.Context, endpoints []*Endpoint) error

+ type ServiceForwarding struct

+ func (s ServiceForwarding) Forward(r *RestRoute) (*RestRoute, error)

+ type ServiceIdentity struct

+ Module string

+ Name string

+ Version string

+ Workspace string

+ func ServiceIdentityFromProto(proto *basev0.ServiceIdentity) *ServiceIdentity

+ func (s *ServiceIdentity) AsAgentResource() *wool.Resource

+ func (s *ServiceIdentity) AsResource() *wool.Resource

+ func (s *ServiceIdentity) Clone() *ServiceIdentity

+ func (s *ServiceIdentity) Unique() string

+ type ServiceReference struct

+ Module string

+ Name string

+ PathOverride *string

+ func ParseServiceReference(input string) (*ServiceReference, error)

+ func (ref *ServiceReference) String() string

+ type ServiceWithCase struct

+ Name shared.Case

+ Unique shared.Case

+ func ToServiceWithCase(svc *Service) *ServiceWithCase

+ type ServiceWithModule struct

+ Module string

+ Name string

+ func ParseServiceWithOptionalModule(input string) (*ServiceWithModule, error)

+ func (s ServiceWithModule) String() string

+ func (s ServiceWithModule) Unique() string

+ type TCP struct

+ func NewTCP() (*TCP, error)

+ func (*TCP) Proto() (*basev0.API, error)

+ type Visibility = string

+ const VisibilityExternal

+ const VisibilityModule

+ const VisibilityPrivate

+ const VisibilityPublic

+ type Workspace struct

+ Description string

+ Layout string

+ Modules []*ModuleReference

+ Name string

+ func CreateWorkspace(ctx context.Context, action *actionsv0.NewWorkspace) (*Workspace, error)

+ func FindWorkspaceUp(ctx context.Context) (*Workspace, error)

+ func LoadWorkspaceFromDir(ctx context.Context, dir string) (*Workspace, error)

+ func NewWorkspace(ctx context.Context, name string, layout string) (*Workspace, error)

+ func Reload(ctx context.Context, workspace *Workspace) (*Workspace, error)

+ func (workspace *Workspace) AddModuleReference(modRef *ModuleReference) error

+ func (workspace *Workspace) Clone() *Workspace

+ func (workspace *Workspace) DeleteModule(ctx context.Context, name string) error

+ func (workspace *Workspace) DeleteServiceDependencies(ctx context.Context, ref *ServiceReference) error

+ func (workspace *Workspace) Dir() string

+ func (workspace *Workspace) ExistsModule(name string) bool

+ func (workspace *Workspace) FindUniqueServiceAndModuleByName(ctx context.Context, name string) (*ServiceWithModule, error)

+ func (workspace *Workspace) FindUniqueServiceByName(ctx context.Context, name string) (*Service, error)

+ func (workspace *Workspace) LoadModuleFromName(ctx context.Context, name string) (*Module, error)

+ func (workspace *Workspace) LoadModuleFromReference(ctx context.Context, ref *ModuleReference) (*Module, error)

+ func (workspace *Workspace) LoadModules(ctx context.Context) ([]*Module, error)

+ func (workspace *Workspace) LoadService(ctx context.Context, input *ServiceWithModule) (*Service, error)

+ func (workspace *Workspace) LoadServiceWithModules(ctx context.Context) ([]*ServiceWithModule, error)

+ func (workspace *Workspace) LoadServices(ctx context.Context) ([]*Service, error)

+ func (workspace *Workspace) ModulePath(ctx context.Context, ref *ModuleReference) string

+ func (workspace *Workspace) ModulesNames() []string

+ func (workspace *Workspace) NewModule(ctx context.Context, action *actionsv0.NewModule) (*Module, error)

+ func (workspace *Workspace) Proto() (*basev0.Workspace, error)

+ func (workspace *Workspace) RootModule(ctx context.Context) (*Module, error)

+ func (workspace *Workspace) Save(ctx context.Context) error

+ func (workspace *Workspace) SaveToDirUnsafe(ctx context.Context, dir string) error

+ func (workspace *Workspace) Valid() error

+ func (workspace *Workspace) WithDir(dir string)

+ func (workspace *Workspace) WithRootModule(ctx context.Context) (*Module, error)

+ type WrapperSwagger struct

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