api

package
v0.0.0-...-55171a9 Latest Latest
Warning

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

 Go to latest Published: Dec 5, 2018 License: MIT Imports: 7 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Policy_name = map[int32]string{
	0: "RANDOM",
	1: "LEAST_CONN",
	2: "ROUND_ROBIN",
	3: "FIRST",
	4: "IP_HASH",
	5: "URI_HASH",
	6: "HEADER",
}
View Source 
var Policy_value = map[string]int32{
	"RANDOM":      0,
	"LEAST_CONN":  1,
	"ROUND_ROBIN": 2,
	"FIRST":       3,
	"IP_HASH":     4,
	"URI_HASH":    5,
	"HEADER":      6,
}

Functions

func RegisterProxyServer 

func RegisterProxyServer(s *grpc.Server, srv ProxyServer)

Types

type AddServerRequest 

type AddServerRequest struct {
	Server               *Server  `protobuf:"bytes,1,opt,name=server" json:"server,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddServerRequest) Descriptor 

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

func (*AddServerRequest) GetServer 

func (m *AddServerRequest) GetServer() *Server

func (*AddServerRequest) ProtoMessage 

func (*AddServerRequest) ProtoMessage()

func (*AddServerRequest) Reset 

func (m *AddServerRequest) Reset()

func (*AddServerRequest) String 

func (m *AddServerRequest) String() string

func (*AddServerRequest) XXX_DiscardUnknown 

func (m *AddServerRequest) XXX_DiscardUnknown()

func (*AddServerRequest) XXX_Marshal 

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

func (*AddServerRequest) XXX_Merge 

func (dst *AddServerRequest) XXX_Merge(src proto.Message)

func (*AddServerRequest) XXX_Size 

func (m *AddServerRequest) XXX_Size() int

func (*AddServerRequest) XXX_Unmarshal 

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

type ConfigRequest 

type ConfigRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ConfigRequest) Descriptor 

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

func (*ConfigRequest) ProtoMessage 

func (*ConfigRequest) ProtoMessage()

func (*ConfigRequest) Reset 

func (m *ConfigRequest) Reset()

func (*ConfigRequest) String 

func (m *ConfigRequest) String() string

func (*ConfigRequest) XXX_DiscardUnknown 

func (m *ConfigRequest) XXX_DiscardUnknown()

func (*ConfigRequest) XXX_Marshal 

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

func (*ConfigRequest) XXX_Merge 

func (dst *ConfigRequest) XXX_Merge(src proto.Message)

func (*ConfigRequest) XXX_Size 

func (m *ConfigRequest) XXX_Size() int

func (*ConfigRequest) XXX_Unmarshal 

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

type ConfigResponse 

type ConfigResponse struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ConfigResponse) Descriptor 

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

func (*ConfigResponse) GetData 

func (m *ConfigResponse) GetData() []byte

func (*ConfigResponse) ProtoMessage 

func (*ConfigResponse) ProtoMessage()

func (*ConfigResponse) Reset 

func (m *ConfigResponse) Reset()

func (*ConfigResponse) String 

func (m *ConfigResponse) String() string

func (*ConfigResponse) XXX_DiscardUnknown 

func (m *ConfigResponse) XXX_DiscardUnknown()

func (*ConfigResponse) XXX_Marshal 

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

func (*ConfigResponse) XXX_Merge 

func (dst *ConfigResponse) XXX_Merge(src proto.Message)

func (*ConfigResponse) XXX_Size 

func (m *ConfigResponse) XXX_Size() int

func (*ConfigResponse) XXX_Unmarshal 

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

type HealthCheck 

type HealthCheck struct {
	HealthCheck          string          `protobuf:"bytes,1,opt,name=health_check,json=healthCheck,proto3" json:"health_check,omitempty"`
	HealthCheckInterval  *types.Duration `protobuf:"bytes,2,opt,name=health_check_interval,json=healthCheckInterval" json:"health_check_interval,omitempty"`
	HealthCheckTimeout   *types.Duration `protobuf:"bytes,3,opt,name=health_check_timeout,json=healthCheckTimeout" json:"health_check_timeout,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*HealthCheck) Descriptor 

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

func (*HealthCheck) GetHealthCheck 

func (m *HealthCheck) GetHealthCheck() string

func (*HealthCheck) GetHealthCheckInterval 

func (m *HealthCheck) GetHealthCheckInterval() *types.Duration

func (*HealthCheck) GetHealthCheckTimeout 

func (m *HealthCheck) GetHealthCheckTimeout() *types.Duration

func (*HealthCheck) ProtoMessage 

func (*HealthCheck) ProtoMessage()

func (*HealthCheck) Reset 

func (m *HealthCheck) Reset()

func (*HealthCheck) String 

func (m *HealthCheck) String() string

func (*HealthCheck) XXX_DiscardUnknown 

func (m *HealthCheck) XXX_DiscardUnknown()

func (*HealthCheck) XXX_Marshal 

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

func (*HealthCheck) XXX_Merge 

func (dst *HealthCheck) XXX_Merge(src proto.Message)

func (*HealthCheck) XXX_Size 

func (m *HealthCheck) XXX_Size() int

func (*HealthCheck) XXX_Unmarshal 

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

type Policy 

type Policy int32
const (
	Policy_RANDOM      Policy = 0
	Policy_LEAST_CONN  Policy = 1
	Policy_ROUND_ROBIN Policy = 2
	Policy_FIRST       Policy = 3
	Policy_IP_HASH     Policy = 4
	Policy_URI_HASH    Policy = 5
	Policy_HEADER      Policy = 6
)

func (Policy) EnumDescriptor 

func (Policy) EnumDescriptor() ([]byte, []int)

func (Policy) String 

func (x Policy) String() string

type ProxyClient 

type ProxyClient interface {
	AddServer(ctx context.Context, in *AddServerRequest, opts ...grpc.CallOption) (*types.Empty, error)
	RemoveServer(ctx context.Context, in *RemoveServerRequest, opts ...grpc.CallOption) (*types.Empty, error)
	Servers(ctx context.Context, in *ServersRequest, opts ...grpc.CallOption) (*ServersResponse, error)
	Reload(ctx context.Context, in *ReloadRequest, opts ...grpc.CallOption) (*types.Empty, error)
	Config(ctx context.Context, in *ConfigRequest, opts ...grpc.CallOption) (*ConfigResponse, error)
}

ProxyClient is the client API for Proxy service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewProxyClient 

func NewProxyClient(cc *grpc.ClientConn) ProxyClient

type ProxyServer 

type ProxyServer interface {
	AddServer(context.Context, *AddServerRequest) (*types.Empty, error)
	RemoveServer(context.Context, *RemoveServerRequest) (*types.Empty, error)
	Servers(context.Context, *ServersRequest) (*ServersResponse, error)
	Reload(context.Context, *ReloadRequest) (*types.Empty, error)
	Config(context.Context, *ConfigRequest) (*ConfigResponse, error)
}

ProxyServer is the server API for Proxy service.

type ReloadRequest 

type ReloadRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReloadRequest) Descriptor 

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

