pb

package
v1.4.0 Latest Latest
Warning

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

 Go to latest Published: Nov 4, 2021 License: Apache-2.0 Imports: 23 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_legacy_consumer_proto protoreflect.FileDescriptor

Functions

func LegacyConsumerServiceClientType 

func LegacyConsumerServiceClientType() reflect.Type

LegacyConsumerServiceClientType .

func LegacyConsumerServiceHandlerType 

func LegacyConsumerServiceHandlerType() reflect.Type

LegacyConsumerServiceHandlerType .

func LegacyConsumerServiceServerType 

func LegacyConsumerServiceServerType() reflect.Type

LegacyConsumerServiceServerType .

func RegisterLegacyConsumerServiceHandler 

func RegisterLegacyConsumerServiceHandler(r http.Router, srv LegacyConsumerServiceHandler, opts ...http.HandleOption)

RegisterLegacyConsumerServiceHandler register LegacyConsumerServiceHandler to http.Router.

func RegisterLegacyConsumerServiceImp 

func RegisterLegacyConsumerServiceImp(regester transport.Register, srv LegacyConsumerServiceServer, opts ...transport.ServiceOption)

RegisterLegacyConsumerServiceImp legacy_consumer.proto

func RegisterLegacyConsumerServiceServer 

func RegisterLegacyConsumerServiceServer(s grpc1.ServiceRegistrar, srv LegacyConsumerServiceServer, opts ...grpc1.HandleOption)

func ServiceNames 

func ServiceNames(svr ...string) []string

ServiceNames return all service names

func Types 

func Types() []reflect.Type

Types

type Endpoint 

type Endpoint struct {
	OuterAddr string `protobuf:"bytes,1,opt,name=outerAddr,proto3" json:"outerAddr,omitempty"`
	InnerAddr string `protobuf:"bytes,2,opt,name=innerAddr,proto3" json:"innerAddr,omitempty"`
	InnerTips string `protobuf:"bytes,3,opt,name=innerTips,proto3" json:"innerTips,omitempty"`
	// contains filtered or unexported fields
}

func (*Endpoint) Descriptor deprecated 

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

Deprecated: Use Endpoint.ProtoReflect.Descriptor instead.

func (*Endpoint) GetInnerAddr 

func (x *Endpoint) GetInnerAddr() string

func (*Endpoint) GetInnerTips 

func (x *Endpoint) GetInnerTips() string

func (*Endpoint) GetOuterAddr 

func (x *Endpoint) GetOuterAddr() string

func (*Endpoint) MarshalJSON 

func (m *Endpoint) MarshalJSON() ([]byte, error)

Endpoint implement json.Marshaler.

func (*Endpoint) ProtoMessage 

func (*Endpoint) ProtoMessage()

func (*Endpoint) ProtoReflect 

func (x *Endpoint) ProtoReflect() protoreflect.Message

func (*Endpoint) Reset 

func (x *Endpoint) Reset()

func (*Endpoint) String 

func (x *Endpoint) String() string

func (*Endpoint) UnmarshalJSON 

func (m *Endpoint) UnmarshalJSON(b []byte) error

Endpoint implement json.Marshaler.

func (*Endpoint) UnmarshalURLValues 

func (m *Endpoint) UnmarshalURLValues(prefix string, values url.Values) error

Endpoint implement urlenc.URLValuesUnmarshaler.

func (*Endpoint) Validate 

func (this *Endpoint) Validate() error

type GetConsumerRequest 

