resolvers

package
v0.0.0-...-0e4f5d7 Latest Latest
Warning

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

 Go to latest Published: Sep 15, 2022 License: Apache-2.0 Imports: 39 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var AllAddressSpaceType = []AddressSpaceType{
	AddressSpaceTypeStandard,
	AddressSpaceTypeBrokered,
}
View Source 
var AllAddressType = []AddressType{
	AddressTypeQueue,
	AddressTypeTopic,
	AddressTypeSubscription,
	AddressTypeMulticast,
	AddressTypeAnycast,
	AddressTypeDeadletter,
}
View Source 
var AllAuthenticationServiceType = []AuthenticationServiceType{
	AuthenticationServiceTypeNone,
	AuthenticationServiceTypeStandard,
}
View Source 
var AllLinkRole = []LinkRole{
	LinkRoleSender,
	LinkRoleReceiver,
}
View Source 
var AllMetricType = []MetricType{
	MetricTypeGauge,
	MetricTypeCounter,
	MetricTypeRate,
}
View Source 
var AllProtocol = []Protocol{
	ProtocolAmqp,
	ProtocolAmqps,
}

Functions

func BuildFilter 

func BuildFilter(f *string, orderedKeyElements ...string) (cache.ObjectFilter, string, error)

func BuildOrderer 

func BuildOrderer(o *string) (func(interface{}) error, error)

func CalcLowerUpper 

func CalcLowerUpper(offset *int, first *int, len int) (int, int)

func MarshalCertBytes 

func MarshalCertBytes(s string) graphql.Marshaler

func Min 

func Min(x, y int) int

func NewExecutableSchema 

func NewExecutableSchema(cfg Config) graphql.ExecutableSchema

NewExecutableSchema creates an ExecutableSchema from the ResolverRoot interface.

func UnmarshalCertBytes 

func UnmarshalCertBytes(v interface{}) (string, error)

Types

type AddressPlanByDisplayOrder 

type AddressPlanByDisplayOrder []*v1beta2.AddressPlan

func (AddressPlanByDisplayOrder) Len 

func (a AddressPlanByDisplayOrder) Len() int

func (AddressPlanByDisplayOrder) Less 

func (a AddressPlanByDisplayOrder) Less(i, j int) bool

func (AddressPlanByDisplayOrder) Swap 

func (a AddressPlanByDisplayOrder) Swap(i, j int)

type AddressPlanSpec_admin_enmasse_io_v1beta2Resolver 

type AddressPlanSpec_admin_enmasse_io_v1beta2Resolver interface {
	AddressType(ctx context.Context, obj *v1beta2.AddressPlanSpec) (AddressType, error)
}

type AddressQueryResultConsoleapiEnmasseIoV1beta1 

type AddressQueryResultConsoleapiEnmasseIoV1beta1 struct {
	Total     int                             `json:"total"`
	Addresses []*consolegraphql.AddressHolder `json:"addresses"`
}

type AddressSpacePlanByDisplayOrder 

type AddressSpacePlanByDisplayOrder []*v1beta2.AddressSpacePlan

func (AddressSpacePlanByDisplayOrder) Len 

func (a AddressSpacePlanByDisplayOrder) Len() int

func (AddressSpacePlanByDisplayOrder) Less 

func (a AddressSpacePlanByDisplayOrder) Less(i, j int) bool

func (AddressSpacePlanByDisplayOrder) Swap 

func (a AddressSpacePlanByDisplayOrder) Swap(i, j int)

type AddressSpacePlanSpec_admin_enmasse_io_v1beta2Resolver 

type AddressSpacePlanSpec_admin_enmasse_io_v1beta2Resolver interface {
	AddressPlans(ctx context.Context, obj *v1beta2.AddressSpacePlanSpec) ([]*v1beta2.AddressPlan, error)
	AddressSpaceType(ctx context.Context, obj *v1beta2.AddressSpacePlanSpec) (*AddressSpaceType, error)
}

type AddressSpaceQueryResultConsoleapiEnmasseIoV1beta1 

type AddressSpaceQueryResultConsoleapiEnmasseIoV1beta1 struct {
	Total         int                                  `json:"total"`
	AddressSpaces []*consolegraphql.AddressSpaceHolder `json:"addressSpaces"`
}

type AddressSpaceSpec_enmasse_io_v1beta1Resolver 

type AddressSpaceSpec_enmasse_io_v1beta1Resolver interface {
	Plan(ctx context.Context, obj *v1beta1.AddressSpaceSpec) (*v1beta2.AddressSpacePlan, error)
	Type(ctx context.Context, obj *v1beta1.AddressSpaceSpec) (AddressSpaceType, error)
}

type AddressSpaceType 

type AddressSpaceType string
const (
	AddressSpaceTypeStandard AddressSpaceType = "standard"
	AddressSpaceTypeBrokered AddressSpaceType = "brokered"
)

