Help us shape the future of Go! Take the 2026 Go Developer Survey

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

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

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

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

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 (*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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL