api

package
v1.16.0 Latest Latest
Warning

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

 Go to latest Published: Oct 31, 2018 License: AGPL-3.0 Imports: 13 Imported by: 0

Documentation

Overview

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var ScrapeTargetHealth_Health_name = map[int32]string{
	0: "UNKNOWN",
	1: "DOWN",
	2: "UP",
}
View Source 
var ScrapeTargetHealth_Health_value = map[string]int32{
	"UNKNOWN": 0,
	"DOWN":    1,
	"UP":      2,
}

Functions

func RegisterAnnotationsHandler added in v1.14.1 

func RegisterAnnotationsHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterAnnotationsHandler registers the http handlers for service Annotations to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterAnnotationsHandlerClient added in v1.14.1 

func RegisterAnnotationsHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AnnotationsClient) error

RegisterAnnotationsHandlerClient registers the http handlers for service Annotations to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "AnnotationsClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "AnnotationsClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "AnnotationsClient" to call the correct interceptors.

func RegisterAnnotationsHandlerFromEndpoint added in v1.14.1 

func RegisterAnnotationsHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterAnnotationsHandlerFromEndpoint is same as RegisterAnnotationsHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterAnnotationsServer added in v1.14.1 

func RegisterAnnotationsServer(s *grpc.Server, srv AnnotationsServer)

func RegisterBaseHandler 

func RegisterBaseHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterBaseHandler registers the http handlers for service Base to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterBaseHandlerClient 

func RegisterBaseHandlerClient(ctx context.Context, mux *runtime.ServeMux, client BaseClient) error

RegisterBaseHandlerClient registers the http handlers for service Base to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "BaseClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "BaseClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "BaseClient" to call the correct interceptors.

func RegisterBaseHandlerFromEndpoint 

func RegisterBaseHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterBaseHandlerFromEndpoint is same as RegisterBaseHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterBaseServer 

func RegisterBaseServer(s *grpc.Server, srv BaseServer)

func RegisterDemoHandler 

func RegisterDemoHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterDemoHandler registers the http handlers for service Demo to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterDemoHandlerClient 

func RegisterDemoHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DemoClient) error

RegisterDemoHandlerClient registers the http handlers for service Demo to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "DemoClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "DemoClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "DemoClient" to call the correct interceptors.

func RegisterDemoHandlerFromEndpoint 

func RegisterDemoHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterDemoHandlerFromEndpoint is same as RegisterDemoHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterDemoServer 

func RegisterDemoServer(s *grpc.Server, srv DemoServer)

func RegisterLogsHandler added in v1.14.1 

func RegisterLogsHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterLogsHandler registers the http handlers for service Logs to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterLogsHandlerClient added in v1.14.1 

func RegisterLogsHandlerClient(ctx context.Context, mux *runtime.ServeMux, client LogsClient) error

RegisterLogsHandlerClient registers the http handlers for service Logs to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "LogsClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "LogsClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "LogsClient" to call the correct interceptors.

func RegisterLogsHandlerFromEndpoint added in v1.14.1 

func RegisterLogsHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterLogsHandlerFromEndpoint is same as RegisterLogsHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterLogsServer added in v1.14.1 

func RegisterLogsServer(s *grpc.Server, srv LogsServer)

func RegisterMySQLHandler added in v1.16.0 

func RegisterMySQLHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterMySQLHandler registers the http handlers for service MySQL to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterMySQLHandlerClient added in v1.16.0 

func RegisterMySQLHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MySQLClient) error

RegisterMySQLHandlerClient registers the http handlers for service MySQL to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "MySQLClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "MySQLClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "MySQLClient" to call the correct interceptors.

func RegisterMySQLHandlerFromEndpoint added in v1.16.0 

func RegisterMySQLHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterMySQLHandlerFromEndpoint is same as RegisterMySQLHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterMySQLServer added in v1.16.0 

func RegisterMySQLServer(s *grpc.Server, srv MySQLServer)

func RegisterPostgreSQLHandler added in v1.16.0 

func RegisterPostgreSQLHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterPostgreSQLHandler registers the http handlers for service PostgreSQL to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterPostgreSQLHandlerClient added in v1.16.0 

func RegisterPostgreSQLHandlerClient(ctx context.Context, mux *runtime.ServeMux, client PostgreSQLClient) error

RegisterPostgreSQLHandlerClient registers the http handlers for service PostgreSQL to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "PostgreSQLClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "PostgreSQLClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "PostgreSQLClient" to call the correct interceptors.

func RegisterPostgreSQLHandlerFromEndpoint added in v1.16.0 

func RegisterPostgreSQLHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterPostgreSQLHandlerFromEndpoint is same as RegisterPostgreSQLHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterPostgreSQLServer added in v1.16.0 

func RegisterPostgreSQLServer(s *grpc.Server, srv PostgreSQLServer)

func RegisterRDSHandler added in v1.5.0 

func RegisterRDSHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterRDSHandler registers the http handlers for service RDS to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterRDSHandlerClient added in v1.5.0 

func RegisterRDSHandlerClient(ctx context.Context, mux *runtime.ServeMux, client RDSClient) error

RegisterRDSHandlerClient registers the http handlers for service RDS to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "RDSClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "RDSClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "RDSClient" to call the correct interceptors.

func RegisterRDSHandlerFromEndpoint added in v1.5.0 

func RegisterRDSHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterRDSHandlerFromEndpoint is same as RegisterRDSHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterRDSServer added in v1.5.0 

func RegisterRDSServer(s *grpc.Server, srv RDSServer)

func RegisterRemoteHandler added in v1.16.0 

func RegisterRemoteHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterRemoteHandler registers the http handlers for service Remote to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterRemoteHandlerClient added in v1.16.0 

func RegisterRemoteHandlerClient(ctx context.Context, mux *runtime.ServeMux, client RemoteClient) error

RegisterRemoteHandlerClient registers the http handlers for service Remote to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "RemoteClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "RemoteClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "RemoteClient" to call the correct interceptors.

func RegisterRemoteHandlerFromEndpoint added in v1.16.0 

func RegisterRemoteHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterRemoteHandlerFromEndpoint is same as RegisterRemoteHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterRemoteServer added in v1.16.0 

func RegisterRemoteServer(s *grpc.Server, srv RemoteServer)

func RegisterScrapeConfigsHandler 

func RegisterScrapeConfigsHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterScrapeConfigsHandler registers the http handlers for service ScrapeConfigs to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterScrapeConfigsHandlerClient 

func RegisterScrapeConfigsHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ScrapeConfigsClient) error

RegisterScrapeConfigsHandlerClient registers the http handlers for service ScrapeConfigs to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ScrapeConfigsClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ScrapeConfigsClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ScrapeConfigsClient" to call the correct interceptors.

func RegisterScrapeConfigsHandlerFromEndpoint 

func RegisterScrapeConfigsHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterScrapeConfigsHandlerFromEndpoint is same as RegisterScrapeConfigsHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterScrapeConfigsServer 

func RegisterScrapeConfigsServer(s *grpc.Server, srv ScrapeConfigsServer)

Types

type AnnotationsClient added in v1.14.1 

type AnnotationsClient interface {
	Create(ctx context.Context, in *AnnotationsCreateRequest, opts ...grpc.CallOption) (*AnnotationsCreateResponse, error)
}

AnnotationsClient is the client API for Annotations service.

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

func NewAnnotationsClient added in v1.14.1 

func NewAnnotationsClient(cc *grpc.ClientConn) AnnotationsClient

type AnnotationsCreateRequest added in v1.14.1 

type AnnotationsCreateRequest struct {
	Tags                 []string `protobuf:"bytes,1,rep,name=tags,proto3" json:"tags,omitempty"`
	Text                 string   `protobuf:"bytes,2,opt,name=text,proto3" json:"text,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AnnotationsCreateRequest) Descriptor added in v1.14.1 

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

func (*AnnotationsCreateRequest) GetTags added in v1.14.1 

func (m *AnnotationsCreateRequest) GetTags() []string

func (*AnnotationsCreateRequest) GetText added in v1.14.1 

func (m *AnnotationsCreateRequest) GetText() string

func (*AnnotationsCreateRequest) ProtoMessage added in v1.14.1 

func (*AnnotationsCreateRequest) ProtoMessage()

func (*AnnotationsCreateRequest) Reset added in v1.14.1 

func (m *AnnotationsCreateRequest) Reset()

func (*AnnotationsCreateRequest) String added in v1.14.1 

func (m *AnnotationsCreateRequest) String() string

func (*AnnotationsCreateRequest) XXX_DiscardUnknown added in v1.16.0 

func (m *AnnotationsCreateRequest) XXX_DiscardUnknown()

func (*AnnotationsCreateRequest) XXX_Marshal added in v1.16.0 

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

func (*AnnotationsCreateRequest) XXX_Merge added in v1.16.0 

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

func (*AnnotationsCreateRequest) XXX_Size added in v1.16.0 

func (m *AnnotationsCreateRequest) XXX_Size() int

func (*AnnotationsCreateRequest) XXX_Unmarshal added in v1.16.0 

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

type AnnotationsCreateResponse added in v1.14.1 

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

func (*AnnotationsCreateResponse) Descriptor added in v1.14.1 

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

func (*AnnotationsCreateResponse) GetMessage added in v1.14.1 

func (m *AnnotationsCreateResponse) GetMessage() string

func (*AnnotationsCreateResponse) ProtoMessage added in v1.14.1 

func (*AnnotationsCreateResponse) ProtoMessage()

func (*AnnotationsCreateResponse) Reset added in v1.14.1 

func (m *AnnotationsCreateResponse) Reset()

func (*AnnotationsCreateResponse) String added in v1.14.1 

func (m *AnnotationsCreateResponse) String() string

func (*AnnotationsCreateResponse) XXX_DiscardUnknown added in v1.16.0 

func (m *AnnotationsCreateResponse) XXX_DiscardUnknown()

func (*AnnotationsCreateResponse) XXX_Marshal added in v1.16.0 

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

func (*AnnotationsCreateResponse) XXX_Merge added in v1.16.0 

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

func (*AnnotationsCreateResponse) XXX_Size added in v1.16.0 

func (m *AnnotationsCreateResponse) XXX_Size() int

func (*AnnotationsCreateResponse) XXX_Unmarshal added in v1.16.0 

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

type AnnotationsServer added in v1.14.1 

type AnnotationsServer interface {
	Create(context.Context, *AnnotationsCreateRequest) (*AnnotationsCreateResponse, error)
}

AnnotationsServer is the server API for Annotations service.

type BaseClient 

type BaseClient interface {
	Version(ctx context.Context, in *BaseVersionRequest, opts ...grpc.CallOption) (*BaseVersionResponse, error)
}

BaseClient is the client API for Base service.

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

func NewBaseClient 

func NewBaseClient(cc *grpc.ClientConn) BaseClient

type BaseServer 

type BaseServer interface {
	Version(context.Context, *BaseVersionRequest) (*BaseVersionResponse, error)
}

BaseServer is the server API for Base service.

type BaseVersionRequest 

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

func (*BaseVersionRequest) Descriptor 

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

func (*BaseVersionRequest) ProtoMessage 

func (*BaseVersionRequest) ProtoMessage()

func (*BaseVersionRequest) Reset 

func (m *BaseVersionRequest) Reset()

func (*BaseVersionRequest) String 

func (m *BaseVersionRequest) String() string

func (*BaseVersionRequest) XXX_DiscardUnknown added in v1.16.0 

func (m *BaseVersionRequest) XXX_DiscardUnknown()

func (*BaseVersionRequest) XXX_Marshal added in v1.16.0 

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

func (*BaseVersionRequest) XXX_Merge added in v1.16.0 

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

func (*BaseVersionRequest) XXX_Size added in v1.16.0 

func (m *BaseVersionRequest) XXX_Size() int

func (*BaseVersionRequest) XXX_Unmarshal added in v1.16.0 

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

type BaseVersionResponse 

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

func (*BaseVersionResponse) Descriptor 

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

func (*BaseVersionResponse) GetVersion 

func (m *BaseVersionResponse) GetVersion() string

func (*BaseVersionResponse) ProtoMessage 

func (*BaseVersionResponse) ProtoMessage()

func (*BaseVersionResponse) Reset 

func (m *BaseVersionResponse) Reset()

func (*BaseVersionResponse) String 

func (m *BaseVersionResponse) String() string

func (*BaseVersionResponse) XXX_DiscardUnknown added in v1.16.0 

func (m *BaseVersionResponse) XXX_DiscardUnknown()

func (*BaseVersionResponse) XXX_Marshal added in v1.16.0 

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

func (*BaseVersionResponse) XXX_Merge added in v1.16.0 

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

func (*BaseVersionResponse) XXX_Size added in v1.16.0 

func (m *BaseVersionResponse) XXX_Size() int

func (*BaseVersionResponse) XXX_Unmarshal added in v1.16.0 

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

type BasicAuth 

type BasicAuth struct {
	Username             string   `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password             string   `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BasicAuth) Descriptor 

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

func (*BasicAuth) GetPassword 

func (m *BasicAuth) GetPassword() string

func (*BasicAuth) GetUsername 

func (m *BasicAuth) GetUsername() string

func (*BasicAuth) ProtoMessage 

func (*BasicAuth) ProtoMessage()

func (*BasicAuth) Reset 

func (m *BasicAuth) Reset()

func (*BasicAuth) String 

func (m *BasicAuth) String() string

func (*BasicAuth) XXX_DiscardUnknown added in v1.16.0 

func (m *BasicAuth) XXX_DiscardUnknown()

func (*BasicAuth) XXX_Marshal added in v1.16.0 

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

func (*BasicAuth) XXX_Merge added in v1.16.0 

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

func (*BasicAuth) XXX_Size added in v1.16.0 

func (m *BasicAuth) XXX_Size() int

func (*BasicAuth) XXX_Unmarshal added in v1.16.0 

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

type Client 

type Client struct {
	BaseClient
	ScrapeConfigsClient
}

Client is a client for pmm-managed APIs.

func NewClient 

func NewClient(cc *grpc.ClientConn) *Client

NewClient creates new Client for a given connection.

type DemoClient 

type DemoClient interface {
	Error(ctx context.Context, in *DemoErrorRequest, opts ...grpc.CallOption) (*DemoErrorResponse, error)
}

DemoClient is the client API for Demo service.

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

func NewDemoClient 

func NewDemoClient(cc *grpc.ClientConn) DemoClient

type DemoErrorRequest 

type DemoErrorRequest struct {
	Code                 uint32   `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Key                  string   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DemoErrorRequest) Descriptor 

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