func (AddressSpaceType) IsValid 

func (e AddressSpaceType) IsValid() bool

func (AddressSpaceType) MarshalGQL 

func (e AddressSpaceType) MarshalGQL(w io.Writer)

func (AddressSpaceType) String 

func (e AddressSpaceType) String() string

func (*AddressSpaceType) UnmarshalGQL 

func (e *AddressSpaceType) UnmarshalGQL(v interface{}) error

type AddressSpaceTypeConsoleapiEnmasseIoV1beta1 

type AddressSpaceTypeConsoleapiEnmasseIoV1beta1 struct {
	ObjectMeta *v1.ObjectMeta                             `json:"metadata"`
	Spec       *AddressTypeSpecConsoleapiEnmasseIoV1beta1 `json:"spec"`
}

type AddressSpaceTypeSpecConsoleapiEnmasseIoV1beta1 

type AddressSpaceTypeSpecConsoleapiEnmasseIoV1beta1 struct {
	AddressSpaceType AddressSpaceType `json:"addressSpaceType"`
	DisplayName      string           `json:"displayName"`
	LongDescription  string           `json:"longDescription"`
	ShortDescription string           `json:"shortDescription"`
	DisplayOrder     int              `json:"displayOrder"`
}

type AddressSpace_consoleapi_enmasse_io_v1beta1Resolver 

type AddressSpace_consoleapi_enmasse_io_v1beta1Resolver interface {
	Connections(ctx context.Context, obj *consolegraphql.AddressSpaceHolder, first *int, offset *int, filter *string, orderBy *string) (*ConnectionQueryResultConsoleapiEnmasseIoV1beta1, error)
	Addresses(ctx context.Context, obj *consolegraphql.AddressSpaceHolder, first *int, offset *int, filter *string, orderBy *string) (*AddressQueryResultConsoleapiEnmasseIoV1beta1, error)
}

type AddressSpec_enmasse_io_v1beta1Resolver 

type AddressSpec_enmasse_io_v1beta1Resolver interface {
	Type(ctx context.Context, obj *v1beta1.AddressSpec) (AddressType, error)
	Plan(ctx context.Context, obj *v1beta1.AddressSpec) (*v1beta2.AddressPlan, error)
}

type AddressType 

type AddressType string
const (
	AddressTypeQueue        AddressType = "queue"
	AddressTypeTopic        AddressType = "topic"
	AddressTypeSubscription AddressType = "subscription"
	AddressTypeMulticast    AddressType = "multicast"
	AddressTypeAnycast      AddressType = "anycast"
	AddressTypeDeadletter   AddressType = "deadletter"
)

func (AddressType) IsValid 

func (e AddressType) IsValid() bool

func (AddressType) MarshalGQL 

func (e AddressType) MarshalGQL(w io.Writer)

func (AddressType) String 

func (e AddressType) String() string

func (*AddressType) UnmarshalGQL 

func (e *AddressType) UnmarshalGQL(v interface{}) error

type AddressTypeConsoleapiEnmasseIoV1beta1 

type AddressTypeConsoleapiEnmasseIoV1beta1 struct {
	ObjectMeta *v1.ObjectMeta                             `json:"metadata"`
	Spec       *AddressTypeSpecConsoleapiEnmasseIoV1beta1 `json:"spec"`
}

type AddressTypeSpecConsoleapiEnmasseIoV1beta1 

type AddressTypeSpecConsoleapiEnmasseIoV1beta1 struct {
	AddressType      AddressType      `json:"addressType"`
	AddressSpaceType AddressSpaceType `json:"addressSpaceType"`
	DisplayName      string           `json:"displayName"`
	LongDescription  string           `json:"longDescription"`
	ShortDescription string           `json:"shortDescription"`
	DisplayOrder     int              `json:"displayOrder"`
}

type Address_consoleapi_enmasse_io_v1beta1Resolver 

type Address_consoleapi_enmasse_io_v1beta1Resolver interface {
	Links(ctx context.Context, obj *consolegraphql.AddressHolder, first *int, offset *int, filter *string, orderBy *string) (*LinkQueryResultConsoleapiEnmasseIoV1beta1, error)
}

type AuthenticationServiceSpec_admin_enmasse_io_v1beta1Resolver 

type AuthenticationServiceSpec_admin_enmasse_io_v1beta1Resolver interface {
	Type(ctx context.Context, obj *v1beta11.AuthenticationServiceSpec) (AuthenticationServiceType, error)
}

type AuthenticationServiceType 

type AuthenticationServiceType string
const (
	AuthenticationServiceTypeNone     AuthenticationServiceType = "none"
	AuthenticationServiceTypeStandard AuthenticationServiceType = "standard"
)

func (AuthenticationServiceType) IsValid 

func (e AuthenticationServiceType) IsValid() bool

