grpc

Documentation

Index

• Constants
• func EncodeServiceProperties(properties ServiceProperties) *types.Struct
• type Plugin
  • func NewPlugin() *Plugin
  • func (p *Plugin) GetDependencies(cfg *v1.Config) *plugin.Dependencies
  • func (p *Plugin) HttpFilters(_ *plugin.FilterPluginParams) []plugin.StagedFilter
  • func (p *Plugin) ParseFunctionSpec(params *plugin.FunctionPluginParams, in v1.FunctionSpec) (*types.Struct, error)
  • func (p *Plugin) ProcessRoute(_ *plugin.RoutePluginParams, in *v1.Route, out *envoyroute.Route) error
  • func (p *Plugin) ProcessUpstream(params *plugin.UpstreamPluginParams, in *v1.Upstream, out *envoyapi.Cluster) error
• type ServiceProperties
  • func DecodeServiceProperties(generic *types.Struct) (ServiceProperties, error)

Constants

const (
	ServiceTypeGRPC = "gRPC"
)

Functions

func EncodeServiceProperties

func EncodeServiceProperties(properties ServiceProperties) *types.Struct

Types

type Plugin

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

func NewPlugin

func NewPlugin() *Plugin

func (*Plugin) GetDependencies

func (p *Plugin) GetDependencies(cfg *v1.Config) *plugin.Dependencies

func (*Plugin) HttpFilters

func (p *Plugin) HttpFilters(_ *plugin.FilterPluginParams) []plugin.StagedFilter

func (*Plugin) ParseFunctionSpec

func (p *Plugin) ParseFunctionSpec(params *plugin.FunctionPluginParams, in v1.FunctionSpec) (*types.Struct, error)

just so the init plugin knows we're functional

func (*Plugin) ProcessRoute

func (p *Plugin) ProcessRoute(_ *plugin.RoutePluginParams, in *v1.Route, out *envoyroute.Route) error

func (*Plugin) ProcessUpstream

func (p *Plugin) ProcessUpstream(params *plugin.UpstreamPluginParams, in *v1.Upstream, out *envoyapi.Cluster) error

type ServiceProperties

type ServiceProperties struct {
	// the name of the gRPC services defined in the descriptors (to route to)
	GRPCServiceNames []string `json:"service_names"`
	// file ref for the proto descriptors generated for is gRPC service
	DescriptorsFileRef string `json:"descriptors_file_ref"`
}

func DecodeServiceProperties

func DecodeServiceProperties(generic *types.Struct) (ServiceProperties, error)