func (*ReloadRequest) ProtoMessage 

func (*ReloadRequest) ProtoMessage()

func (*ReloadRequest) Reset 

func (m *ReloadRequest) Reset()

func (*ReloadRequest) String 

func (m *ReloadRequest) String() string

func (*ReloadRequest) XXX_DiscardUnknown 

func (m *ReloadRequest) XXX_DiscardUnknown()

func (*ReloadRequest) XXX_Marshal 

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

func (*ReloadRequest) XXX_Merge 

func (dst *ReloadRequest) XXX_Merge(src proto.Message)

func (*ReloadRequest) XXX_Size 

func (m *ReloadRequest) XXX_Size() int

func (*ReloadRequest) XXX_Unmarshal 

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

type RemoveServerRequest 

type RemoveServerRequest struct {
	Host                 string   `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveServerRequest) Descriptor 

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

func (*RemoveServerRequest) GetHost 

func (m *RemoveServerRequest) GetHost() string

func (*RemoveServerRequest) ProtoMessage 

func (*RemoveServerRequest) ProtoMessage()

func (*RemoveServerRequest) Reset 

func (m *RemoveServerRequest) Reset()

func (*RemoveServerRequest) String 

func (m *RemoveServerRequest) String() string

func (*RemoveServerRequest) XXX_DiscardUnknown 

func (m *RemoveServerRequest) XXX_DiscardUnknown()

func (*RemoveServerRequest) XXX_Marshal 

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

func (*RemoveServerRequest) XXX_Merge 

func (dst *RemoveServerRequest) XXX_Merge(src proto.Message)

func (*RemoveServerRequest) XXX_Size 

func (m *RemoveServerRequest) XXX_Size() int

func (*RemoveServerRequest) XXX_Unmarshal 

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

type Server 

type Server struct {
	Host                 string            `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Path                 string            `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	TLS                  bool              `protobuf:"varint,3,opt,name=tls,proto3" json:"tls,omitempty"`
	Policy               Policy            `protobuf:"varint,4,opt,name=policy,proto3,enum=io.stellarproject.radiant.api.v1.Policy" json:"policy,omitempty"`
	Timeouts             *types.Duration   `protobuf:"bytes,5,opt,name=timeouts" json:"timeouts,omitempty"`
	Upstreams            []string          `protobuf:"bytes,6,rep,name=upstreams" json:"upstreams,omitempty"`
	HealthCheck          *HealthCheck      `protobuf:"bytes,7,opt,name=health_check,json=healthCheck" json:"health_check,omitempty"`
	InsecureSkipVerify   bool              `protobuf:"varint,8,opt,name=insecure_skip_verify,json=insecureSkipVerify,proto3" json:"insecure_skip_verify,omitempty"`
	Preset               string            `protobuf:"bytes,9,opt,name=preset,proto3" json:"preset,omitempty"`
	ProxyUpstreamHeaders map[string]string `` /* 205-byte string literal not displayed */
	Limits               string            `protobuf:"bytes,11,opt,name=limits,proto3" json:"limits,omitempty"`
	ProxyTryDuration     *types.Duration   `protobuf:"bytes,12,opt,name=proxy_try_duration,json=proxyTryDuration" json:"proxy_try_duration,omitempty"`
	ProxyFailTimeout     *types.Duration   `protobuf:"bytes,13,opt,name=proxy_fail_timeout,json=proxyFailTimeout" json:"proxy_fail_timeout,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Server) Descriptor 

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

func (*Server) GetHealthCheck 

func (m *Server) GetHealthCheck() *HealthCheck

func (*Server) GetHost 

func (m *Server) GetHost() string

func (*Server) GetInsecureSkipVerify 

func (m *Server) GetInsecureSkipVerify() bool

func (*Server) GetLimits 

func (m *Server) GetLimits() string

func (*Server) GetPath 

func (m *Server) GetPath() string

func (*Server) GetPolicy 

func (m *Server) GetPolicy() Policy

func (*Server) GetPreset 

func (m *Server) GetPreset() string

func (*Server) GetProxyFailTimeout 

func (m *Server) GetProxyFailTimeout() *types.Duration

func (*Server) GetProxyTryDuration 

func (m *Server) GetProxyTryDuration() *types.Duration

func (*Server) GetProxyUpstreamHeaders 

func (m *Server) GetProxyUpstreamHeaders() map[string]string

func (*Server) GetTLS 

func (m *Server) GetTLS() bool

func (*Server) GetTimeouts 

func (m *Server) GetTimeouts() *types.Duration

func (*Server) GetUpstreams 

func (m *Server) GetUpstreams() []string

func (*Server) ProtoMessage 

func (*Server) ProtoMessage()

func (*Server) Reset 

func (m *Server) Reset()

func (*Server) String 

func (m *Server) String() string

func (*Server) XXX_DiscardUnknown 

func (m *Server) XXX_DiscardUnknown()

func (*Server) XXX_Marshal 

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

func (*Server) XXX_Merge 

func (dst *Server) XXX_Merge(src proto.Message)

func (*Server) XXX_Size 

func (m *Server) XXX_Size() int

func (*Server) XXX_Unmarshal 

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

type ServersRequest 

type ServersRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ServersRequest) Descriptor 

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