func (AuthenticationServiceType) MarshalGQL 

func (e AuthenticationServiceType) MarshalGQL(w io.Writer)

func (AuthenticationServiceType) String 

func (e AuthenticationServiceType) String() string

func (*AuthenticationServiceType) UnmarshalGQL 

func (e *AuthenticationServiceType) UnmarshalGQL(v interface{}) error

type ComplexityRoot 

type ComplexityRoot struct {
	AddressPlanSpecAdminEnmasseIoV1beta2 struct {
		AddressType      func(childComplexity int) int
		DisplayName      func(childComplexity int) int
		DisplayOrder     func(childComplexity int) int
		LongDescription  func(childComplexity int) int
		ShortDescription func(childComplexity int) int
	}

	AddressPlanStatusEnmasseIoV1beta1 struct {
		Name       func(childComplexity int) int
		Partitions func(childComplexity int) int
	}

	AddressPlanAdminEnmasseIoV1beta2 struct {
		ObjectMeta func(childComplexity int) int
		Spec       func(childComplexity int) int
	}

	AddressQueryResultConsoleapiEnmasseIoV1beta1 struct {
		Addresses func(childComplexity int) int
		Total     func(childComplexity int) int
	}

	AddressSpacePlanSpecAdminEnmasseIoV1beta2 struct {
		AddressPlans     func(childComplexity int) int
		AddressSpaceType func(childComplexity int) int
		DisplayName      func(childComplexity int) int
		DisplayOrder     func(childComplexity int) int
		LongDescription  func(childComplexity int) int
		ShortDescription func(childComplexity int) int
	}

	AddressSpacePlanAdminEnmasseIoV1beta2 struct {
		ObjectMeta func(childComplexity int) int
		Spec       func(childComplexity int) int
	}

	AddressSpaceQueryResultConsoleapiEnmasseIoV1beta1 struct {
		AddressSpaces func(childComplexity int) int
		Total         func(childComplexity int) int
	}

	AddressSpaceSchemaSpecEnmasseIoV1beta1 struct {
		AuthenticationServices   func(childComplexity int) int
		CertificateProviderTypes func(childComplexity int) int
		Description              func(childComplexity int) int
		EndpointExposeTypes      func(childComplexity int) int
		RouteServicePorts        func(childComplexity int) int
	}

	AddressSpaceSchemaEnmasseIoV1beta1 struct {
		ObjectMeta func(childComplexity int) int
		Spec       func(childComplexity int) int
	}

	AddressSpaceSpecEnmasseIoV1beta1 struct {
		AuthenticationService func(childComplexity int) int
		Endpoints             func(childComplexity int) int
		Plan                  func(childComplexity int) int
		Type                  func(childComplexity int) int
	}

	AddressSpaceStatusEnmasseIoV1beta1 struct {
		CACertificate  func(childComplexity int) int
		EndpointStatus func(childComplexity int) int
		IsReady        func(childComplexity int) int
		Messages       func(childComplexity int) int
		Phase          func(childComplexity int) int
	}

	AddressSpaceTypeSpecConsoleapiEnmasseIoV1beta1 struct {
		AddressSpaceType func(childComplexity int) int
		DisplayName      func(childComplexity int) int
		DisplayOrder     func(childComplexity int) int
		LongDescription  func(childComplexity int) int
		ShortDescription func(childComplexity int) int
	}

	AddressSpaceTypeConsoleapiEnmasseIoV1beta1 struct {
		ObjectMeta func(childComplexity int) int
		Spec       func(childComplexity int) int
	}

	AddressSpaceConsoleapiEnmasseIoV1beta1 struct {
		Addresses   func(childComplexity int, first *int, offset *int, filter *string, orderBy *string) int
		Connections func(childComplexity int, first *int, offset *int, filter *string, orderBy *string) int
		Metrics     func(childComplexity int) int
		ObjectMeta  func(childComplexity int) int
		Spec        func(childComplexity int) int
		Status      func(childComplexity int) int
	}

	AddressSpecEnmasseIoV1beta1 struct {
		Address      func(childComplexity int) int
		AddressSpace func(childComplexity int) int
		Deadletter   func(childComplexity int) int
		Expiry       func(childComplexity int) int
		Plan         func(childComplexity int) int
		Topic        func(childComplexity int) int
		Type         func(childComplexity int) int
	}

	AddressStatusEnmasseIoV1beta1 struct {
		IsReady    func(childComplexity int) int
		Messages   func(childComplexity int) int
		Phase      func(childComplexity int) int
		PlanStatus func(childComplexity int) int
	}

	AddressTypeSpecConsoleapiEnmasseIoV1beta1 struct {
		AddressSpaceType func(childComplexity int) int
		AddressType      func(childComplexity int) int
		DisplayName      func(childComplexity int) int
		DisplayOrder     func(childComplexity int) int
		LongDescription  func(childComplexity int) int
		ShortDescription func(childComplexity int) int
	}

	AddressTypeConsoleapiEnmasseIoV1beta1 struct {
		ObjectMeta func(childComplexity int) int
		Spec       func(childComplexity int) int
	}

	AddressConsoleapiEnmasseIoV1beta1 struct {
		Links      func(childComplexity int, first *int, offset *int, filter *string, orderBy *string) int
		Metrics    func(childComplexity int) int
		ObjectMeta func(childComplexity int) int
		Spec       func(childComplexity int) int
		Status     func(childComplexity int) int
	}

	AuthenticationServiceSpecAdminEnmasseIoV1beta1 struct {
		Type func(childComplexity int) int
	}

	AuthenticationServiceStatusAdminEnmasseIoV1beta1 struct {
		Host func(childComplexity int) int
		Port func(childComplexity int) int
	}

	AuthenticationServiceAdminEnmasseIoV1beta1 struct {
		ObjectMeta func(childComplexity int) int
		Spec       func(childComplexity int) int
		Status     func(childComplexity int) int
	}

	AuthenticationServiceEnmasseIoV1beta1 struct {
		Name func(childComplexity int) int
	}

	CertificateProviderTypeDescriptionEnmasseIoV1beta1 struct {
		Description func(childComplexity int) int
		DisplayName func(childComplexity int) int
		Name        func(childComplexity int) int
	}

	CertificateSpecEnmasseIoV1beta1 struct {
		Provider   func(childComplexity int) int
		SecretName func(childComplexity int) int
		TlsCert    func(childComplexity int) int
		TlsKey     func(childComplexity int) int
	}

	ConnectionQueryResultConsoleapiEnmasseIoV1beta1 struct {
		Connections func(childComplexity int) int
		Total       func(childComplexity int) int
	}

	ConnectionSpecConsoleapiEnmasseIoV1beta1 struct {
		AddressSpace func(childComplexity int) int
		ContainerId  func(childComplexity int) int
		Encrypted    func(childComplexity int) int
		Hostname     func(childComplexity int) int
		Principal    func(childComplexity int) int
		Properties   func(childComplexity int) int
		Protocol     func(childComplexity int) int
	}

	ConnectionConsoleapiEnmasseIoV1beta1 struct {
		Links      func(childComplexity int, first *int, offset *int, filter *string, orderBy *string) int
		Metrics    func(childComplexity int) int
		ObjectMeta func(childComplexity int) int
		Spec       func(childComplexity int) int
	}

	EndpointExposeTypeDescriptionEnmasseIoV1beta1 struct {
		Description func(childComplexity int) int
		DisplayName func(childComplexity int) int
		Name        func(childComplexity int) int
	}

	EndpointSpecEnmasseIoV1beta1 struct {
		Certificate func(childComplexity int) int
		Expose      func(childComplexity int) int
		Name        func(childComplexity int) int
		Service     func(childComplexity int) int
	}

	EndpointStatusEnmasseIoV1beta1 struct {
		Certificate   func(childComplexity int) int
		ExternalHost  func(childComplexity int) int
		ExternalPorts func(childComplexity int) int
		Name          func(childComplexity int) int
		ServiceHost   func(childComplexity int) int
		ServicePorts  func(childComplexity int) int
	}

	ExposeSpecEnmasseIoV1beta1 struct {
		LoadBalancerPorts        func(childComplexity int) int
		LoadBalancerSourceRanges func(childComplexity int) int
		RouteHost                func(childComplexity int) int
		RouteServicePort         func(childComplexity int) int
		RouteTlsTermination      func(childComplexity int) int
		Type                     func(childComplexity int) int
	}

	KeyValue struct {
		Key   func(childComplexity int) int
		Value func(childComplexity int) int
	}

	LinkQueryResultConsoleapiEnmasseIoV1beta1 struct {
		Links func(childComplexity int) int
		Total func(childComplexity int) int
	}

	LinkSpecConsoleapiEnmasseIoV1beta1 struct {
		Address    func(childComplexity int) int
		Connection func(childComplexity int) int
		Role       func(childComplexity int) int
	}

	LinkConsoleapiEnmasseIoV1beta1 struct {
		Metrics    func(childComplexity int) int
		ObjectMeta func(childComplexity int) int
		Spec       func(childComplexity int) int
	}

	MessagingEndpointPortEnmasseIoV1beta2 struct {
		Name     func(childComplexity int) int
		Port     func(childComplexity int) int
		Protocol func(childComplexity int) int
	}

	MessagingEndpointQueryResultConsoleapiEnmasseIoV1beta1 struct {
		MessagingEndpoints func(childComplexity int) int
		Total              func(childComplexity int) int
	}

	MessagingEndpointSpecEnmasseIoV1beta2 struct {
		Protocols func(childComplexity int) int
	}

	MessagingEndpointStatusEnmasseIoV1beta2 struct {
		Host          func(childComplexity int) int
		InternalPorts func(childComplexity int) int
		Message       func(childComplexity int) int
		Phase         func(childComplexity int) int
		Ports         func(childComplexity int) int
		Type          func(childComplexity int) int
	}

	MessagingEndpointEnmasseIoV1beta2 struct {
		ObjectMeta func(childComplexity int) int
		Spec       func(childComplexity int) int
		Status     func(childComplexity int) int
	}

	MetadataConsoleapiEnmasseIoV1beta1 struct {
		Annotations       func(childComplexity int) int
		CreationTimestamp func(childComplexity int) int
		Name              func(childComplexity int) int
		Namespace         func(childComplexity int) int
		ResourceVersion   func(childComplexity int) int
		UID               func(childComplexity int) int
	}

	MetricConsoleapiEnmasseIoV1beta1 struct {
		Name  func(childComplexity int) int
		Type  func(childComplexity int) int
		Units func(childComplexity int) int
		Value func(childComplexity int) int
	}

	Mutation struct {
		CloseConnections    func(childComplexity int, input []*v1.ObjectMeta) int
		CreateAddress       func(childComplexity int, input v1beta1.Address, addressSpace *string) int
		CreateAddressSpace  func(childComplexity int, input v1beta1.AddressSpace) int
		DeleteAddress       func(childComplexity int, input v1.ObjectMeta) int
		DeleteAddressSpace  func(childComplexity int, input v1.ObjectMeta) int
		DeleteAddressSpaces func(childComplexity int, input []*v1.ObjectMeta) int
		DeleteAddresses     func(childComplexity int, input []*v1.ObjectMeta) int
		PatchAddress        func(childComplexity int, input v1.ObjectMeta, jsonPatch string, patchType string) int
		PatchAddressSpace   func(childComplexity int, input v1.ObjectMeta, jsonPatch string, patchType string) int
		PurgeAddress        func(childComplexity int, input v1.ObjectMeta) int
		PurgeAddresses      func(childComplexity int, input []*v1.ObjectMeta) int
	}

	NamespaceStatusV1 struct {
		Phase func(childComplexity int) int
	}

	NamespaceV1 struct {
		ObjectMeta func(childComplexity int) int
		Status     func(childComplexity int) int
	}

	ObjectMetaV1 struct {
		Annotations       func(childComplexity int) int
		CreationTimestamp func(childComplexity int) int
		Name              func(childComplexity int) int
		Namespace         func(childComplexity int) int
		ResourceVersion   func(childComplexity int) int
		UID               func(childComplexity int) int
	}

	PortEnmasseIoV1beta1 struct {
		Name func(childComplexity int) int
		Port func(childComplexity int) int
	}

	Query struct {
		AddressCommand            func(childComplexity int, input v1beta1.Address, addressSpace *string) int
		AddressPlans              func(childComplexity int, addressSpacePlan *string, addressType *AddressType) int
		AddressSpaceCommand       func(childComplexity int, input v1beta1.AddressSpace) int
		AddressSpacePlans         func(childComplexity int, addressSpaceType *AddressSpaceType) int
		AddressSpaceSchema        func(childComplexity int) int
		AddressSpaceSchemaV2      func(childComplexity int, addressSpaceType *AddressSpaceType) int
		AddressSpaceTypes         func(childComplexity int) int
		AddressSpaceTypesV2       func(childComplexity int) int
		AddressSpaces             func(childComplexity int, first *int, offset *int, filter *string, orderBy *string) int
		AddressTypes              func(childComplexity int) int
		AddressTypesV2            func(childComplexity int, addressSpaceType *AddressSpaceType) int
		Addresses                 func(childComplexity int, first *int, offset *int, filter *string, orderBy *string) int
		AuthenticationServices    func(childComplexity int) int
		Connections               func(childComplexity int, first *int, offset *int, filter *string, orderBy *string) int
		MessagingCertificateChain func(childComplexity int, input v1.ObjectMeta) int
		MessagingEndpoints        func(childComplexity int, first *int, offset *int, filter *string, orderBy *string) int
		Namespaces                func(childComplexity int) int
		Whoami                    func(childComplexity int) int
	}

	RouteServicePortDescriptionEnmasseIoV1beta1 struct {
		DisplayName          func(childComplexity int) int
		Name                 func(childComplexity int) int
		RouteTlsTerminations func(childComplexity int) int
	}

	UserV1 struct {
		FullName   func(childComplexity int) int
		Groups     func(childComplexity int) int
		Identities func(childComplexity int) int
		ObjectMeta func(childComplexity int) int
	}
}

