grpc

Documentation

Index

• type DestinationSpec
  • func (*DestinationSpec) Descriptor() ([]byte, []int)
  • func (this *DestinationSpec) Equal(that interface{}) bool
  • func (m *DestinationSpec) GetFunction() string
  • func (m *DestinationSpec) GetPackage() string
  • func (m *DestinationSpec) GetParameters() *transformation.Parameters
  • func (m *DestinationSpec) GetService() string
  • func (*DestinationSpec) ProtoMessage()
  • func (m *DestinationSpec) Reset()
  • func (m *DestinationSpec) String() string
  • func (m *DestinationSpec) XXX_DiscardUnknown()
  • func (m *DestinationSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *DestinationSpec) XXX_Merge(src proto.Message)
  • func (m *DestinationSpec) XXX_Size() int
  • func (m *DestinationSpec) XXX_Unmarshal(b []byte) error
• type ServiceSpec
  • func (*ServiceSpec) Descriptor() ([]byte, []int)
  • func (this *ServiceSpec) Equal(that interface{}) bool
  • func (m *ServiceSpec) GetDescriptors() []byte
  • func (m *ServiceSpec) GetGrpcServices() []*ServiceSpec_GrpcService
  • func (*ServiceSpec) ProtoMessage()
  • func (m *ServiceSpec) Reset()
  • func (m *ServiceSpec) String() string
  • func (m *ServiceSpec) XXX_DiscardUnknown()
  • func (m *ServiceSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ServiceSpec) XXX_Merge(src proto.Message)
  • func (m *ServiceSpec) XXX_Size() int
  • func (m *ServiceSpec) XXX_Unmarshal(b []byte) error
• type ServiceSpec_GrpcService
  • func (*ServiceSpec_GrpcService) Descriptor() ([]byte, []int)
  • func (this *ServiceSpec_GrpcService) Equal(that interface{}) bool
  • func (m *ServiceSpec_GrpcService) GetFunctionNames() []string
  • func (m *ServiceSpec_GrpcService) GetPackageName() string
  • func (m *ServiceSpec_GrpcService) GetServiceName() string
  • func (*ServiceSpec_GrpcService) ProtoMessage()
  • func (m *ServiceSpec_GrpcService) Reset()
  • func (m *ServiceSpec_GrpcService) String() string
  • func (m *ServiceSpec_GrpcService) XXX_DiscardUnknown()
  • func (m *ServiceSpec_GrpcService) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ServiceSpec_GrpcService) XXX_Merge(src proto.Message)
  • func (m *ServiceSpec_GrpcService) XXX_Size() int
  • func (m *ServiceSpec_GrpcService) XXX_Unmarshal(b []byte) error

Types

type DestinationSpec