type GetConsumerRequest struct {
	OrgId     string `protobuf:"bytes,1,opt,name=orgId,proto3" json:"orgId,omitempty"`
	ProjectId string `protobuf:"bytes,2,opt,name=projectId,proto3" json:"projectId,omitempty"`
	Env       string `protobuf:"bytes,3,opt,name=env,proto3" json:"env,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConsumerRequest) Descriptor deprecated 

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

Deprecated: Use GetConsumerRequest.ProtoReflect.Descriptor instead.

func (*GetConsumerRequest) GetEnv 

func (x *GetConsumerRequest) GetEnv() string

func (*GetConsumerRequest) GetOrgId 

func (x *GetConsumerRequest) GetOrgId() string

func (*GetConsumerRequest) GetProjectId 

func (x *GetConsumerRequest) GetProjectId() string

func (*GetConsumerRequest) MarshalJSON 

func (m *GetConsumerRequest) MarshalJSON() ([]byte, error)

GetConsumerRequest implement json.Marshaler.

func (*GetConsumerRequest) ProtoMessage 

func (*GetConsumerRequest) ProtoMessage()

func (*GetConsumerRequest) ProtoReflect 

func (x *GetConsumerRequest) ProtoReflect() protoreflect.Message

func (*GetConsumerRequest) Reset 

func (x *GetConsumerRequest) Reset()

func (*GetConsumerRequest) String 

func (x *GetConsumerRequest) String() string

func (*GetConsumerRequest) UnmarshalJSON 

func (m *GetConsumerRequest) UnmarshalJSON(b []byte) error

GetConsumerRequest implement json.Marshaler.

func (*GetConsumerRequest) UnmarshalURLValues 

func (m *GetConsumerRequest) UnmarshalURLValues(prefix string, values url.Values) error

GetConsumerRequest implement urlenc.URLValuesUnmarshaler.

func (*GetConsumerRequest) Validate 

func (this *GetConsumerRequest) Validate() error

type GetConsumerResponse 

type GetConsumerResponse struct {
	ConsumerName    string    `protobuf:"bytes,1,opt,name=consumerName,proto3" json:"consumerName,omitempty"`
	ConsumerId      string    `protobuf:"bytes,2,opt,name=consumerId,proto3" json:"consumerId,omitempty"`
	Endpoint        *Endpoint `protobuf:"bytes,3,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	GatewayInstance string    `protobuf:"bytes,4,opt,name=gatewayInstance,proto3" json:"gatewayInstance,omitempty"`
	ClusterName     string    `protobuf:"bytes,5,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConsumerResponse) Descriptor deprecated 

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

Deprecated: Use GetConsumerResponse.ProtoReflect.Descriptor instead.

func (*GetConsumerResponse) GetClusterName 

func (x *GetConsumerResponse) GetClusterName() string

func (*GetConsumerResponse) GetConsumerId 

func (x *GetConsumerResponse) GetConsumerId() string

func (*GetConsumerResponse) GetConsumerName 

func (x *GetConsumerResponse) GetConsumerName() string

func (*GetConsumerResponse) GetEndpoint 

func (x *GetConsumerResponse) GetEndpoint() *Endpoint

func (*GetConsumerResponse) GetGatewayInstance 

func (x *GetConsumerResponse) GetGatewayInstance() string

func (*GetConsumerResponse) MarshalJSON 

func (m *GetConsumerResponse) MarshalJSON() ([]byte, error)

GetConsumerResponse implement json.Marshaler.

func (*GetConsumerResponse) ProtoMessage 

func (*GetConsumerResponse) ProtoMessage()

func (*GetConsumerResponse) ProtoReflect 

func (x *GetConsumerResponse) ProtoReflect() protoreflect.Message

func (*GetConsumerResponse) Reset 

func (x *GetConsumerResponse) Reset()

func (*GetConsumerResponse) String 

func (x *GetConsumerResponse) String() string

func (*GetConsumerResponse) UnmarshalJSON 

func (m *GetConsumerResponse) UnmarshalJSON(b []byte) error

GetConsumerResponse implement json.Marshaler.

func (*GetConsumerResponse) UnmarshalURLValues 

func (m *GetConsumerResponse) UnmarshalURLValues(prefix string, values url.Values) error

GetConsumerResponse implement urlenc.URLValuesUnmarshaler.

func (*GetConsumerResponse) Validate 

func (this *GetConsumerResponse) Validate() error

type LegacyConsumerServiceClient 

type LegacyConsumerServiceClient interface {
	// +publish path:"/api/gateway/consumer"
	GetConsumer(ctx context.Context, in *GetConsumerRequest, opts ...grpc.CallOption) (*GetConsumerResponse, error)
}

LegacyConsumerServiceClient is the client API for LegacyConsumerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewLegacyConsumerServiceClient 

func NewLegacyConsumerServiceClient(cc grpc1.ClientConnInterface) LegacyConsumerServiceClient

type LegacyConsumerServiceHandler 

type LegacyConsumerServiceHandler interface {
	// +publish path:"/api/gateway/consumer"
	// GET /api/gateway/consumer
	GetConsumer(context.Context, *GetConsumerRequest) (*GetConsumerResponse, error)
}

LegacyConsumerServiceHandler is the server API for LegacyConsumerService service.

type LegacyConsumerServiceServer 

type LegacyConsumerServiceServer interface {
	// +publish path:"/api/gateway/consumer"
	GetConsumer(context.Context, *GetConsumerRequest) (*GetConsumerResponse, error)
}

LegacyConsumerServiceServer is the server API for LegacyConsumerService service. All implementations should embed UnimplementedLegacyConsumerServiceServer for forward compatibility

type UnimplementedLegacyConsumerServiceServer 

type UnimplementedLegacyConsumerServiceServer struct {
}

UnimplementedLegacyConsumerServiceServer should be embedded to have forward compatible implementations.

func (*UnimplementedLegacyConsumerServiceServer) GetConsumer 

func (*UnimplementedLegacyConsumerServiceServer) GetConsumer(context.Context, *GetConsumerRequest) (*GetConsumerResponse, 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.