type Config 

type Config struct {
	Resolvers  ResolverRoot
	Directives DirectiveRoot
	Complexity ComplexityRoot
}

type ConnectionQueryResultConsoleapiEnmasseIoV1beta1 

type ConnectionQueryResultConsoleapiEnmasseIoV1beta1 struct {
	Total       int                          `json:"total"`
	Connections []*consolegraphql.Connection `json:"connections"`
}

type ConnectionSpec_consoleapi_enmasse_io_v1beta1Resolver 

type ConnectionSpec_consoleapi_enmasse_io_v1beta1Resolver interface {
	AddressSpace(ctx context.Context, obj *consolegraphql.ConnectionSpec) (*consolegraphql.AddressSpaceHolder, error)

	Protocol(ctx context.Context, obj *consolegraphql.ConnectionSpec) (Protocol, error)

	Properties(ctx context.Context, obj *consolegraphql.ConnectionSpec) ([]*KeyValue, error)
}

type Connection_consoleapi_enmasse_io_v1beta1Resolver 

type Connection_consoleapi_enmasse_io_v1beta1Resolver interface {
	Links(ctx context.Context, obj *consolegraphql.Connection, first *int, offset *int, filter *string, orderBy *string) (*LinkQueryResultConsoleapiEnmasseIoV1beta1, error)
}