type DestinationSpec struct {
	// The proto package of the function.
	Package string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	// The name of the service of the function.
	Service string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	// The name of the function.
	Function string `protobuf:"bytes,3,opt,name=function,proto3" json:"function,omitempty"`
	// Parameters describe how to extract the function parameters from the
	// request.
	Parameters           *transformation.Parameters `protobuf:"bytes,4,opt,name=parameters,proto3" json:"parameters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

This is only for upstream with Grpc service spec.

func (*DestinationSpec) Descriptor

func (*DestinationSpec) Descriptor() ([]byte, []int)

func (*DestinationSpec) Equal

func (this *DestinationSpec) Equal(that interface{}) bool

func (*DestinationSpec) GetFunction

func (m *DestinationSpec) GetFunction() string

func (*DestinationSpec) GetPackage

func (m *DestinationSpec) GetPackage() string

func (*DestinationSpec) GetParameters

func (m *DestinationSpec) GetParameters() *transformation.Parameters

func (*DestinationSpec) GetService

func (m *DestinationSpec) GetService() string

func (*DestinationSpec) ProtoMessage

func (*DestinationSpec) ProtoMessage()

func (*DestinationSpec) Reset

func (m *DestinationSpec) Reset()

func (*DestinationSpec) String

func (m *DestinationSpec) String() string

func (*DestinationSpec) XXX_DiscardUnknown

func (m *DestinationSpec) XXX_DiscardUnknown()

func (*DestinationSpec) XXX_Marshal

func (m *DestinationSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DestinationSpec) XXX_Merge

func (m *DestinationSpec) XXX_Merge(src proto.Message)

func (*DestinationSpec) XXX_Size

func (m *DestinationSpec) XXX_Size() int

func (*DestinationSpec) XXX_Unmarshal

func (m *DestinationSpec) XXX_Unmarshal(b []byte) error

type ServiceSpec

type ServiceSpec struct {
	// Descriptors that contain information of the services listed below.
	// this is a serialized google.protobuf.FileDescriptorSet
	Descriptors []byte `protobuf:"bytes,1,opt,name=descriptors,proto3" json:"descriptors,omitempty"`
	// List of services used by this upstream. For a grpc upstream where you don't
	// need to use Gloo's function routing, this can be an empty list. These
	// services must be present in the descriptors.
	GrpcServices         []*ServiceSpec_GrpcService `protobuf:"bytes,2,rep,name=grpc_services,json=grpcServices,proto3" json:"grpc_services,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

Service spec describing GRPC upstreams. This will usually be filled automatically via function discovery (if the upstream supports reflection). If your upstream service is a GRPC service, use this service spec (an empty spec is fine), to make sure that traffic to it is routed with http2.

func (*ServiceSpec) Descriptor

func (*ServiceSpec) Descriptor() ([]byte, []int)

func (*ServiceSpec) Equal

func (this *ServiceSpec) Equal(that interface{}) bool

func (*ServiceSpec) GetDescriptors

func (m *ServiceSpec) GetDescriptors() []byte

func (*ServiceSpec) GetGrpcServices

func (m *ServiceSpec) GetGrpcServices() []*ServiceSpec_GrpcService

func (*ServiceSpec) ProtoMessage

func (*ServiceSpec) ProtoMessage()

func (*ServiceSpec) Reset

func (m *ServiceSpec) Reset()

func (*ServiceSpec) String

func (m *ServiceSpec) String() string

func (*ServiceSpec) XXX_DiscardUnknown

func (m *ServiceSpec) XXX_DiscardUnknown()

func (*ServiceSpec) XXX_Marshal

func (m *ServiceSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceSpec) XXX_Merge

func (m *ServiceSpec) XXX_Merge(src proto.Message)

func (*ServiceSpec) XXX_Size

func (m *ServiceSpec) XXX_Size() int

func (*ServiceSpec) XXX_Unmarshal

func (m *ServiceSpec) XXX_Unmarshal(b []byte) error

type ServiceSpec_GrpcService

type ServiceSpec_GrpcService struct {
	// The package of this service.
	PackageName string `protobuf:"bytes,1,opt,name=package_name,json=packageName,proto3" json:"package_name,omitempty"`
	// The service name of this service.
	ServiceName string `protobuf:"bytes,2,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// The functions available in this service.
	FunctionNames        []string `protobuf:"bytes,3,rep,name=function_names,json=functionNames,proto3" json:"function_names,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Describes a grpc service

func (*ServiceSpec_GrpcService) Descriptor

func (*ServiceSpec_GrpcService) Descriptor() ([]byte, []int)

func (*ServiceSpec_GrpcService) Equal

func (this *ServiceSpec_GrpcService) Equal(that interface{}) bool

func (*ServiceSpec_GrpcService) GetFunctionNames

func (m *ServiceSpec_GrpcService) GetFunctionNames() []string

func (*ServiceSpec_GrpcService) GetPackageName

func (m *ServiceSpec_GrpcService) GetPackageName() string

func (*ServiceSpec_GrpcService) GetServiceName

func (m *ServiceSpec_GrpcService) GetServiceName() string

func (*ServiceSpec_GrpcService) ProtoMessage

func (*ServiceSpec_GrpcService) ProtoMessage()

func (*ServiceSpec_GrpcService) Reset

func (m *ServiceSpec_GrpcService) Reset()

func (*ServiceSpec_GrpcService) String

func (m *ServiceSpec_GrpcService) String() string

func (*ServiceSpec_GrpcService) XXX_DiscardUnknown

func (m *ServiceSpec_GrpcService) XXX_DiscardUnknown()

func (*ServiceSpec_GrpcService) XXX_Marshal

func (m *ServiceSpec_GrpcService) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceSpec_GrpcService) XXX_Merge

func (m *ServiceSpec_GrpcService) XXX_Merge(src proto.Message)

func (*ServiceSpec_GrpcService) XXX_Size

func (m *ServiceSpec_GrpcService) XXX_Size() int

func (*ServiceSpec_GrpcService) XXX_Unmarshal

func (m *ServiceSpec_GrpcService) XXX_Unmarshal(b []byte) error