dynamicProxyController

package
v2.0.0-rc7 Latest Latest
Warning

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

 Go to latest Published: Mar 4, 2026 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DynamicProxyController_FrontendMappings_FullMethodName = "/DynamicProxyController/FrontendMappings"
)

Variables

View Source 
var DynamicProxyController_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "DynamicProxyController",
	HandlerType: (*DynamicProxyControllerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "FrontendMappings",
			Handler:    _DynamicProxyController_FrontendMappings_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "controller/dynamicProxyController/dynamicProxyController.proto",
}

DynamicProxyController_ServiceDesc is the grpc.ServiceDesc for DynamicProxyController service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_controller_dynamicProxyController_dynamicProxyController_proto protoreflect.FileDescriptor

Functions

func RegisterDynamicProxyControllerServer 

func RegisterDynamicProxyControllerServer(s grpc.ServiceRegistrar, srv DynamicProxyControllerServer)

Types

type AmqpPublisher 

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

func NewAmqpPublisher 

func NewAmqpPublisher(cfg *AmqpPublisherConfig) (*AmqpPublisher, error)

func (*AmqpPublisher) Close 

func (p *AmqpPublisher) Close() error

func (*AmqpPublisher) Publish 

func (p *AmqpPublisher) Publish(ctx context.Context, frontendToken string, m Mapping) error

type AmqpPublisherConfig 

type AmqpPublisherConfig struct {
	Url          string `dd:"+required"`
	ExchangeName string `dd:"+required"`
}

type Config 

type Config struct {
	IdentityPath  string               `dd:"+required"`
	ServiceName   string               `dd:"+required"`
	AmqpPublisher *AmqpPublisherConfig `dd:"+required"`
}

type Controller 

type Controller struct {
	UnimplementedDynamicProxyControllerServer
	// contains filtered or unexported fields
}

func NewController 

func NewController(cfg *Config, str *store.Store) (*Controller, error)

func (*Controller) BindFrontendMapping 

func (c *Controller) BindFrontendMapping(frontendToken, name, shareToken string, trx *sqlx.Tx) error

func (*Controller) FrontendMappings 

func (c *Controller) FrontendMappings(_ context.Context, req *FrontendMappingsRequest) (*FrontendMappingsResponse, error)

func (*Controller) UnbindFrontendMapping 

func (c *Controller) UnbindFrontendMapping(frontendToken, name string, trx *sqlx.Tx) error

type DynamicProxyControllerClient 

type DynamicProxyControllerClient interface {
	FrontendMappings(ctx context.Context, in *FrontendMappingsRequest, opts ...grpc.CallOption) (*FrontendMappingsResponse, error)
}

DynamicProxyControllerClient is the client API for DynamicProxyController 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 NewDynamicProxyControllerClient 

func NewDynamicProxyControllerClient(cc grpc.ClientConnInterface) DynamicProxyControllerClient

type DynamicProxyControllerServer 

type DynamicProxyControllerServer interface {
	FrontendMappings(context.Context, *FrontendMappingsRequest) (*FrontendMappingsResponse, error)
	// contains filtered or unexported methods
}

DynamicProxyControllerServer is the server API for DynamicProxyController service. All implementations must embed UnimplementedDynamicProxyControllerServer for forward compatibility.

type FrontendMapping 

type FrontendMapping struct {
	Id         int64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name       string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	ShareToken string `protobuf:"bytes,3,opt,name=shareToken,proto3" json:"shareToken,omitempty"`
	// contains filtered or unexported fields
}

func (*FrontendMapping) Descriptor deprecated 

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

Deprecated: Use FrontendMapping.ProtoReflect.Descriptor instead.

func (*FrontendMapping) GetId 

func (x *FrontendMapping) GetId() int64

func (*FrontendMapping) GetName 

func (x *FrontendMapping) GetName() string

func (*FrontendMapping) GetShareToken 

func (x *FrontendMapping) GetShareToken() string

func (*FrontendMapping) ProtoMessage 

func (*FrontendMapping) ProtoMessage()

func (*FrontendMapping) ProtoReflect 

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

func (*FrontendMapping) Reset 

func (x *FrontendMapping) Reset()

func (*FrontendMapping) String 

func (x *FrontendMapping) String() string

type FrontendMappingsRequest 

type FrontendMappingsRequest struct {
	Id            int64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	FrontendToken string `protobuf:"bytes,2,opt,name=frontendToken,proto3" json:"frontendToken,omitempty"`
	Name          string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*FrontendMappingsRequest) Descriptor deprecated 

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

Deprecated: Use FrontendMappingsRequest.ProtoReflect.Descriptor instead.

func (*FrontendMappingsRequest) GetFrontendToken 

func (x *FrontendMappingsRequest) GetFrontendToken() string

func (*FrontendMappingsRequest) GetId 

func (x *FrontendMappingsRequest) GetId() int64

func (*FrontendMappingsRequest) GetName 

func (x *FrontendMappingsRequest) GetName() string

func (*FrontendMappingsRequest) ProtoMessage 

func (*FrontendMappingsRequest) ProtoMessage()

func (*FrontendMappingsRequest) ProtoReflect 

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

func (*FrontendMappingsRequest) Reset 

func (x *FrontendMappingsRequest) Reset()

func (*FrontendMappingsRequest) String 

func (x *FrontendMappingsRequest) String() string

type FrontendMappingsResponse 

type FrontendMappingsResponse struct {
	FrontendMappings []*FrontendMapping `protobuf:"bytes,1,rep,name=frontendMappings,proto3" json:"frontendMappings,omitempty"`
	// contains filtered or unexported fields
}

func (*FrontendMappingsResponse) Descriptor deprecated 

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

Deprecated: Use FrontendMappingsResponse.ProtoReflect.Descriptor instead.

func (*FrontendMappingsResponse) GetFrontendMappings 

func (x *FrontendMappingsResponse) GetFrontendMappings() []*FrontendMapping

func (*FrontendMappingsResponse) ProtoMessage 

func (*FrontendMappingsResponse) ProtoMessage()

func (*FrontendMappingsResponse) ProtoReflect 

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

func (*FrontendMappingsResponse) Reset 

func (x *FrontendMappingsResponse) Reset()

func (*FrontendMappingsResponse) String 

func (x *FrontendMappingsResponse) String() string

type Mapping 

type Mapping struct {
	Id         int64     `json:"id"`
	Operation  Operation `json:"o"`
	Name       string    `json:"n"`
	ShareToken string    `json:"st"`
}

type Operation 

type Operation string
const (
	OperationBind   Operation = "bnd"
	OperationUnbind Operation = "ubd"
)

type UnimplementedDynamicProxyControllerServer 

type UnimplementedDynamicProxyControllerServer struct{}

UnimplementedDynamicProxyControllerServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedDynamicProxyControllerServer) FrontendMappings 

func (UnimplementedDynamicProxyControllerServer) FrontendMappings(context.Context, *FrontendMappingsRequest) (*FrontendMappingsResponse, error)

type UnsafeDynamicProxyControllerServer 

type UnsafeDynamicProxyControllerServer interface {
	// contains filtered or unexported methods
}

UnsafeDynamicProxyControllerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DynamicProxyControllerServer will result in compilation errors.

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.