type DirectiveRoot 

type DirectiveRoot struct {
}

type KeyValue 

type KeyValue struct {
	Key   string `json:"key"`
	Value string `json:"value"`
}

type LinkQueryResultConsoleapiEnmasseIoV1beta1 

type LinkQueryResultConsoleapiEnmasseIoV1beta1 struct {
	Total int                    `json:"total"`
	Links []*consolegraphql.Link `json:"links"`
}

type LinkRole 

type LinkRole string
const (
	LinkRoleSender   LinkRole = "sender"
	LinkRoleReceiver LinkRole = "receiver"
)

func (LinkRole) IsValid 

func (e LinkRole) IsValid() bool

func (LinkRole) MarshalGQL 

func (e LinkRole) MarshalGQL(w io.Writer)

func (LinkRole) String 

func (e LinkRole) String() string

func (*LinkRole) UnmarshalGQL 

func (e *LinkRole) UnmarshalGQL(v interface{}) error

type LinkSpec_consoleapi_enmasse_io_v1beta1Resolver 

type LinkSpec_consoleapi_enmasse_io_v1beta1Resolver interface {
	Connection(ctx context.Context, obj *consolegraphql.LinkSpec) (*consolegraphql.Connection, error)

	Role(ctx context.Context, obj *consolegraphql.LinkSpec) (LinkRole, error)
}