func (*DemoErrorRequest) GetCode 

func (m *DemoErrorRequest) GetCode() uint32

func (*DemoErrorRequest) GetKey 

func (m *DemoErrorRequest) GetKey() string

func (*DemoErrorRequest) GetValue 

func (m *DemoErrorRequest) GetValue() string

func (*DemoErrorRequest) ProtoMessage 

func (*DemoErrorRequest) ProtoMessage()

func (*DemoErrorRequest) Reset 

func (m *DemoErrorRequest) Reset()

func (*DemoErrorRequest) String 

func (m *DemoErrorRequest) String() string

func (*DemoErrorRequest) XXX_DiscardUnknown added in v1.16.0 

func (m *DemoErrorRequest) XXX_DiscardUnknown()

func (*DemoErrorRequest) XXX_Marshal added in v1.16.0 

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

func (*DemoErrorRequest) XXX_Merge added in v1.16.0 

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

func (*DemoErrorRequest) XXX_Size added in v1.16.0 

func (m *DemoErrorRequest) XXX_Size() int

func (*DemoErrorRequest) XXX_Unmarshal added in v1.16.0 

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

type DemoErrorResponse 

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

func (*DemoErrorResponse) Descriptor 

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

func (*DemoErrorResponse) ProtoMessage 

func (*DemoErrorResponse) ProtoMessage()

func (*DemoErrorResponse) Reset 

func (m *DemoErrorResponse) Reset()

func (*DemoErrorResponse) String 

func (m *DemoErrorResponse) String() string

func (*DemoErrorResponse) XXX_DiscardUnknown added in v1.16.0 

func (m *DemoErrorResponse) XXX_DiscardUnknown()

func (*DemoErrorResponse) XXX_Marshal added in v1.16.0 

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

func (*DemoErrorResponse) XXX_Merge added in v1.16.0 

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

func (*DemoErrorResponse) XXX_Size added in v1.16.0 

func (m *DemoErrorResponse) XXX_Size() int

func (*DemoErrorResponse) XXX_Unmarshal added in v1.16.0 

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

type DemoServer 

type DemoServer interface {
	Error(context.Context, *DemoErrorRequest) (*DemoErrorResponse, error)
}

DemoServer is the server API for Demo service.

type LabelPair 

type LabelPair struct {
	// Label name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Label value
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LabelPair) Descriptor 

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

func (*LabelPair) GetName 

func (m *LabelPair) GetName() string

func (*LabelPair) GetValue 

func (m *LabelPair) GetValue() string

func (*LabelPair) ProtoMessage 

func (*LabelPair) ProtoMessage()

func (*LabelPair) Reset 

func (m *LabelPair) Reset()

func (*LabelPair) String 

func (m *LabelPair) String() string

func (*LabelPair) XXX_DiscardUnknown added in v1.16.0 

func (m *LabelPair) XXX_DiscardUnknown()

func (*LabelPair) XXX_Marshal added in v1.16.0 

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

func (*LabelPair) XXX_Merge added in v1.16.0 

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

func (*LabelPair) XXX_Size added in v1.16.0 

func (m *LabelPair) XXX_Size() int

func (*LabelPair) XXX_Unmarshal added in v1.16.0 

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

type Log added in v1.14.1 