func (*ServersRequest) ProtoMessage 

func (*ServersRequest) ProtoMessage()

func (*ServersRequest) Reset 

func (m *ServersRequest) Reset()

func (*ServersRequest) String 

func (m *ServersRequest) String() string

func (*ServersRequest) XXX_DiscardUnknown 

func (m *ServersRequest) XXX_DiscardUnknown()

func (*ServersRequest) XXX_Marshal 

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

func (*ServersRequest) XXX_Merge 

func (dst *ServersRequest) XXX_Merge(src proto.Message)

func (*ServersRequest) XXX_Size 

func (m *ServersRequest) XXX_Size() int

func (*ServersRequest) XXX_Unmarshal 

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

type ServersResponse 

type ServersResponse struct {
	Servers              []*Server `protobuf:"bytes,1,rep,name=servers" json:"servers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ServersResponse) Descriptor 

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

func (*ServersResponse) GetServers 

func (m *ServersResponse) GetServers() []*Server

func (*ServersResponse) ProtoMessage 

func (*ServersResponse) ProtoMessage()

func (*ServersResponse) Reset 

func (m *ServersResponse) Reset()

func (*ServersResponse) String 

func (m *ServersResponse) String() string

func (*ServersResponse) XXX_DiscardUnknown 

func (m *ServersResponse) XXX_DiscardUnknown()

func (*ServersResponse) XXX_Marshal 

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

func (*ServersResponse) XXX_Merge 

func (dst *ServersResponse) XXX_Merge(src proto.Message)

func (*ServersResponse) XXX_Size 

func (m *ServersResponse) XXX_Size() int

func (*ServersResponse) XXX_Unmarshal 

func (m *ServersResponse) 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.