type MessagingEndpointQueryResultConsoleapiEnmasseIoV1beta1 

type MessagingEndpointQueryResultConsoleapiEnmasseIoV1beta1 struct {
	Total              int                          `json:"total"`
	MessagingEndpoints []*v1beta2.MessagingEndpoint `json:"messagingEndpoints"`
}

type MetadataConsoleapiEnmasseIoV1beta1 

type MetadataConsoleapiEnmasseIoV1beta1 struct {
	Annotations       []*KeyValue `json:"annotations"`
	Name              string      `json:"name"`
	Namespace         string      `json:"namespace"`
	ResourceVersion   string      `json:"resourceVersion"`
	CreationTimestamp string      `json:"creationTimestamp"`
	UID               string      `json:"uid"`
}

type MetricType 

type MetricType string
const (
	MetricTypeGauge   MetricType = "gauge"
	MetricTypeCounter MetricType = "counter"
	MetricTypeRate    MetricType = "rate"
)

func (MetricType) IsValid 

func (e MetricType) IsValid() bool

func (MetricType) MarshalGQL 

func (e MetricType) MarshalGQL(w io.Writer)

func (MetricType) String 

func (e MetricType) String() string

func (*MetricType) UnmarshalGQL 

func (e *MetricType) UnmarshalGQL(v interface{}) error

type Metric_consoleapi_enmasse_io_v1beta1Resolver 

type Metric_consoleapi_enmasse_io_v1beta1Resolver interface {
	Type(ctx context.Context, obj *consolegraphql.Metric) (MetricType, error)

	Units(ctx context.Context, obj *consolegraphql.Metric) (string, error)
}

type MutationResolver 

type MutationResolver interface {
	CreateAddressSpace(ctx context.Context, input v1beta1.AddressSpace) (*v1.ObjectMeta, error)
	PatchAddressSpace(ctx context.Context, input v1.ObjectMeta, jsonPatch string, patchType string) (*bool, error)
	DeleteAddressSpace(ctx context.Context, input v1.ObjectMeta) (*bool, error)
	DeleteAddressSpaces(ctx context.Context, input []*v1.ObjectMeta) (*bool, error)
	CreateAddress(ctx context.Context, input v1beta1.Address, addressSpace *string) (*v1.ObjectMeta, error)
	PatchAddress(ctx context.Context, input v1.ObjectMeta, jsonPatch string, patchType string) (*bool, error)
	DeleteAddress(ctx context.Context, input v1.ObjectMeta) (*bool, error)
	DeleteAddresses(ctx context.Context, input []*v1.ObjectMeta) (*bool, error)
	PurgeAddress(ctx context.Context, input v1.ObjectMeta) (*bool, error)
	PurgeAddresses(ctx context.Context, input []*v1.ObjectMeta) (*bool, error)
	CloseConnections(ctx context.Context, input []*v1.ObjectMeta) (*bool, error)
}

