grpc

package
v1.6.0-beta9 Latest Latest
Warning

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

 Go to latest Published: Nov 10, 2020 License: Apache-2.0 Imports: 13 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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) Hash added in v1.2.13 

func (m *DestinationSpec) Hash(hasher hash.Hash64) (uint64, error)

Hash function

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) Hash added in v1.2.13 

func (m *ServiceSpec) Hash(hasher hash.Hash64) (uint64, error)

Hash function

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) Hash added in v1.2.13 

func (m *ServiceSpec_GrpcService) Hash(hasher hash.Hash64) (uint64, error)

Hash function

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

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.