type Log struct {
	// Last lines of log file
	Lines                []string `protobuf:"bytes,1,rep,name=lines,proto3" json:"lines,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Log) Descriptor added in v1.14.1 

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

func (*Log) GetLines added in v1.14.1 

func (m *Log) GetLines() []string

func (*Log) ProtoMessage added in v1.14.1 

func (*Log) ProtoMessage()

func (*Log) Reset added in v1.14.1 

func (m *Log) Reset()

func (*Log) String added in v1.14.1 

func (m *Log) String() string

func (*Log) XXX_DiscardUnknown added in v1.16.0 

func (m *Log) XXX_DiscardUnknown()

func (*Log) XXX_Marshal added in v1.16.0 

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

func (*Log) XXX_Merge added in v1.16.0 

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

func (*Log) XXX_Size added in v1.16.0 

func (m *Log) XXX_Size() int

func (*Log) XXX_Unmarshal added in v1.16.0 

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

type LogsAllRequest added in v1.14.1 

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

func (*LogsAllRequest) Descriptor added in v1.14.1 

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

func (*LogsAllRequest) ProtoMessage added in v1.14.1 

func (*LogsAllRequest) ProtoMessage()

func (*LogsAllRequest) Reset added in v1.14.1 

func (m *LogsAllRequest) Reset()

func (*LogsAllRequest) String added in v1.14.1 

func (m *LogsAllRequest) String() string

func (*LogsAllRequest) XXX_DiscardUnknown added in v1.16.0 

func (m *LogsAllRequest) XXX_DiscardUnknown()

func (*LogsAllRequest) XXX_Marshal added in v1.16.0 

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

func (*LogsAllRequest) XXX_Merge added in v1.16.0 

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

func (*LogsAllRequest) XXX_Size added in v1.16.0 

func (m *LogsAllRequest) XXX_Size() int

func (*LogsAllRequest) XXX_Unmarshal added in v1.16.0 

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

type LogsAllResponse added in v1.14.1 

type LogsAllResponse struct {
	// Maps log file name to content
	Logs                 map[string]*Log `` /* 149-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*LogsAllResponse) Descriptor added in v1.14.1 

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

func (*LogsAllResponse) GetLogs added in v1.14.1 

func (m *LogsAllResponse) GetLogs() map[string]*Log

func (*LogsAllResponse) ProtoMessage added in v1.14.1 

func (*LogsAllResponse) ProtoMessage()

func (*LogsAllResponse) Reset added in v1.14.1 

func (m *LogsAllResponse) Reset()

func (*LogsAllResponse) String added in v1.14.1 

func (m *LogsAllResponse) String() string

func (*LogsAllResponse) XXX_DiscardUnknown added in v1.16.0 

func (m *LogsAllResponse) XXX_DiscardUnknown()

func (*LogsAllResponse) XXX_Marshal added in v1.16.0 

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

func (*LogsAllResponse) XXX_Merge added in v1.16.0 

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

func (*LogsAllResponse) XXX_Size added in v1.16.0 

func (m *LogsAllResponse) XXX_Size() int

func (*LogsAllResponse) XXX_Unmarshal added in v1.16.0 

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

type LogsClient added in v1.14.1 

type LogsClient interface {
	// All returns last lines of all log files.
	All(ctx context.Context, in *LogsAllRequest, opts ...grpc.CallOption) (*LogsAllResponse, error)
}

LogsClient is the client API for Logs service.

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

func NewLogsClient added in v1.14.1 

func NewLogsClient(cc *grpc.ClientConn) LogsClient

type LogsServer added in v1.14.1 

type LogsServer interface {
	// All returns last lines of all log files.
	All(context.Context, *LogsAllRequest) (*LogsAllResponse, error)
}

LogsServer is the server API for Logs service.

type MySQLAddRequest added in v1.16.0 

type MySQLAddRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Address              string   `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Port                 uint32   `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	Username             string   `protobuf:"bytes,4,opt,name=username,proto3" json:"username,omitempty"`
	Password             string   `protobuf:"bytes,5,opt,name=password,proto3" json:"password,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MySQLAddRequest) Descriptor added in v1.16.0 

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

func (*MySQLAddRequest) GetAddress added in v1.16.0 

func (m *MySQLAddRequest) GetAddress() string

func (*MySQLAddRequest) GetName added in v1.16.0 

func (m *MySQLAddRequest) GetName() string

func (*MySQLAddRequest) GetPassword added in v1.16.0 

func (m *MySQLAddRequest) GetPassword() string

func (*MySQLAddRequest) GetPort added in v1.16.0 

func (m *MySQLAddRequest) GetPort() uint32

func (*MySQLAddRequest) GetUsername added in v1.16.0 

func (m *MySQLAddRequest) GetUsername() string

func (*MySQLAddRequest) ProtoMessage added in v1.16.0 

func (*MySQLAddRequest) ProtoMessage()

func (*MySQLAddRequest) Reset added in v1.16.0 

func (m *MySQLAddRequest) Reset()

func (*MySQLAddRequest) String added in v1.16.0 

func (m *MySQLAddRequest) String() string

func (*MySQLAddRequest) XXX_DiscardUnknown added in v1.16.0 

func (m *MySQLAddRequest) XXX_DiscardUnknown()

func (*MySQLAddRequest) XXX_Marshal added in v1.16.0 

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

func (*MySQLAddRequest) XXX_Merge added in v1.16.0 

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

func (*MySQLAddRequest) XXX_Size added in v1.16.0 

func (m *MySQLAddRequest) XXX_Size() int

func (*MySQLAddRequest) XXX_Unmarshal added in v1.16.0 

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

type MySQLAddResponse added in v1.16.0 

type MySQLAddResponse struct {
	Id                   int32    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MySQLAddResponse) Descriptor added in v1.16.0 

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

func (*MySQLAddResponse) GetId added in v1.16.0 

func (m *MySQLAddResponse) GetId() int32

func (*MySQLAddResponse) ProtoMessage added in v1.16.0 

func (*MySQLAddResponse) ProtoMessage()

func (*MySQLAddResponse) Reset added in v1.16.0 

func (m *MySQLAddResponse) Reset()

func (*MySQLAddResponse) String added in v1.16.0 

func (m *MySQLAddResponse) String() string

func (*MySQLAddResponse) XXX_DiscardUnknown added in v1.16.0 

func (m *MySQLAddResponse) XXX_DiscardUnknown()

func (*MySQLAddResponse) XXX_Marshal added in v1.16.0 

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

func (*MySQLAddResponse) XXX_Merge added in v1.16.0 

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

func (*MySQLAddResponse) XXX_Size added in v1.16.0 

func (m *MySQLAddResponse) XXX_Size() int

func (*MySQLAddResponse) XXX_Unmarshal added in v1.16.0 

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

type MySQLClient added in v1.16.0 

type MySQLClient interface {
	List(ctx context.Context, in *MySQLListRequest, opts ...grpc.CallOption) (*MySQLListResponse, error)
	Add(ctx context.Context, in *MySQLAddRequest, opts ...grpc.CallOption) (*MySQLAddResponse, error)
	Remove(ctx context.Context, in *MySQLRemoveRequest, opts ...grpc.CallOption) (*MySQLRemoveResponse, error)
}

MySQLClient is the client API for MySQL service.

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

func NewMySQLClient added in v1.16.0 

func NewMySQLClient(cc *grpc.ClientConn) MySQLClient

type MySQLInstance added in v1.16.0 

type MySQLInstance struct {
	Node                 *MySQLNode    `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	Service              *MySQLService `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*MySQLInstance) Descriptor added in v1.16.0 

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

func (*MySQLInstance) GetNode added in v1.16.0 

func (m *MySQLInstance) GetNode() *MySQLNode

func (*MySQLInstance) GetService added in v1.16.0 

func (m *MySQLInstance) GetService() *MySQLService

func (*MySQLInstance) ProtoMessage added in v1.16.0 

func (*MySQLInstance) ProtoMessage()

func (*MySQLInstance) Reset added in v1.16.0 

func (m *MySQLInstance) Reset()

func (*MySQLInstance) String added in v1.16.0 

func (m *MySQLInstance) String() string

func (*MySQLInstance) XXX_DiscardUnknown added in v1.16.0 

func (m *MySQLInstance) XXX_DiscardUnknown()

func (*MySQLInstance) XXX_Marshal added in v1.16.0 

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

func (*MySQLInstance) XXX_Merge added in v1.16.0 

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

func (*MySQLInstance) XXX_Size added in v1.16.0 

func (m *MySQLInstance) XXX_Size() int

func (*MySQLInstance) XXX_Unmarshal added in v1.16.0 

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

type MySQLListRequest added in v1.16.0 

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

func (*MySQLListRequest) Descriptor added in v1.16.0 

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

func (*MySQLListRequest) ProtoMessage added in v1.16.0 

func (*MySQLListRequest) ProtoMessage()

func (*MySQLListRequest) Reset added in v1.16.0 

func (m *MySQLListRequest) Reset()

func (*MySQLListRequest) String added in v1.16.0 

func (m *MySQLListRequest) String() string

func (*MySQLListRequest) XXX_DiscardUnknown added in v1.16.0 

func (m *MySQLListRequest) XXX_DiscardUnknown()

func (*MySQLListRequest) XXX_Marshal added in v1.16.0 

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

func (*MySQLListRequest) XXX_Merge added in v1.16.0 

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

func (*MySQLListRequest) XXX_Size added in v1.16.0 

func (m *MySQLListRequest) XXX_Size() int

func (*MySQLListRequest) XXX_Unmarshal added in v1.16.0 

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

type MySQLListResponse added in v1.16.0 

type MySQLListResponse struct {
	Instances            []*MySQLInstance `protobuf:"bytes,1,rep,name=instances,proto3" json:"instances,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*MySQLListResponse) Descriptor added in v1.16.0 

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

func (*MySQLListResponse) GetInstances added in v1.16.0 

func (m *MySQLListResponse) GetInstances() []*MySQLInstance

func (*MySQLListResponse) ProtoMessage added in v1.16.0 

func (*MySQLListResponse) ProtoMessage()

func (*MySQLListResponse) Reset added in v1.16.0 

func (m *MySQLListResponse) Reset()

func (*MySQLListResponse) String added in v1.16.0 

func (m *MySQLListResponse) String() string

func (*MySQLListResponse) XXX_DiscardUnknown added in v1.16.0 

func (m *MySQLListResponse) XXX_DiscardUnknown()

func (*MySQLListResponse) XXX_Marshal added in v1.16.0 

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

func (*MySQLListResponse) XXX_Merge added in v1.16.0 

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

func (*MySQLListResponse) XXX_Size added in v1.16.0 

func (m *MySQLListResponse) XXX_Size() int

func (*MySQLListResponse) XXX_Unmarshal added in v1.16.0 

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

type MySQLNode added in v1.16.0 

type MySQLNode struct {
	Name                 string   `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MySQLNode) Descriptor added in v1.16.0 

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

func (*MySQLNode) GetName added in v1.16.0 

func (m *MySQLNode) GetName() string

func (*MySQLNode) ProtoMessage added in v1.16.0 

func (*MySQLNode) ProtoMessage()

func (*MySQLNode) Reset added in v1.16.0 

func (m *MySQLNode) Reset()

func (*MySQLNode) String added in v1.16.0 

func (m *MySQLNode) String() string

func (*MySQLNode) XXX_DiscardUnknown added in v1.16.0 

func (m *MySQLNode) XXX_DiscardUnknown()

func (*MySQLNode) XXX_Marshal added in v1.16.0 

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

func (*MySQLNode) XXX_Merge added in v1.16.0 

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

func (*MySQLNode) XXX_Size added in v1.16.0 

func (m *MySQLNode) XXX_Size() int

func (*MySQLNode) XXX_Unmarshal added in v1.16.0 

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

type MySQLRemoveRequest added in v1.16.0 

type MySQLRemoveRequest struct {
	Id                   int32    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MySQLRemoveRequest) Descriptor added in v1.16.0 

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

func (*MySQLRemoveRequest) GetId added in v1.16.0 

func (m *MySQLRemoveRequest) GetId() int32

func (*MySQLRemoveRequest) ProtoMessage added in v1.16.0 

func (*MySQLRemoveRequest) ProtoMessage()

func (*MySQLRemoveRequest) Reset added in v1.16.0 

func (m *MySQLRemoveRequest) Reset()

func (*MySQLRemoveRequest) String added in v1.16.0 

func (m *MySQLRemoveRequest) String() string

func (*MySQLRemoveRequest) XXX_DiscardUnknown added in v1.16.0 

func (m *MySQLRemoveRequest) XXX_DiscardUnknown()

func (*MySQLRemoveRequest) XXX_Marshal added in v1.16.0 

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

func (*MySQLRemoveRequest) XXX_Merge added in v1.16.0 

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

func (*MySQLRemoveRequest) XXX_Size added in v1.16.0 

func (m *MySQLRemoveRequest) XXX_Size() int

func (*MySQLRemoveRequest) XXX_Unmarshal added in v1.16.0 

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

type MySQLRemoveResponse added in v1.16.0 

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

func (*MySQLRemoveResponse) Descriptor added in v1.16.0 

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

func (*MySQLRemoveResponse) ProtoMessage added in v1.16.0 

func (*MySQLRemoveResponse) ProtoMessage()

func (*MySQLRemoveResponse) Reset added in v1.16.0 

func (m *MySQLRemoveResponse) Reset()

func (*MySQLRemoveResponse) String added in v1.16.0 

func (m *MySQLRemoveResponse) String() string

func (*MySQLRemoveResponse) XXX_DiscardUnknown added in v1.16.0 

func (m *MySQLRemoveResponse) XXX_DiscardUnknown()

func (*MySQLRemoveResponse) XXX_Marshal added in v1.16.0 

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

func (*MySQLRemoveResponse) XXX_Merge added in v1.16.0 

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

func (*MySQLRemoveResponse) XXX_Size added in v1.16.0 

func (m *MySQLRemoveResponse) XXX_Size() int

func (*MySQLRemoveResponse) XXX_Unmarshal added in v1.16.0 

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

type MySQLServer added in v1.16.0 

type MySQLServer interface {
	List(context.Context, *MySQLListRequest) (*MySQLListResponse, error)
	Add(context.Context, *MySQLAddRequest) (*MySQLAddResponse, error)
	Remove(context.Context, *MySQLRemoveRequest) (*MySQLRemoveResponse, error)
}

MySQLServer is the server API for MySQL service.

type MySQLService added in v1.16.0 

type MySQLService struct {
	Address              string   `protobuf:"bytes,4,opt,name=address,proto3" json:"address,omitempty"`
	Port                 uint32   `protobuf:"varint,5,opt,name=port,proto3" json:"port,omitempty"`
	Engine               string   `protobuf:"bytes,6,opt,name=engine,proto3" json:"engine,omitempty"`
	EngineVersion        string   `protobuf:"bytes,7,opt,name=engine_version,json=engineVersion,proto3" json:"engine_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MySQLService) Descriptor added in v1.16.0 

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

func (*MySQLService) GetAddress added in v1.16.0 

func (m *MySQLService) GetAddress() string

func (*MySQLService) GetEngine added in v1.16.0 

func (m *MySQLService) GetEngine() string

func (*MySQLService) GetEngineVersion added in v1.16.0 

func (m *MySQLService) GetEngineVersion() string

func (*MySQLService) GetPort added in v1.16.0 

func (m *MySQLService) GetPort() uint32

func (*MySQLService) ProtoMessage added in v1.16.0 

func (*MySQLService) ProtoMessage()

func (*MySQLService) Reset added in v1.16.0 

func (m *MySQLService) Reset()

func (*MySQLService) String added in v1.16.0 

func (m *MySQLService) String() string

func (*MySQLService) XXX_DiscardUnknown added in v1.16.0 

func (m *MySQLService) XXX_DiscardUnknown()

func (*MySQLService) XXX_Marshal added in v1.16.0 

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

func (*MySQLService) XXX_Merge added in v1.16.0 

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

func (*MySQLService) XXX_Size added in v1.16.0 

func (m *MySQLService) XXX_Size() int

func (*MySQLService) XXX_Unmarshal added in v1.16.0 

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

type PostgreSQLAddRequest added in v1.16.0 

type PostgreSQLAddRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Address              string   `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Port                 uint32   `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	Username             string   `protobuf:"bytes,4,opt,name=username,proto3" json:"username,omitempty"`
	Password             string   `protobuf:"bytes,5,opt,name=password,proto3" json:"password,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PostgreSQLAddRequest) Descriptor added in v1.16.0 

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

func (*PostgreSQLAddRequest) GetAddress added in v1.16.0 

func (m *PostgreSQLAddRequest) GetAddress() string

func (*PostgreSQLAddRequest) GetName added in v1.16.0 

func (m *PostgreSQLAddRequest) GetName() string

func (*PostgreSQLAddRequest) GetPassword added in v1.16.0 

func (m *PostgreSQLAddRequest) GetPassword() string

func (*PostgreSQLAddRequest) GetPort added in v1.16.0 

func (m *PostgreSQLAddRequest) GetPort() uint32

func (*PostgreSQLAddRequest) GetUsername added in v1.16.0 

func (m *PostgreSQLAddRequest) GetUsername() string

func (*PostgreSQLAddRequest) ProtoMessage added in v1.16.0 

func (*PostgreSQLAddRequest) ProtoMessage()

func (*PostgreSQLAddRequest) Reset added in v1.16.0 

func (m *PostgreSQLAddRequest) Reset()

func (*PostgreSQLAddRequest) String added in v1.16.0 

func (m *PostgreSQLAddRequest) String() string

func (*PostgreSQLAddRequest) XXX_DiscardUnknown added in v1.16.0 

func (m *PostgreSQLAddRequest) XXX_DiscardUnknown()

func (*PostgreSQLAddRequest) XXX_Marshal added in v1.16.0 

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

func (*PostgreSQLAddRequest) XXX_Merge added in v1.16.0 

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

func (*PostgreSQLAddRequest) XXX_Size added in v1.16.0 

func (m *PostgreSQLAddRequest) XXX_Size() int

func (*PostgreSQLAddRequest) XXX_Unmarshal added in v1.16.0 

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

type PostgreSQLAddResponse added in v1.16.0 

type PostgreSQLAddResponse struct {
	Id                   int32    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PostgreSQLAddResponse) Descriptor added in v1.16.0 

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

func (*PostgreSQLAddResponse) GetId added in v1.16.0 

func (m *PostgreSQLAddResponse) GetId() int32

func (*PostgreSQLAddResponse) ProtoMessage added in v1.16.0 

func (*PostgreSQLAddResponse) ProtoMessage()

func (*PostgreSQLAddResponse) Reset added in v1.16.0 

func (m *PostgreSQLAddResponse) Reset()

func (*PostgreSQLAddResponse) String added in v1.16.0 

func (m *PostgreSQLAddResponse) String() string

func (*PostgreSQLAddResponse) XXX_DiscardUnknown added in v1.16.0 

func (m *PostgreSQLAddResponse) XXX_DiscardUnknown()

func (*PostgreSQLAddResponse) XXX_Marshal added in v1.16.0 

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

func (*PostgreSQLAddResponse) XXX_Merge added in v1.16.0 

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

func (*PostgreSQLAddResponse) XXX_Size added in v1.16.0 

func (m *PostgreSQLAddResponse) XXX_Size() int

func (*PostgreSQLAddResponse) XXX_Unmarshal added in v1.16.0 

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

type PostgreSQLClient added in v1.16.0 

type PostgreSQLClient interface {
	List(ctx context.Context, in *PostgreSQLListRequest, opts ...grpc.CallOption) (*PostgreSQLListResponse, error)
	Add(ctx context.Context, in *PostgreSQLAddRequest, opts ...grpc.CallOption) (*PostgreSQLAddResponse, error)
	Remove(ctx context.Context, in *PostgreSQLRemoveRequest, opts ...grpc.CallOption) (*PostgreSQLRemoveResponse, error)
}

PostgreSQLClient is the client API for PostgreSQL service.

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

func NewPostgreSQLClient added in v1.16.0 

func NewPostgreSQLClient(cc *grpc.ClientConn) PostgreSQLClient

type PostgreSQLInstance added in v1.16.0 

type PostgreSQLInstance struct {
	Node                 *PostgreSQLNode    `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	Service              *PostgreSQLService `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*PostgreSQLInstance) Descriptor added in v1.16.0 

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

func (*PostgreSQLInstance) GetNode added in v1.16.0 

func (m *PostgreSQLInstance) GetNode() *PostgreSQLNode

func (*PostgreSQLInstance) GetService added in v1.16.0 

func (m *PostgreSQLInstance) GetService() *PostgreSQLService

func (*PostgreSQLInstance) ProtoMessage added in v1.16.0 

func (*PostgreSQLInstance) ProtoMessage()

func (*PostgreSQLInstance) Reset added in v1.16.0 

func (m *PostgreSQLInstance) Reset()

func (*PostgreSQLInstance) String added in v1.16.0 

func (m *PostgreSQLInstance) String() string

func (*PostgreSQLInstance) XXX_DiscardUnknown added in v1.16.0 

func (m *PostgreSQLInstance) XXX_DiscardUnknown()

func (*PostgreSQLInstance) XXX_Marshal added in v1.16.0 

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

func (*PostgreSQLInstance) XXX_Merge added in v1.16.0 

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

func (*PostgreSQLInstance) XXX_Size added in v1.16.0 

func (m *PostgreSQLInstance) XXX_Size() int

func (*PostgreSQLInstance) XXX_Unmarshal added in v1.16.0 

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

type PostgreSQLListRequest added in v1.16.0 

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

func (*PostgreSQLListRequest) Descriptor added in v1.16.0 

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

func (*PostgreSQLListRequest) ProtoMessage added in v1.16.0 

func (*PostgreSQLListRequest) ProtoMessage()

func (*PostgreSQLListRequest) Reset added in v1.16.0 

func (m *PostgreSQLListRequest) Reset()

func (*PostgreSQLListRequest) String added in v1.16.0 

func (m *PostgreSQLListRequest) String() string

func (*PostgreSQLListRequest) XXX_DiscardUnknown added in v1.16.0 

func (m *PostgreSQLListRequest) XXX_DiscardUnknown()

func (*PostgreSQLListRequest) XXX_Marshal added in v1.16.0 

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

func (*PostgreSQLListRequest) XXX_Merge added in v1.16.0 

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

func (*PostgreSQLListRequest) XXX_Size added in v1.16.0 

func (m *PostgreSQLListRequest) XXX_Size() int

func (*PostgreSQLListRequest) XXX_Unmarshal added in v1.16.0 

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

type PostgreSQLListResponse added in v1.16.0 

type PostgreSQLListResponse struct {
	Instances            []*PostgreSQLInstance `protobuf:"bytes,1,rep,name=instances,proto3" json:"instances,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*PostgreSQLListResponse) Descriptor added in v1.16.0 

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

func (*PostgreSQLListResponse) GetInstances added in v1.16.0 

func (m *PostgreSQLListResponse) GetInstances() []*PostgreSQLInstance

func (*PostgreSQLListResponse) ProtoMessage added in v1.16.0 

func (*PostgreSQLListResponse) ProtoMessage()

func (*PostgreSQLListResponse) Reset added in v1.16.0 

func (m *PostgreSQLListResponse) Reset()

func (*PostgreSQLListResponse) String added in v1.16.0 

func (m *PostgreSQLListResponse) String() string

func (*PostgreSQLListResponse) XXX_DiscardUnknown added in v1.16.0 

func (m *PostgreSQLListResponse) XXX_DiscardUnknown()

func (*PostgreSQLListResponse) XXX_Marshal added in v1.16.0 

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

func (*PostgreSQLListResponse) XXX_Merge added in v1.16.0 

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

func (*PostgreSQLListResponse) XXX_Size added in v1.16.0 

func (m *PostgreSQLListResponse) XXX_Size() int

func (*PostgreSQLListResponse) XXX_Unmarshal added in v1.16.0 

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

type PostgreSQLNode added in v1.16.0 

type PostgreSQLNode struct {
	Name                 string   `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PostgreSQLNode) Descriptor added in v1.16.0 

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

func (*PostgreSQLNode) GetName added in v1.16.0 

func (m *PostgreSQLNode) GetName() string

func (*PostgreSQLNode) ProtoMessage added in v1.16.0 

func (*PostgreSQLNode) ProtoMessage()

func (*PostgreSQLNode) Reset added in v1.16.0 

func (m *PostgreSQLNode) Reset()

func (*PostgreSQLNode) String added in v1.16.0 

func (m *PostgreSQLNode) String() string

func (*PostgreSQLNode) XXX_DiscardUnknown added in v1.16.0 

func (m *PostgreSQLNode) XXX_DiscardUnknown()

func (*PostgreSQLNode) XXX_Marshal added in v1.16.0 

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

func (*PostgreSQLNode) XXX_Merge added in v1.16.0 

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

func (*PostgreSQLNode) XXX_Size added in v1.16.0 

func (m *PostgreSQLNode) XXX_Size() int

func (*PostgreSQLNode) XXX_Unmarshal added in v1.16.0 

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

type PostgreSQLRemoveRequest added in v1.16.0 

type PostgreSQLRemoveRequest struct {
	Id                   int32    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PostgreSQLRemoveRequest) Descriptor added in v1.16.0 

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

func (*PostgreSQLRemoveRequest) GetId added in v1.16.0 

func (m *PostgreSQLRemoveRequest) GetId() int32

func (*PostgreSQLRemoveRequest) ProtoMessage added in v1.16.0 

func (*PostgreSQLRemoveRequest) ProtoMessage()

func (*PostgreSQLRemoveRequest) Reset added in v1.16.0 

func (m *PostgreSQLRemoveRequest) Reset()

func (*PostgreSQLRemoveRequest) String added in v1.16.0 

func (m *PostgreSQLRemoveRequest) String() string

func (*PostgreSQLRemoveRequest) XXX_DiscardUnknown added in v1.16.0 

func (m *PostgreSQLRemoveRequest) XXX_DiscardUnknown()

func (*PostgreSQLRemoveRequest) XXX_Marshal added in v1.16.0 

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

func (*PostgreSQLRemoveRequest) XXX_Merge added in v1.16.0 

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

func (*PostgreSQLRemoveRequest) XXX_Size added in v1.16.0 

func (m *PostgreSQLRemoveRequest) XXX_Size() int

func (*PostgreSQLRemoveRequest) XXX_Unmarshal added in v1.16.0 

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

type PostgreSQLRemoveResponse added in v1.16.0 

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

func (*PostgreSQLRemoveResponse) Descriptor added in v1.16.0 

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

func (*PostgreSQLRemoveResponse) ProtoMessage added in v1.16.0 

func (*PostgreSQLRemoveResponse) ProtoMessage()

func (*PostgreSQLRemoveResponse) Reset added in v1.16.0 

func (m *PostgreSQLRemoveResponse) Reset()

func (*PostgreSQLRemoveResponse) String added in v1.16.0 

func (m *PostgreSQLRemoveResponse) String() string

func (*PostgreSQLRemoveResponse) XXX_DiscardUnknown added in v1.16.0 

func (m *PostgreSQLRemoveResponse) XXX_DiscardUnknown()

func (*PostgreSQLRemoveResponse) XXX_Marshal added in v1.16.0 

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

func (*PostgreSQLRemoveResponse) XXX_Merge added in v1.16.0 

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

func (*PostgreSQLRemoveResponse) XXX_Size added in v1.16.0 

func (m *PostgreSQLRemoveResponse) XXX_Size() int

func (*PostgreSQLRemoveResponse) XXX_Unmarshal added in v1.16.0 

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

type PostgreSQLServer added in v1.16.0 

type PostgreSQLServer interface {
	List(context.Context, *PostgreSQLListRequest) (*PostgreSQLListResponse, error)
	Add(context.Context, *PostgreSQLAddRequest) (*PostgreSQLAddResponse, error)
	Remove(context.Context, *PostgreSQLRemoveRequest) (*PostgreSQLRemoveResponse, error)
}

PostgreSQLServer is the server API for PostgreSQL service.

type PostgreSQLService added in v1.16.0 

type PostgreSQLService struct {
	Address              string   `protobuf:"bytes,4,opt,name=address,proto3" json:"address,omitempty"`
	Port                 uint32   `protobuf:"varint,5,opt,name=port,proto3" json:"port,omitempty"`
	Engine               string   `protobuf:"bytes,6,opt,name=engine,proto3" json:"engine,omitempty"`
	EngineVersion        string   `protobuf:"bytes,7,opt,name=engine_version,json=engineVersion,proto3" json:"engine_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PostgreSQLService) Descriptor added in v1.16.0 

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

func (*PostgreSQLService) GetAddress added in v1.16.0 

func (m *PostgreSQLService) GetAddress() string

func (*PostgreSQLService) GetEngine added in v1.16.0 

func (m *PostgreSQLService) GetEngine() string

func (*PostgreSQLService) GetEngineVersion added in v1.16.0 

func (m *PostgreSQLService) GetEngineVersion() string

func (*PostgreSQLService) GetPort added in v1.16.0 

func (m *PostgreSQLService) GetPort() uint32

func (*PostgreSQLService) ProtoMessage added in v1.16.0 

func (*PostgreSQLService) ProtoMessage()

func (*PostgreSQLService) Reset added in v1.16.0 

func (m *PostgreSQLService) Reset()

func (*PostgreSQLService) String added in v1.16.0 

func (m *PostgreSQLService) String() string

func (*PostgreSQLService) XXX_DiscardUnknown added in v1.16.0 

func (m *PostgreSQLService) XXX_DiscardUnknown()

func (*PostgreSQLService) XXX_Marshal added in v1.16.0 

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

func (*PostgreSQLService) XXX_Merge added in v1.16.0 

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

func (*PostgreSQLService) XXX_Size added in v1.16.0 

func (m *PostgreSQLService) XXX_Size() int

func (*PostgreSQLService) XXX_Unmarshal added in v1.16.0 

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

type RDSAddRequest added in v1.5.0 

type RDSAddRequest struct {
	AwsAccessKeyId       string         `protobuf:"bytes,1,opt,name=aws_access_key_id,json=awsAccessKeyId,proto3" json:"aws_access_key_id,omitempty"`
	AwsSecretAccessKey   string         `protobuf:"bytes,2,opt,name=aws_secret_access_key,json=awsSecretAccessKey,proto3" json:"aws_secret_access_key,omitempty"`
	Id                   *RDSInstanceID `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	Username             string         `protobuf:"bytes,4,opt,name=username,proto3" json:"username,omitempty"`
	Password             string         `protobuf:"bytes,5,opt,name=password,proto3" json:"password,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*RDSAddRequest) Descriptor added in v1.5.0 

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

func (*RDSAddRequest) GetAwsAccessKeyId added in v1.5.0 

func (m *RDSAddRequest) GetAwsAccessKeyId() string

func (*RDSAddRequest) GetAwsSecretAccessKey added in v1.5.0 

func (m *RDSAddRequest) GetAwsSecretAccessKey() string

func (*RDSAddRequest) GetId added in v1.5.0 

func (m *RDSAddRequest) GetId() *RDSInstanceID

func (*RDSAddRequest) GetPassword added in v1.5.0 

func (m *RDSAddRequest) GetPassword() string

func (*RDSAddRequest) GetUsername added in v1.5.0 

func (m *RDSAddRequest) GetUsername() string

func (*RDSAddRequest) ProtoMessage added in v1.5.0 

func (*RDSAddRequest) ProtoMessage()

func (*RDSAddRequest) Reset added in v1.5.0 

func (m *RDSAddRequest) Reset()

func (*RDSAddRequest) String added in v1.5.0 

func (m *RDSAddRequest) String() string

func (*RDSAddRequest) XXX_DiscardUnknown added in v1.16.0 

func (m *RDSAddRequest) XXX_DiscardUnknown()

func (*RDSAddRequest) XXX_Marshal added in v1.16.0 

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

func (*RDSAddRequest) XXX_Merge added in v1.16.0 

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

func (*RDSAddRequest) XXX_Size added in v1.16.0 

func (m *RDSAddRequest) XXX_Size() int

func (*RDSAddRequest) XXX_Unmarshal added in v1.16.0 

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

type RDSAddResponse added in v1.5.0 

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

func (*RDSAddResponse) Descriptor added in v1.5.0 

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

func (*RDSAddResponse) ProtoMessage added in v1.5.0 

func (*RDSAddResponse) ProtoMessage()

func (*RDSAddResponse) Reset added in v1.5.0 

func (m *RDSAddResponse) Reset()

func (*RDSAddResponse) String added in v1.5.0 

func (m *RDSAddResponse) String() string

func (*RDSAddResponse) XXX_DiscardUnknown added in v1.16.0 

func (m *RDSAddResponse) XXX_DiscardUnknown()

func (*RDSAddResponse) XXX_Marshal added in v1.16.0 

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

func (*RDSAddResponse) XXX_Merge added in v1.16.0 

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

func (*RDSAddResponse) XXX_Size added in v1.16.0 

func (m *RDSAddResponse) XXX_Size() int

func (*RDSAddResponse) XXX_Unmarshal added in v1.16.0 

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

type RDSClient added in v1.5.0 

type RDSClient interface {
	Discover(ctx context.Context, in *RDSDiscoverRequest, opts ...grpc.CallOption) (*RDSDiscoverResponse, error)
	List(ctx context.Context, in *RDSListRequest, opts ...grpc.CallOption) (*RDSListResponse, error)
	Add(ctx context.Context, in *RDSAddRequest, opts ...grpc.CallOption) (*RDSAddResponse, error)
	Remove(ctx context.Context, in *RDSRemoveRequest, opts ...grpc.CallOption) (*RDSRemoveResponse, error)
}

RDSClient is the client API for RDS service.

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

func NewRDSClient added in v1.5.0 

func NewRDSClient(cc *grpc.ClientConn) RDSClient

type RDSDiscoverRequest added in v1.5.0 

type RDSDiscoverRequest struct {
	AwsAccessKeyId       string   `protobuf:"bytes,1,opt,name=aws_access_key_id,json=awsAccessKeyId,proto3" json:"aws_access_key_id,omitempty"`
	AwsSecretAccessKey   string   `protobuf:"bytes,2,opt,name=aws_secret_access_key,json=awsSecretAccessKey,proto3" json:"aws_secret_access_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RDSDiscoverRequest) Descriptor added in v1.5.0 

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

func (*RDSDiscoverRequest) GetAwsAccessKeyId added in v1.5.0 

func (m *RDSDiscoverRequest) GetAwsAccessKeyId() string

func (*RDSDiscoverRequest) GetAwsSecretAccessKey added in v1.5.0 

func (m *RDSDiscoverRequest) GetAwsSecretAccessKey() string

func (*RDSDiscoverRequest) ProtoMessage added in v1.5.0 

func (*RDSDiscoverRequest) ProtoMessage()

func (*RDSDiscoverRequest) Reset added in v1.5.0 

func (m *RDSDiscoverRequest) Reset()

func (*RDSDiscoverRequest) String added in v1.5.0 

func (m *RDSDiscoverRequest) String() string

func (*RDSDiscoverRequest) XXX_DiscardUnknown added in v1.16.0 

func (m *RDSDiscoverRequest) XXX_DiscardUnknown()

func (*RDSDiscoverRequest) XXX_Marshal added in v1.16.0 

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

func (*RDSDiscoverRequest) XXX_Merge added in v1.16.0 

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

func (*RDSDiscoverRequest) XXX_Size added in v1.16.0 

func (m *RDSDiscoverRequest) XXX_Size() int

func (*RDSDiscoverRequest) XXX_Unmarshal added in v1.16.0 

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

type RDSDiscoverResponse added in v1.5.0 

type RDSDiscoverResponse struct {
	Instances            []*RDSInstance `protobuf:"bytes,1,rep,name=instances,proto3" json:"instances,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*RDSDiscoverResponse) Descriptor added in v1.5.0 

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

func (*RDSDiscoverResponse) GetInstances added in v1.5.0 

func (m *RDSDiscoverResponse) GetInstances() []*RDSInstance

func (*RDSDiscoverResponse) ProtoMessage added in v1.5.0 

func (*RDSDiscoverResponse) ProtoMessage()

func (*RDSDiscoverResponse) Reset added in v1.5.0 

func (m *RDSDiscoverResponse) Reset()

func (*RDSDiscoverResponse) String added in v1.5.0 

func (m *RDSDiscoverResponse) String() string

func (*RDSDiscoverResponse) XXX_DiscardUnknown added in v1.16.0 

func (m *RDSDiscoverResponse) XXX_DiscardUnknown()

func (*RDSDiscoverResponse) XXX_Marshal added in v1.16.0 

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

func (*RDSDiscoverResponse) XXX_Merge added in v1.16.0 

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

func (*RDSDiscoverResponse) XXX_Size added in v1.16.0 

func (m *RDSDiscoverResponse) XXX_Size() int

func (*RDSDiscoverResponse) XXX_Unmarshal added in v1.16.0 

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

type RDSInstance added in v1.5.0 

type RDSInstance struct {
	Node                 *RDSNode    `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	Service              *RDSService `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*RDSInstance) Descriptor added in v1.5.0 

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

func (*RDSInstance) GetNode added in v1.5.0 

func (m *RDSInstance) GetNode() *RDSNode

func (*RDSInstance) GetService added in v1.5.0 

func (m *RDSInstance) GetService() *RDSService

func (*RDSInstance) ProtoMessage added in v1.5.0 

func (*RDSInstance) ProtoMessage()

func (*RDSInstance) Reset added in v1.5.0 

func (m *RDSInstance) Reset()

func (*RDSInstance) String added in v1.5.0 

func (m *RDSInstance) String() string

func (*RDSInstance) XXX_DiscardUnknown added in v1.16.0 

func (m *RDSInstance) XXX_DiscardUnknown()

func (*RDSInstance) XXX_Marshal added in v1.16.0 

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

func (*RDSInstance) XXX_Merge added in v1.16.0 

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

func (*RDSInstance) XXX_Size added in v1.16.0 

func (m *RDSInstance) XXX_Size() int

func (*RDSInstance) XXX_Unmarshal added in v1.16.0 

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

type RDSInstanceID added in v1.5.0 

type RDSInstanceID struct {
	Region               string   `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RDSInstanceID) Descriptor added in v1.5.0 

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

func (*RDSInstanceID) GetName added in v1.5.0 

func (m *RDSInstanceID) GetName() string

func (*RDSInstanceID) GetRegion added in v1.5.0 

func (m *RDSInstanceID) GetRegion() string

func (*RDSInstanceID) ProtoMessage added in v1.5.0 

func (*RDSInstanceID) ProtoMessage()

func (*RDSInstanceID) Reset added in v1.5.0 

func (m *RDSInstanceID) Reset()

func (*RDSInstanceID) String added in v1.5.0 

func (m *RDSInstanceID) String() string

func (*RDSInstanceID) XXX_DiscardUnknown added in v1.16.0 

func (m *RDSInstanceID) XXX_DiscardUnknown()

func (*RDSInstanceID) XXX_Marshal added in v1.16.0 

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

func (*RDSInstanceID) XXX_Merge added in v1.16.0 

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

func (*RDSInstanceID) XXX_Size added in v1.16.0 

func (m *RDSInstanceID) XXX_Size() int

func (*RDSInstanceID) XXX_Unmarshal added in v1.16.0 

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

type RDSListRequest added in v1.5.0 

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

func (*RDSListRequest) Descriptor added in v1.5.0 

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

func (*RDSListRequest) ProtoMessage added in v1.5.0 

func (*RDSListRequest) ProtoMessage()

func (*RDSListRequest) Reset added in v1.5.0 

func (m *RDSListRequest) Reset()

func (*RDSListRequest) String added in v1.5.0 

func (m *RDSListRequest) String() string

func (*RDSListRequest) XXX_DiscardUnknown added in v1.16.0 

func (m *RDSListRequest) XXX_DiscardUnknown()

func (*RDSListRequest) XXX_Marshal added in v1.16.0 

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

func (*RDSListRequest) XXX_Merge added in v1.16.0 

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

func (*RDSListRequest) XXX_Size added in v1.16.0 

func (m *RDSListRequest) XXX_Size() int

func (*RDSListRequest) XXX_Unmarshal added in v1.16.0 

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

type RDSListResponse added in v1.5.0 

type RDSListResponse struct {
	Instances            []*RDSInstance `protobuf:"bytes,1,rep,name=instances,proto3" json:"instances,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*RDSListResponse) Descriptor added in v1.5.0 

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

func (*RDSListResponse) GetInstances added in v1.5.0 

func (m *RDSListResponse) GetInstances() []*RDSInstance

func (*RDSListResponse) ProtoMessage added in v1.5.0 

func (*RDSListResponse) ProtoMessage()

func (*RDSListResponse) Reset added in v1.5.0 

func (m *RDSListResponse) Reset()

func (*RDSListResponse) String added in v1.5.0 

func (m *RDSListResponse) String() string

func (*RDSListResponse) XXX_DiscardUnknown added in v1.16.0 

func (m *RDSListResponse) XXX_DiscardUnknown()

func (*RDSListResponse) XXX_Marshal added in v1.16.0 

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

func (*RDSListResponse) XXX_Merge added in v1.16.0 

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

func (*RDSListResponse) XXX_Size added in v1.16.0 

func (m *RDSListResponse) XXX_Size() int

func (*RDSListResponse) XXX_Unmarshal added in v1.16.0 

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

type RDSNode added in v1.5.0 

type RDSNode struct {
	Region               string   `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
	Name                 string   `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RDSNode) Descriptor added in v1.5.0 

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

func (*RDSNode) GetName added in v1.5.0 

func (m *RDSNode) GetName() string

func (*RDSNode) GetRegion added in v1.5.0 

func (m *RDSNode) GetRegion() string

func (*RDSNode) ProtoMessage added in v1.5.0 

func (*RDSNode) ProtoMessage()

func (*RDSNode) Reset added in v1.5.0 

func (m *RDSNode) Reset()

func (*RDSNode) String added in v1.5.0 

func (m *RDSNode) String() string

func (*RDSNode) XXX_DiscardUnknown added in v1.16.0 

func (m *RDSNode) XXX_DiscardUnknown()

func (*RDSNode) XXX_Marshal added in v1.16.0 

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

func (*RDSNode) XXX_Merge added in v1.16.0 

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

func (*RDSNode) XXX_Size added in v1.16.0 

func (m *RDSNode) XXX_Size() int

func (*RDSNode) XXX_Unmarshal added in v1.16.0 

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

type RDSRemoveRequest added in v1.5.0 

type RDSRemoveRequest struct {
	Id                   *RDSInstanceID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*RDSRemoveRequest) Descriptor added in v1.5.0 

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

func (*RDSRemoveRequest) GetId added in v1.5.0 

func (m *RDSRemoveRequest) GetId() *RDSInstanceID

func (*RDSRemoveRequest) ProtoMessage added in v1.5.0 

func (*RDSRemoveRequest) ProtoMessage()

func (*RDSRemoveRequest) Reset added in v1.5.0 

func (m *RDSRemoveRequest) Reset()

func (*RDSRemoveRequest) String added in v1.5.0 

func (m *RDSRemoveRequest) String() string

func (*RDSRemoveRequest) XXX_DiscardUnknown added in v1.16.0 

func (m *RDSRemoveRequest) XXX_DiscardUnknown()

func (*RDSRemoveRequest) XXX_Marshal added in v1.16.0 

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

func (*RDSRemoveRequest) XXX_Merge added in v1.16.0 

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

func (*RDSRemoveRequest) XXX_Size added in v1.16.0 

func (m *RDSRemoveRequest) XXX_Size() int

func (*RDSRemoveRequest) XXX_Unmarshal added in v1.16.0 

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

type RDSRemoveResponse added in v1.5.0 

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

func (*RDSRemoveResponse) Descriptor added in v1.5.0 

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

func (*RDSRemoveResponse) ProtoMessage added in v1.5.0 

func (*RDSRemoveResponse) ProtoMessage()

func (*RDSRemoveResponse) Reset added in v1.5.0 

func (m *RDSRemoveResponse) Reset()

func (*RDSRemoveResponse) String added in v1.5.0 

func (m *RDSRemoveResponse) String() string

func (*RDSRemoveResponse) XXX_DiscardUnknown added in v1.16.0 

func (m *RDSRemoveResponse) XXX_DiscardUnknown()

func (*RDSRemoveResponse) XXX_Marshal added in v1.16.0 

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

func (*RDSRemoveResponse) XXX_Merge added in v1.16.0 

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

func (*RDSRemoveResponse) XXX_Size added in v1.16.0 

func (m *RDSRemoveResponse) XXX_Size() int

func (*RDSRemoveResponse) XXX_Unmarshal added in v1.16.0 

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

type RDSServer added in v1.5.0 

type RDSServer interface {
	Discover(context.Context, *RDSDiscoverRequest) (*RDSDiscoverResponse, error)
	List(context.Context, *RDSListRequest) (*RDSListResponse, error)
	Add(context.Context, *RDSAddRequest) (*RDSAddResponse, error)
	Remove(context.Context, *RDSRemoveRequest) (*RDSRemoveResponse, error)
}

RDSServer is the server API for RDS service.

type RDSService added in v1.5.0 

type RDSService struct {
	Address              string   `protobuf:"bytes,4,opt,name=address,proto3" json:"address,omitempty"`
	Port                 uint32   `protobuf:"varint,5,opt,name=port,proto3" json:"port,omitempty"`
	Engine               string   `protobuf:"bytes,6,opt,name=engine,proto3" json:"engine,omitempty"`
	EngineVersion        string   `protobuf:"bytes,7,opt,name=engine_version,json=engineVersion,proto3" json:"engine_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RDSService) Descriptor added in v1.5.0 

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

func (*RDSService) GetAddress added in v1.5.0 

func (m *RDSService) GetAddress() string

func (*RDSService) GetEngine added in v1.5.0 

func (m *RDSService) GetEngine() string

func (*RDSService) GetEngineVersion added in v1.5.0 

func (m *RDSService) GetEngineVersion() string

func (*RDSService) GetPort added in v1.5.0 

func (m *RDSService) GetPort() uint32

func (*RDSService) ProtoMessage added in v1.5.0 

func (*RDSService) ProtoMessage()

func (*RDSService) Reset added in v1.5.0 

func (m *RDSService) Reset()

func (*RDSService) String added in v1.5.0 

func (m *RDSService) String() string

func (*RDSService) XXX_DiscardUnknown added in v1.16.0 

func (m *RDSService) XXX_DiscardUnknown()

func (*RDSService) XXX_Marshal added in v1.16.0 

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

func (*RDSService) XXX_Merge added in v1.16.0 

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

func (*RDSService) XXX_Size added in v1.16.0 

func (m *RDSService) XXX_Size() int

func (*RDSService) XXX_Unmarshal added in v1.16.0 

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

type RemoteClient added in v1.16.0 

type RemoteClient interface {
	List(ctx context.Context, in *RemoteListRequest, opts ...grpc.CallOption) (*RemoteListResponse, error)
}

RemoteClient is the client API for Remote service.

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

func NewRemoteClient added in v1.16.0 

func NewRemoteClient(cc *grpc.ClientConn) RemoteClient

type RemoteInstance added in v1.16.0 

type RemoteInstance struct {
	Node                 *RemoteNode    `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	Service              *RemoteService `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*RemoteInstance) Descriptor added in v1.16.0 

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

func (*RemoteInstance) GetNode added in v1.16.0 

func (m *RemoteInstance) GetNode() *RemoteNode

func (*RemoteInstance) GetService added in v1.16.0 

func (m *RemoteInstance) GetService() *RemoteService

func (*RemoteInstance) ProtoMessage added in v1.16.0 

func (*RemoteInstance) ProtoMessage()

func (*RemoteInstance) Reset added in v1.16.0 

func (m *RemoteInstance) Reset()

func (*RemoteInstance) String added in v1.16.0 

func (m *RemoteInstance) String() string

func (*RemoteInstance) XXX_DiscardUnknown added in v1.16.0 

func (m *RemoteInstance) XXX_DiscardUnknown()

func (*RemoteInstance) XXX_Marshal added in v1.16.0 

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

func (*RemoteInstance) XXX_Merge added in v1.16.0 

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

func (*RemoteInstance) XXX_Size added in v1.16.0 

func (m *RemoteInstance) XXX_Size() int

func (*RemoteInstance) XXX_Unmarshal added in v1.16.0 

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

type RemoteListRequest added in v1.16.0 

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

func (*RemoteListRequest) Descriptor added in v1.16.0 

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

func (*RemoteListRequest) ProtoMessage added in v1.16.0 

func (*RemoteListRequest) ProtoMessage()

func (*RemoteListRequest) Reset added in v1.16.0 

func (m *RemoteListRequest) Reset()

func (*RemoteListRequest) String added in v1.16.0 

func (m *RemoteListRequest) String() string

func (*RemoteListRequest) XXX_DiscardUnknown added in v1.16.0 

func (m *RemoteListRequest) XXX_DiscardUnknown()

func (*RemoteListRequest) XXX_Marshal added in v1.16.0 

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

func (*RemoteListRequest) XXX_Merge added in v1.16.0 

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

func (*RemoteListRequest) XXX_Size added in v1.16.0 

func (m *RemoteListRequest) XXX_Size() int

func (*RemoteListRequest) XXX_Unmarshal added in v1.16.0 

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

type RemoteListResponse added in v1.16.0 

type RemoteListResponse struct {
	Instances            []*RemoteInstance `protobuf:"bytes,1,rep,name=instances,proto3" json:"instances,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*RemoteListResponse) Descriptor added in v1.16.0 

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

func (*RemoteListResponse) GetInstances added in v1.16.0 

func (m *RemoteListResponse) GetInstances() []*RemoteInstance

func (*RemoteListResponse) ProtoMessage added in v1.16.0 

func (*RemoteListResponse) ProtoMessage()

func (*RemoteListResponse) Reset added in v1.16.0 

func (m *RemoteListResponse) Reset()

func (*RemoteListResponse) String added in v1.16.0 

func (m *RemoteListResponse) String() string

func (*RemoteListResponse) XXX_DiscardUnknown added in v1.16.0 

func (m *RemoteListResponse) XXX_DiscardUnknown()

func (*RemoteListResponse) XXX_Marshal added in v1.16.0 

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

func (*RemoteListResponse) XXX_Merge added in v1.16.0 

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

func (*RemoteListResponse) XXX_Size added in v1.16.0 

func (m *RemoteListResponse) XXX_Size() int

func (*RemoteListResponse) XXX_Unmarshal added in v1.16.0 

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

type RemoteNode added in v1.16.0 

type RemoteNode struct {
	Id                   int32    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string   `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Region               string   `protobuf:"bytes,4,opt,name=region,proto3" json:"region,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoteNode) Descriptor added in v1.16.0 

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

func (*RemoteNode) GetId added in v1.16.0 

func (m *RemoteNode) GetId() int32

func (*RemoteNode) GetName added in v1.16.0 

func (m *RemoteNode) GetName() string

func (*RemoteNode) GetRegion added in v1.16.0 

func (m *RemoteNode) GetRegion() string

func (*RemoteNode) ProtoMessage added in v1.16.0 

func (*RemoteNode) ProtoMessage()

func (*RemoteNode) Reset added in v1.16.0 

func (m *RemoteNode) Reset()

func (*RemoteNode) String added in v1.16.0 

func (m *RemoteNode) String() string

func (*RemoteNode) XXX_DiscardUnknown added in v1.16.0 

func (m *RemoteNode) XXX_DiscardUnknown()

func (*RemoteNode) XXX_Marshal added in v1.16.0 

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

func (*RemoteNode) XXX_Merge added in v1.16.0 

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

func (*RemoteNode) XXX_Size added in v1.16.0 

func (m *RemoteNode) XXX_Size() int

func (*RemoteNode) XXX_Unmarshal added in v1.16.0 

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

type RemoteServer added in v1.16.0 

type RemoteServer interface {
	List(context.Context, *RemoteListRequest) (*RemoteListResponse, error)
}

RemoteServer is the server API for Remote service.

type RemoteService added in v1.16.0 

type RemoteService struct {
	Type                 string   `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Address              string   `protobuf:"bytes,4,opt,name=address,proto3" json:"address,omitempty"`
	Port                 uint32   `protobuf:"varint,5,opt,name=port,proto3" json:"port,omitempty"`
	Engine               string   `protobuf:"bytes,6,opt,name=engine,proto3" json:"engine,omitempty"`
	EngineVersion        string   `protobuf:"bytes,7,opt,name=engine_version,json=engineVersion,proto3" json:"engine_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoteService) Descriptor added in v1.16.0 

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

func (*RemoteService) GetAddress added in v1.16.0 

func (m *RemoteService) GetAddress() string

func (*RemoteService) GetEngine added in v1.16.0 

func (m *RemoteService) GetEngine() string

func (*RemoteService) GetEngineVersion added in v1.16.0 

func (m *RemoteService) GetEngineVersion() string

func (*RemoteService) GetPort added in v1.16.0 

func (m *RemoteService) GetPort() uint32

func (*RemoteService) GetType added in v1.16.0 

func (m *RemoteService) GetType() string

func (*RemoteService) ProtoMessage added in v1.16.0 

func (*RemoteService) ProtoMessage()

func (*RemoteService) Reset added in v1.16.0 

func (m *RemoteService) Reset()

func (*RemoteService) String added in v1.16.0 

func (m *RemoteService) String() string

func (*RemoteService) XXX_DiscardUnknown added in v1.16.0 

func (m *RemoteService) XXX_DiscardUnknown()

func (*RemoteService) XXX_Marshal added in v1.16.0 

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

func (*RemoteService) XXX_Merge added in v1.16.0 

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

func (*RemoteService) XXX_Size added in v1.16.0 

func (m *RemoteService) XXX_Size() int

func (*RemoteService) XXX_Unmarshal added in v1.16.0 

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

type ScrapeConfig 

type ScrapeConfig struct {
	// The job name assigned to scraped metrics by default: "example-job" (required)
	JobName string `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	// How frequently to scrape targets from this job: "10s"
	ScrapeInterval string `protobuf:"bytes,2,opt,name=scrape_interval,json=scrapeInterval,proto3" json:"scrape_interval,omitempty"`
	// Per-scrape timeout when scraping this job: "5s"
	ScrapeTimeout string `protobuf:"bytes,3,opt,name=scrape_timeout,json=scrapeTimeout,proto3" json:"scrape_timeout,omitempty"`
	// The HTTP resource path on which to fetch metrics from targets: "/metrics"
	MetricsPath string `protobuf:"bytes,4,opt,name=metrics_path,json=metricsPath,proto3" json:"metrics_path,omitempty"`
	// Configures the protocol scheme used for requests: "http" or "https"
	Scheme string `protobuf:"bytes,5,opt,name=scheme,proto3" json:"scheme,omitempty"`
	// Sets the `Authorization` header on every scrape request with the configured username and password
	BasicAuth *BasicAuth `protobuf:"bytes,6,opt,name=basic_auth,json=basicAuth,proto3" json:"basic_auth,omitempty"`
	// Configures the scrape request's TLS settings
	TlsConfig *TLSConfig `protobuf:"bytes,7,opt,name=tls_config,json=tlsConfig,proto3" json:"tls_config,omitempty"`
	// List of labeled statically configured targets for this job
	StaticConfigs        []*StaticConfig `protobuf:"bytes,8,rep,name=static_configs,json=staticConfigs,proto3" json:"static_configs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ScrapeConfig) Descriptor 

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

func (*ScrapeConfig) GetBasicAuth 

func (m *ScrapeConfig) GetBasicAuth() *BasicAuth

func (*ScrapeConfig) GetJobName 

func (m *ScrapeConfig) GetJobName() string

func (*ScrapeConfig) GetMetricsPath 

func (m *ScrapeConfig) GetMetricsPath() string

func (*ScrapeConfig) GetScheme 

func (m *ScrapeConfig) GetScheme() string

func (*ScrapeConfig) GetScrapeInterval 

func (m *ScrapeConfig) GetScrapeInterval() string

func (*ScrapeConfig) GetScrapeTimeout 

func (m *ScrapeConfig) GetScrapeTimeout() string

func (*ScrapeConfig) GetStaticConfigs 

func (m *ScrapeConfig) GetStaticConfigs() []*StaticConfig

func (*ScrapeConfig) GetTlsConfig 

func (m *ScrapeConfig) GetTlsConfig() *TLSConfig

func (*ScrapeConfig) ProtoMessage 

func (*ScrapeConfig) ProtoMessage()

func (*ScrapeConfig) Reset 

func (m *ScrapeConfig) Reset()

func (*ScrapeConfig) String 

func (m *ScrapeConfig) String() string

func (*ScrapeConfig) XXX_DiscardUnknown added in v1.16.0 

func (m *ScrapeConfig) XXX_DiscardUnknown()

func (*ScrapeConfig) XXX_Marshal added in v1.16.0 

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

func (*ScrapeConfig) XXX_Merge added in v1.16.0 

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

func (*ScrapeConfig) XXX_Size added in v1.16.0 

func (m *ScrapeConfig) XXX_Size() int

func (*ScrapeConfig) XXX_Unmarshal added in v1.16.0 

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

type ScrapeConfigsClient 

type ScrapeConfigsClient interface {
	// List returns all scrape configs.
	List(ctx context.Context, in *ScrapeConfigsListRequest, opts ...grpc.CallOption) (*ScrapeConfigsListResponse, error)
	// Get returns a scrape config by job name.
	// Errors: NotFound(5) if no such scrape config is present.
	Get(ctx context.Context, in *ScrapeConfigsGetRequest, opts ...grpc.CallOption) (*ScrapeConfigsGetResponse, error)
	// Create creates a new scrape config.
	// Errors: InvalidArgument(3) if some argument is not valid,
	// AlreadyExists(6) if scrape config with that job name is already present,
	// FailedPrecondition(9) if reachability check was requested and some scrape target can't be reached.
	Create(ctx context.Context, in *ScrapeConfigsCreateRequest, opts ...grpc.CallOption) (*ScrapeConfigsCreateResponse, error)
	// Update updates existing scrape config by job name.
	// Errors: InvalidArgument(3) if some argument is not valid,
	// NotFound(5) if no such scrape config is present,
	// FailedPrecondition(9) if reachability check was requested and some scrape target can't be reached.
	Update(ctx context.Context, in *ScrapeConfigsUpdateRequest, opts ...grpc.CallOption) (*ScrapeConfigsUpdateResponse, error)
	// Delete removes existing scrape config by job name.
	// Errors: NotFound(5) if no such scrape config is present.
	Delete(ctx context.Context, in *ScrapeConfigsDeleteRequest, opts ...grpc.CallOption) (*ScrapeConfigsDeleteResponse, error)
}

ScrapeConfigsClient is the client API for ScrapeConfigs service.

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

func NewScrapeConfigsClient 

func NewScrapeConfigsClient(cc *grpc.ClientConn) ScrapeConfigsClient

type ScrapeConfigsCreateRequest 

type ScrapeConfigsCreateRequest struct {
	ScrapeConfig *ScrapeConfig `protobuf:"bytes,1,opt,name=scrape_config,json=scrapeConfig,proto3" json:"scrape_config,omitempty"`
	// Check that added targets can be scraped from PMM Server
	CheckReachability    bool     `protobuf:"varint,2,opt,name=check_reachability,json=checkReachability,proto3" json:"check_reachability,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ScrapeConfigsCreateRequest) Descriptor 

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

func (*ScrapeConfigsCreateRequest) GetCheckReachability added in v1.7.0 

func (m *ScrapeConfigsCreateRequest) GetCheckReachability() bool

func (*ScrapeConfigsCreateRequest) GetScrapeConfig 

func (m *ScrapeConfigsCreateRequest) GetScrapeConfig() *ScrapeConfig

func (*ScrapeConfigsCreateRequest) ProtoMessage 

func (*ScrapeConfigsCreateRequest) ProtoMessage()

func (*ScrapeConfigsCreateRequest) Reset 

func (m *ScrapeConfigsCreateRequest) Reset()

func (*ScrapeConfigsCreateRequest) String 

func (m *ScrapeConfigsCreateRequest) String() string

func (*ScrapeConfigsCreateRequest) XXX_DiscardUnknown added in v1.16.0 

func (m *ScrapeConfigsCreateRequest) XXX_DiscardUnknown()

func (*ScrapeConfigsCreateRequest) XXX_Marshal added in v1.16.0 

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

func (*ScrapeConfigsCreateRequest) XXX_Merge added in v1.16.0 

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

func (*ScrapeConfigsCreateRequest) XXX_Size added in v1.16.0 

func (m *ScrapeConfigsCreateRequest) XXX_Size() int

func (*ScrapeConfigsCreateRequest) XXX_Unmarshal added in v1.16.0 

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

type ScrapeConfigsCreateResponse 

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

func (*ScrapeConfigsCreateResponse) Descriptor 

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

func (*ScrapeConfigsCreateResponse) ProtoMessage 

func (*ScrapeConfigsCreateResponse) ProtoMessage()

func (*ScrapeConfigsCreateResponse) Reset 

func (m *ScrapeConfigsCreateResponse) Reset()

func (*ScrapeConfigsCreateResponse) String 

func (m *ScrapeConfigsCreateResponse) String() string

func (*ScrapeConfigsCreateResponse) XXX_DiscardUnknown added in v1.16.0 

func (m *ScrapeConfigsCreateResponse) XXX_DiscardUnknown()

func (*ScrapeConfigsCreateResponse) XXX_Marshal added in v1.16.0 

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

func (*ScrapeConfigsCreateResponse) XXX_Merge added in v1.16.0 

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

func (*ScrapeConfigsCreateResponse) XXX_Size added in v1.16.0 

func (m *ScrapeConfigsCreateResponse) XXX_Size() int

func (*ScrapeConfigsCreateResponse) XXX_Unmarshal added in v1.16.0 

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

type ScrapeConfigsDeleteRequest 

type ScrapeConfigsDeleteRequest struct {
	JobName              string   `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ScrapeConfigsDeleteRequest) Descriptor 

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

func (*ScrapeConfigsDeleteRequest) GetJobName 

func (m *ScrapeConfigsDeleteRequest) GetJobName() string

func (*ScrapeConfigsDeleteRequest) ProtoMessage 

func (*ScrapeConfigsDeleteRequest) ProtoMessage()

func (*ScrapeConfigsDeleteRequest) Reset 

func (m *ScrapeConfigsDeleteRequest) Reset()

func (*ScrapeConfigsDeleteRequest) String 

func (m *ScrapeConfigsDeleteRequest) String() string

func (*ScrapeConfigsDeleteRequest) XXX_DiscardUnknown added in v1.16.0 

func (m *ScrapeConfigsDeleteRequest) XXX_DiscardUnknown()

func (*ScrapeConfigsDeleteRequest) XXX_Marshal added in v1.16.0 

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

func (*ScrapeConfigsDeleteRequest) XXX_Merge added in v1.16.0 

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

func (*ScrapeConfigsDeleteRequest) XXX_Size added in v1.16.0 

func (m *ScrapeConfigsDeleteRequest) XXX_Size() int

func (*ScrapeConfigsDeleteRequest) XXX_Unmarshal added in v1.16.0 

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

type ScrapeConfigsDeleteResponse 

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

func (*ScrapeConfigsDeleteResponse) Descriptor 

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

func (*ScrapeConfigsDeleteResponse) ProtoMessage 

func (*ScrapeConfigsDeleteResponse) ProtoMessage()

func (*ScrapeConfigsDeleteResponse) Reset 

func (m *ScrapeConfigsDeleteResponse) Reset()

func (*ScrapeConfigsDeleteResponse) String 

func (m *ScrapeConfigsDeleteResponse) String() string

func (*ScrapeConfigsDeleteResponse) XXX_DiscardUnknown added in v1.16.0 

func (m *ScrapeConfigsDeleteResponse) XXX_DiscardUnknown()

func (*ScrapeConfigsDeleteResponse) XXX_Marshal added in v1.16.0 

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

func (*ScrapeConfigsDeleteResponse) XXX_Merge added in v1.16.0 

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

func (*ScrapeConfigsDeleteResponse) XXX_Size added in v1.16.0 

func (m *ScrapeConfigsDeleteResponse) XXX_Size() int

func (*ScrapeConfigsDeleteResponse) XXX_Unmarshal added in v1.16.0 

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

type ScrapeConfigsGetRequest 

type ScrapeConfigsGetRequest struct {
	JobName              string   `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ScrapeConfigsGetRequest) Descriptor 

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

func (*ScrapeConfigsGetRequest) GetJobName 

func (m *ScrapeConfigsGetRequest) GetJobName() string

func (*ScrapeConfigsGetRequest) ProtoMessage 

func (*ScrapeConfigsGetRequest) ProtoMessage()

func (*ScrapeConfigsGetRequest) Reset 

func (m *ScrapeConfigsGetRequest) Reset()

func (*ScrapeConfigsGetRequest) String 

func (m *ScrapeConfigsGetRequest) String() string

func (*ScrapeConfigsGetRequest) XXX_DiscardUnknown added in v1.16.0 

func (m *ScrapeConfigsGetRequest) XXX_DiscardUnknown()

func (*ScrapeConfigsGetRequest) XXX_Marshal added in v1.16.0 

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

func (*ScrapeConfigsGetRequest) XXX_Merge added in v1.16.0 

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

func (*ScrapeConfigsGetRequest) XXX_Size added in v1.16.0 

func (m *ScrapeConfigsGetRequest) XXX_Size() int

func (*ScrapeConfigsGetRequest) XXX_Unmarshal added in v1.16.0 

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

type ScrapeConfigsGetResponse 

type ScrapeConfigsGetResponse struct {
	ScrapeConfig *ScrapeConfig `protobuf:"bytes,1,opt,name=scrape_config,json=scrapeConfig,proto3" json:"scrape_config,omitempty"`
	// Scrape targets health for this scrape job
	ScrapeTargetsHealth  []*ScrapeTargetHealth `protobuf:"bytes,2,rep,name=scrape_targets_health,json=scrapeTargetsHealth,proto3" json:"scrape_targets_health,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ScrapeConfigsGetResponse) Descriptor 

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

func (*ScrapeConfigsGetResponse) GetScrapeConfig 

func (m *ScrapeConfigsGetResponse) GetScrapeConfig() *ScrapeConfig

func (*ScrapeConfigsGetResponse) GetScrapeTargetsHealth added in v1.7.0 

func (m *ScrapeConfigsGetResponse) GetScrapeTargetsHealth() []*ScrapeTargetHealth

func (*ScrapeConfigsGetResponse) ProtoMessage 

func (*ScrapeConfigsGetResponse) ProtoMessage()

func (*ScrapeConfigsGetResponse) Reset 

func (m *ScrapeConfigsGetResponse) Reset()

func (*ScrapeConfigsGetResponse) String 

func (m *ScrapeConfigsGetResponse) String() string

func (*ScrapeConfigsGetResponse) XXX_DiscardUnknown added in v1.16.0 

func (m *ScrapeConfigsGetResponse) XXX_DiscardUnknown()

func (*ScrapeConfigsGetResponse) XXX_Marshal added in v1.16.0 

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

func (*ScrapeConfigsGetResponse) XXX_Merge added in v1.16.0 

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

func (*ScrapeConfigsGetResponse) XXX_Size added in v1.16.0 

func (m *ScrapeConfigsGetResponse) XXX_Size() int

func (*ScrapeConfigsGetResponse) XXX_Unmarshal added in v1.16.0 

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

type ScrapeConfigsListRequest 

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

func (*ScrapeConfigsListRequest) Descriptor 

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

func (*ScrapeConfigsListRequest) ProtoMessage 

func (*ScrapeConfigsListRequest) ProtoMessage()

func (*ScrapeConfigsListRequest) Reset 

func (m *ScrapeConfigsListRequest) Reset()

func (*ScrapeConfigsListRequest) String 

func (m *ScrapeConfigsListRequest) String() string

func (*ScrapeConfigsListRequest) XXX_DiscardUnknown added in v1.16.0 

func (m *ScrapeConfigsListRequest) XXX_DiscardUnknown()

func (*ScrapeConfigsListRequest) XXX_Marshal added in v1.16.0 

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

func (*ScrapeConfigsListRequest) XXX_Merge added in v1.16.0 

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

func (*ScrapeConfigsListRequest) XXX_Size added in v1.16.0 

func (m *ScrapeConfigsListRequest) XXX_Size() int

func (*ScrapeConfigsListRequest) XXX_Unmarshal added in v1.16.0 

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

type ScrapeConfigsListResponse 

type ScrapeConfigsListResponse struct {
	ScrapeConfigs []*ScrapeConfig `protobuf:"bytes,1,rep,name=scrape_configs,json=scrapeConfigs,proto3" json:"scrape_configs,omitempty"`
	// Scrape targets health for all managed scrape jobs
	ScrapeTargetsHealth  []*ScrapeTargetHealth `protobuf:"bytes,2,rep,name=scrape_targets_health,json=scrapeTargetsHealth,proto3" json:"scrape_targets_health,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ScrapeConfigsListResponse) Descriptor 

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

func (*ScrapeConfigsListResponse) GetScrapeConfigs 

func (m *ScrapeConfigsListResponse) GetScrapeConfigs() []*ScrapeConfig

func (*ScrapeConfigsListResponse) GetScrapeTargetsHealth added in v1.7.0 

func (m *ScrapeConfigsListResponse) GetScrapeTargetsHealth() []*ScrapeTargetHealth

func (*ScrapeConfigsListResponse) ProtoMessage 

func (*ScrapeConfigsListResponse) ProtoMessage()

func (*ScrapeConfigsListResponse) Reset 

func (m *ScrapeConfigsListResponse) Reset()

func (*ScrapeConfigsListResponse) String 

func (m *ScrapeConfigsListResponse) String() string

func (*ScrapeConfigsListResponse) XXX_DiscardUnknown added in v1.16.0 

func (m *ScrapeConfigsListResponse) XXX_DiscardUnknown()

func (*ScrapeConfigsListResponse) XXX_Marshal added in v1.16.0 

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

func (*ScrapeConfigsListResponse) XXX_Merge added in v1.16.0 

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

func (*ScrapeConfigsListResponse) XXX_Size added in v1.16.0 

func (m *ScrapeConfigsListResponse) XXX_Size() int

func (*ScrapeConfigsListResponse) XXX_Unmarshal added in v1.16.0 

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

type ScrapeConfigsServer 

type ScrapeConfigsServer interface {
	// List returns all scrape configs.
	List(context.Context, *ScrapeConfigsListRequest) (*ScrapeConfigsListResponse, error)
	// Get returns a scrape config by job name.
	// Errors: NotFound(5) if no such scrape config is present.
	Get(context.Context, *ScrapeConfigsGetRequest) (*ScrapeConfigsGetResponse, error)
	// Create creates a new scrape config.
	// Errors: InvalidArgument(3) if some argument is not valid,
	// AlreadyExists(6) if scrape config with that job name is already present,
	// FailedPrecondition(9) if reachability check was requested and some scrape target can't be reached.
	Create(context.Context, *ScrapeConfigsCreateRequest) (*ScrapeConfigsCreateResponse, error)
	// Update updates existing scrape config by job name.
	// Errors: InvalidArgument(3) if some argument is not valid,
	// NotFound(5) if no such scrape config is present,
	// FailedPrecondition(9) if reachability check was requested and some scrape target can't be reached.
	Update(context.Context, *ScrapeConfigsUpdateRequest) (*ScrapeConfigsUpdateResponse, error)
	// Delete removes existing scrape config by job name.
	// Errors: NotFound(5) if no such scrape config is present.
	Delete(context.Context, *ScrapeConfigsDeleteRequest) (*ScrapeConfigsDeleteResponse, error)
}

ScrapeConfigsServer is the server API for ScrapeConfigs service.

type ScrapeConfigsUpdateRequest added in v1.7.0 

type ScrapeConfigsUpdateRequest struct {
	ScrapeConfig *ScrapeConfig `protobuf:"bytes,1,opt,name=scrape_config,json=scrapeConfig,proto3" json:"scrape_config,omitempty"`
	// Check that added targets can be scraped from PMM Server
	CheckReachability    bool     `protobuf:"varint,2,opt,name=check_reachability,json=checkReachability,proto3" json:"check_reachability,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ScrapeConfigsUpdateRequest) Descriptor added in v1.7.0 

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

func (*ScrapeConfigsUpdateRequest) GetCheckReachability added in v1.7.0 

func (m *ScrapeConfigsUpdateRequest) GetCheckReachability() bool

func (*ScrapeConfigsUpdateRequest) GetScrapeConfig added in v1.7.0 

func (m *ScrapeConfigsUpdateRequest) GetScrapeConfig() *ScrapeConfig

func (*ScrapeConfigsUpdateRequest) ProtoMessage added in v1.7.0 

func (*ScrapeConfigsUpdateRequest) ProtoMessage()

func (*ScrapeConfigsUpdateRequest) Reset added in v1.7.0 

func (m *ScrapeConfigsUpdateRequest) Reset()

func (*ScrapeConfigsUpdateRequest) String added in v1.7.0 

func (m *ScrapeConfigsUpdateRequest) String() string

func (*ScrapeConfigsUpdateRequest) XXX_DiscardUnknown added in v1.16.0 

func (m *ScrapeConfigsUpdateRequest) XXX_DiscardUnknown()

func (*ScrapeConfigsUpdateRequest) XXX_Marshal added in v1.16.0 

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

func (*ScrapeConfigsUpdateRequest) XXX_Merge added in v1.16.0 

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

func (*ScrapeConfigsUpdateRequest) XXX_Size added in v1.16.0 

func (m *ScrapeConfigsUpdateRequest) XXX_Size() int

func (*ScrapeConfigsUpdateRequest) XXX_Unmarshal added in v1.16.0 

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

type ScrapeConfigsUpdateResponse added in v1.7.0 

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

func (*ScrapeConfigsUpdateResponse) Descriptor added in v1.7.0 

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

func (*ScrapeConfigsUpdateResponse) ProtoMessage added in v1.7.0 

func (*ScrapeConfigsUpdateResponse) ProtoMessage()

func (*ScrapeConfigsUpdateResponse) Reset added in v1.7.0 

func (m *ScrapeConfigsUpdateResponse) Reset()

func (*ScrapeConfigsUpdateResponse) String added in v1.7.0 

func (m *ScrapeConfigsUpdateResponse) String() string

func (*ScrapeConfigsUpdateResponse) XXX_DiscardUnknown added in v1.16.0 

func (m *ScrapeConfigsUpdateResponse) XXX_DiscardUnknown()

func (*ScrapeConfigsUpdateResponse) XXX_Marshal added in v1.16.0 

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

func (*ScrapeConfigsUpdateResponse) XXX_Merge added in v1.16.0 

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

func (*ScrapeConfigsUpdateResponse) XXX_Size added in v1.16.0 

func (m *ScrapeConfigsUpdateResponse) XXX_Size() int

func (*ScrapeConfigsUpdateResponse) XXX_Unmarshal added in v1.16.0 

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

type ScrapeTargetHealth added in v1.7.0 

type ScrapeTargetHealth struct {
	// Original scrape job name
	JobName string `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	// "job" label value, may be different from job_name due to relabeling
	Job string `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"`
	// Original target
	Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	// "instance" label value, may be different from target due to relabeling
	Instance             string                    `protobuf:"bytes,4,opt,name=instance,proto3" json:"instance,omitempty"`
	Health               ScrapeTargetHealth_Health `protobuf:"varint,5,opt,name=health,proto3,enum=api.ScrapeTargetHealth_Health" json:"health,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

ScrapeTargetHealth represents Prometheus scrape target health: unknown, down, or up.

func (*ScrapeTargetHealth) Descriptor added in v1.7.0 

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

func (*ScrapeTargetHealth) GetHealth added in v1.7.0 

func (m *ScrapeTargetHealth) GetHealth() ScrapeTargetHealth_Health

func (*ScrapeTargetHealth) GetInstance added in v1.7.0 

func (m *ScrapeTargetHealth) GetInstance() string

func (*ScrapeTargetHealth) GetJob added in v1.7.0 

func (m *ScrapeTargetHealth) GetJob() string

func (*ScrapeTargetHealth) GetJobName added in v1.7.0 

func (m *ScrapeTargetHealth) GetJobName() string

func (*ScrapeTargetHealth) GetTarget added in v1.7.0 

func (m *ScrapeTargetHealth) GetTarget() string

func (*ScrapeTargetHealth) ProtoMessage added in v1.7.0 

func (*ScrapeTargetHealth) ProtoMessage()

func (*ScrapeTargetHealth) Reset added in v1.7.0 

func (m *ScrapeTargetHealth) Reset()

func (*ScrapeTargetHealth) String added in v1.7.0 

func (m *ScrapeTargetHealth) String() string

func (*ScrapeTargetHealth) XXX_DiscardUnknown added in v1.16.0 

func (m *ScrapeTargetHealth) XXX_DiscardUnknown()

func (*ScrapeTargetHealth) XXX_Marshal added in v1.16.0 

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

func (*ScrapeTargetHealth) XXX_Merge added in v1.16.0 

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

func (*ScrapeTargetHealth) XXX_Size added in v1.16.0 

func (m *ScrapeTargetHealth) XXX_Size() int

func (*ScrapeTargetHealth) XXX_Unmarshal added in v1.16.0 

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

type ScrapeTargetHealth_Health added in v1.7.0 

type ScrapeTargetHealth_Health int32

Target health : unknown, down, or up. 

const (
	ScrapeTargetHealth_UNKNOWN ScrapeTargetHealth_Health = 0
	ScrapeTargetHealth_DOWN    ScrapeTargetHealth_Health = 1
	ScrapeTargetHealth_UP      ScrapeTargetHealth_Health = 2
)

func (ScrapeTargetHealth_Health) EnumDescriptor added in v1.7.0 

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

func (ScrapeTargetHealth_Health) String added in v1.7.0 

func (x ScrapeTargetHealth_Health) String() string

type StaticConfig 

type StaticConfig struct {
	// Hostnames or IPs followed by an optional port number: "1.2.3.4:9090"
	Targets []string `protobuf:"bytes,1,rep,name=targets,proto3" json:"targets,omitempty"`
	// Labels assigned to all metrics scraped from the targets
	Labels               []*LabelPair `protobuf:"bytes,2,rep,name=labels,proto3" json:"labels,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*StaticConfig) Descriptor 

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

func (*StaticConfig) GetLabels 

func (m *StaticConfig) GetLabels() []*LabelPair

func (*StaticConfig) GetTargets 

func (m *StaticConfig) GetTargets() []string

func (*StaticConfig) ProtoMessage 

func (*StaticConfig) ProtoMessage()

func (*StaticConfig) Reset 

func (m *StaticConfig) Reset()

func (*StaticConfig) String 

func (m *StaticConfig) String() string

func (*StaticConfig) XXX_DiscardUnknown added in v1.16.0 

func (m *StaticConfig) XXX_DiscardUnknown()

func (*StaticConfig) XXX_Marshal added in v1.16.0 

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

func (*StaticConfig) XXX_Merge added in v1.16.0 

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

func (*StaticConfig) XXX_Size added in v1.16.0 

func (m *StaticConfig) XXX_Size() int

func (*StaticConfig) XXX_Unmarshal added in v1.16.0 

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

type TLSConfig 

type TLSConfig struct {
	InsecureSkipVerify   bool     `protobuf:"varint,5,opt,name=insecure_skip_verify,json=insecureSkipVerify,proto3" json:"insecure_skip_verify,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TLSConfig) Descriptor 

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

func (*TLSConfig) GetInsecureSkipVerify 

func (m *TLSConfig) GetInsecureSkipVerify() bool

func (*TLSConfig) ProtoMessage 

func (*TLSConfig) ProtoMessage()

func (*TLSConfig) Reset 

func (m *TLSConfig) Reset()

func (*TLSConfig) String 

func (m *TLSConfig) String() string

func (*TLSConfig) XXX_DiscardUnknown added in v1.16.0 

func (m *TLSConfig) XXX_DiscardUnknown()

func (*TLSConfig) XXX_Marshal added in v1.16.0 

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

func (*TLSConfig) XXX_Merge added in v1.16.0 

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

func (*TLSConfig) XXX_Size added in v1.16.0 

func (m *TLSConfig) XXX_Size() int

func (*TLSConfig) XXX_Unmarshal added in v1.16.0 

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

Source Files

View all Source files

Directories

Path Synopsis
swagger
client
client/annotations
client/base
client/demo
client/logs
client/my_sql
client/postgre_sql
client/r_d_s
client/remote
client/scrape_configs
models

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.