type NamespaceStatus_v1Resolver 

type NamespaceStatus_v1Resolver interface {
	Phase(ctx context.Context, obj *v11.NamespaceStatus) (string, error)
}

type ObjectMeta_v1Resolver 

type ObjectMeta_v1Resolver interface {
	Annotations(ctx context.Context, obj *v1.ObjectMeta) ([]*KeyValue, error)

	CreationTimestamp(ctx context.Context, obj *v1.ObjectMeta) (string, error)
	UID(ctx context.Context, obj *v1.ObjectMeta) (string, error)
}

type Port_enmasse_io_v1beta1Resolver 

type Port_enmasse_io_v1beta1Resolver interface {
	Port(ctx context.Context, obj *v1beta1.Port) (int, error)
}

type Protocol 

type Protocol string
const (
	ProtocolAmqp  Protocol = "amqp"
	ProtocolAmqps Protocol = "amqps"
)

func (Protocol) IsValid 

func (e Protocol) IsValid() bool

func (Protocol) MarshalGQL 

func (e Protocol) MarshalGQL(w io.Writer)

func (Protocol) String 

func (e Protocol) String() string

func (*Protocol) UnmarshalGQL 

func (e *Protocol) UnmarshalGQL(v interface{}) error

type QueryResolver 

type QueryResolver interface {
	AddressSpaceTypes(ctx context.Context) ([]AddressSpaceType, error)
	AddressSpaceTypesV2(ctx context.Context) ([]*AddressSpaceTypeConsoleapiEnmasseIoV1beta1, error)
	AddressTypes(ctx context.Context) ([]AddressType, error)
	AddressTypesV2(ctx context.Context, addressSpaceType *AddressSpaceType) ([]*AddressTypeConsoleapiEnmasseIoV1beta1, error)
	AddressSpacePlans(ctx context.Context, addressSpaceType *AddressSpaceType) ([]*v1beta2.AddressSpacePlan, error)
	AddressPlans(ctx context.Context, addressSpacePlan *string, addressType *AddressType) ([]*v1beta2.AddressPlan, error)
	AuthenticationServices(ctx context.Context) ([]*v1beta11.AuthenticationService, error)
	AddressSpaceSchema(ctx context.Context) ([]*v1beta1.AddressSpaceSchema, error)
	AddressSpaceSchemaV2(ctx context.Context, addressSpaceType *AddressSpaceType) ([]*v1beta1.AddressSpaceSchema, error)
	Whoami(ctx context.Context) (*v12.User, error)
	Namespaces(ctx context.Context) ([]*v11.Namespace, error)
	AddressSpaces(ctx context.Context, first *int, offset *int, filter *string, orderBy *string) (*AddressSpaceQueryResultConsoleapiEnmasseIoV1beta1, error)
	Addresses(ctx context.Context, first *int, offset *int, filter *string, orderBy *string) (*AddressQueryResultConsoleapiEnmasseIoV1beta1, error)
	Connections(ctx context.Context, first *int, offset *int, filter *string, orderBy *string) (*ConnectionQueryResultConsoleapiEnmasseIoV1beta1, error)
	MessagingCertificateChain(ctx context.Context, input v1.ObjectMeta) (string, error)
	AddressSpaceCommand(ctx context.Context, input v1beta1.AddressSpace) (string, error)
	AddressCommand(ctx context.Context, input v1beta1.Address, addressSpace *string) (string, error)
	MessagingEndpoints(ctx context.Context, first *int, offset *int, filter *string, orderBy *string) (*MessagingEndpointQueryResultConsoleapiEnmasseIoV1beta1, error)
}

type Resolver 

type Resolver struct {
	AdminConfig  *v1beta2.AdminV1beta2Client
	CoreConfig   *v1beta1.EnmasseV1beta1Client
	Cache        *cache.MemdbCache
	GetCollector func(string) agent.Delegate
}

func (*Resolver) AddressPlanSpec_admin_enmasse_io_v1beta2 

func (r *Resolver) AddressPlanSpec_admin_enmasse_io_v1beta2() AddressPlanSpec_admin_enmasse_io_v1beta2Resolver

func (*Resolver) AddressSpacePlanSpec_admin_enmasse_io_v1beta2 

func (r *Resolver) AddressSpacePlanSpec_admin_enmasse_io_v1beta2() AddressSpacePlanSpec_admin_enmasse_io_v1beta2Resolver

func (*Resolver) AddressSpaceSpec_enmasse_io_v1beta1 

func (r *Resolver) AddressSpaceSpec_enmasse_io_v1beta1() AddressSpaceSpec_enmasse_io_v1beta1Resolver

func (*Resolver) AddressSpace_consoleapi_enmasse_io_v1beta1 

func (r *Resolver) AddressSpace_consoleapi_enmasse_io_v1beta1() AddressSpace_consoleapi_enmasse_io_v1beta1Resolver

func (*Resolver) AddressSpec_enmasse_io_v1beta1 

func (r *Resolver) AddressSpec_enmasse_io_v1beta1() AddressSpec_enmasse_io_v1beta1Resolver

func (*Resolver) Address_consoleapi_enmasse_io_v1beta1 

func (r *Resolver) Address_consoleapi_enmasse_io_v1beta1() Address_consoleapi_enmasse_io_v1beta1Resolver

func (*Resolver) AuthenticationServiceSpec_admin_enmasse_io_v1beta1 

func (r *Resolver) AuthenticationServiceSpec_admin_enmasse_io_v1beta1() AuthenticationServiceSpec_admin_enmasse_io_v1beta1Resolver

func (*Resolver) ConnectionSpec_consoleapi_enmasse_io_v1beta1 

func (r *Resolver) ConnectionSpec_consoleapi_enmasse_io_v1beta1() ConnectionSpec_consoleapi_enmasse_io_v1beta1Resolver

func (*Resolver) Connection_consoleapi_enmasse_io_v1beta1 

func (r *Resolver) Connection_consoleapi_enmasse_io_v1beta1() Connection_consoleapi_enmasse_io_v1beta1Resolver

func (*Resolver) LinkSpec_consoleapi_enmasse_io_v1beta1 

func (r *Resolver) LinkSpec_consoleapi_enmasse_io_v1beta1() LinkSpec_consoleapi_enmasse_io_v1beta1Resolver

func (*Resolver) Metric_consoleapi_enmasse_io_v1beta1 

func (r *Resolver) Metric_consoleapi_enmasse_io_v1beta1() Metric_consoleapi_enmasse_io_v1beta1Resolver

func (*Resolver) Mutation 

func (r *Resolver) Mutation() MutationResolver

func (*Resolver) NamespaceStatus_v1 

func (r *Resolver) NamespaceStatus_v1() NamespaceStatus_v1Resolver

func (*Resolver) ObjectMeta_v1 

func (r *Resolver) ObjectMeta_v1() ObjectMeta_v1Resolver

func (*Resolver) Port_enmasse_io_v1beta1 

func (r *Resolver) Port_enmasse_io_v1beta1() Port_enmasse_io_v1beta1Resolver

func (*Resolver) Query 

func (r *Resolver) Query() QueryResolver

type ResolverRoot 

type ResolverRoot interface {
	AddressPlanSpec_admin_enmasse_io_v1beta2() AddressPlanSpec_admin_enmasse_io_v1beta2Resolver
	AddressSpacePlanSpec_admin_enmasse_io_v1beta2() AddressSpacePlanSpec_admin_enmasse_io_v1beta2Resolver
	AddressSpaceSpec_enmasse_io_v1beta1() AddressSpaceSpec_enmasse_io_v1beta1Resolver
	AddressSpace_consoleapi_enmasse_io_v1beta1() AddressSpace_consoleapi_enmasse_io_v1beta1Resolver
	AddressSpec_enmasse_io_v1beta1() AddressSpec_enmasse_io_v1beta1Resolver
	Address_consoleapi_enmasse_io_v1beta1() Address_consoleapi_enmasse_io_v1beta1Resolver
	AuthenticationServiceSpec_admin_enmasse_io_v1beta1() AuthenticationServiceSpec_admin_enmasse_io_v1beta1Resolver
	ConnectionSpec_consoleapi_enmasse_io_v1beta1() ConnectionSpec_consoleapi_enmasse_io_v1beta1Resolver
	Connection_consoleapi_enmasse_io_v1beta1() Connection_consoleapi_enmasse_io_v1beta1Resolver
	LinkSpec_consoleapi_enmasse_io_v1beta1() LinkSpec_consoleapi_enmasse_io_v1beta1Resolver
	Metric_consoleapi_enmasse_io_v1beta1() Metric_consoleapi_enmasse_io_v1beta1Resolver
	Mutation() MutationResolver
	NamespaceStatus_v1() NamespaceStatus_v1Resolver
	ObjectMeta_v1() ObjectMeta_v1Resolver
	Port_enmasse_io_v1beta1() Port_enmasse_io_v1beta1Resolver
	Query() QueryResolver
}

Source Files

View all Source files

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.