Documentation ¶
Index ¶
- Variables
- func RegisterDatabaseServer(s *grpc.Server, srv DatabaseServer)
- func Serve(db Database, tlsProvider func() (*tls.Config, error))
- func ServeConfig(db Database, tlsProvider func() (*tls.Config, error)) *plugin.ServeConfig
- type CreateUserRequest
- func (*CreateUserRequest) Descriptor() ([]byte, []int)
- func (m *CreateUserRequest) GetExpiration() *timestamp.Timestamp
- func (m *CreateUserRequest) GetStatements() *Statements
- func (m *CreateUserRequest) GetUsernameConfig() *UsernameConfig
- func (*CreateUserRequest) ProtoMessage()
- func (m *CreateUserRequest) Reset()
- func (m *CreateUserRequest) String() string
- func (m *CreateUserRequest) XXX_DiscardUnknown()
- func (m *CreateUserRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateUserRequest) XXX_Merge(src proto.Message)
- func (m *CreateUserRequest) XXX_Size() int
- func (m *CreateUserRequest) XXX_Unmarshal(b []byte) error
- type CreateUserRequestRPC
- type CreateUserResponse
- func (*CreateUserResponse) Descriptor() ([]byte, []int)
- func (m *CreateUserResponse) GetPassword() string
- func (m *CreateUserResponse) GetUsername() string
- func (*CreateUserResponse) ProtoMessage()
- func (m *CreateUserResponse) Reset()
- func (m *CreateUserResponse) String() string
- func (m *CreateUserResponse) XXX_DiscardUnknown()
- func (m *CreateUserResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateUserResponse) XXX_Merge(src proto.Message)
- func (m *CreateUserResponse) XXX_Size() int
- func (m *CreateUserResponse) XXX_Unmarshal(b []byte) error
- type Database
- type DatabaseClient
- type DatabaseErrorSanitizerMiddleware
- func (mw *DatabaseErrorSanitizerMiddleware) Close() (err error)
- func (mw *DatabaseErrorSanitizerMiddleware) CreateUser(ctx context.Context, statements Statements, usernameConfig UsernameConfig, ...) (username string, password string, err error)
- func (mw *DatabaseErrorSanitizerMiddleware) Init(ctx context.Context, conf map[string]interface{}, verifyConnection bool) (saveConf map[string]interface{}, err error)
- func (mw *DatabaseErrorSanitizerMiddleware) Initialize(ctx context.Context, conf map[string]interface{}, verifyConnection bool) error
- func (mw *DatabaseErrorSanitizerMiddleware) RenewUser(ctx context.Context, statements Statements, username string, ...) (err error)
- func (mw *DatabaseErrorSanitizerMiddleware) RevokeUser(ctx context.Context, statements Statements, username string) (err error)
- func (mw *DatabaseErrorSanitizerMiddleware) RotateRootCredentials(ctx context.Context, statements []string) (conf map[string]interface{}, err error)
- func (mw *DatabaseErrorSanitizerMiddleware) Type() (string, error)
- type DatabasePlugin
- type DatabasePluginClient
- type DatabaseServer
- type Empty
- func (*Empty) Descriptor() ([]byte, []int)
- func (*Empty) ProtoMessage()
- func (m *Empty) Reset()
- func (m *Empty) String() string
- func (m *Empty) XXX_DiscardUnknown()
- func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Empty) XXX_Merge(src proto.Message)
- func (m *Empty) XXX_Size() int
- func (m *Empty) XXX_Unmarshal(b []byte) error
- type GRPCDatabasePlugin
- type InitRequest
- func (*InitRequest) Descriptor() ([]byte, []int)
- func (m *InitRequest) GetConfig() []byte
- func (m *InitRequest) GetVerifyConnection() bool
- func (*InitRequest) ProtoMessage()
- func (m *InitRequest) Reset()
- func (m *InitRequest) String() string
- func (m *InitRequest) XXX_DiscardUnknown()
- func (m *InitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InitRequest) XXX_Merge(src proto.Message)
- func (m *InitRequest) XXX_Size() int
- func (m *InitRequest) XXX_Unmarshal(b []byte) error
- type InitRequestRPC
- type InitResponse
- func (*InitResponse) Descriptor() ([]byte, []int)
- func (m *InitResponse) GetConfig() []byte
- func (*InitResponse) ProtoMessage()
- func (m *InitResponse) Reset()
- func (m *InitResponse) String() string
- func (m *InitResponse) XXX_DiscardUnknown()
- func (m *InitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InitResponse) XXX_Merge(src proto.Message)
- func (m *InitResponse) XXX_Size() int
- func (m *InitResponse) XXX_Unmarshal(b []byte) error
- type InitializeRequestdeprecated
- func (*InitializeRequest) Descriptor() ([]byte, []int)
- func (m *InitializeRequest) GetConfig() []byte
- func (m *InitializeRequest) GetVerifyConnection() bool
- func (*InitializeRequest) ProtoMessage()
- func (m *InitializeRequest) Reset()
- func (m *InitializeRequest) String() string
- func (m *InitializeRequest) XXX_DiscardUnknown()
- func (m *InitializeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InitializeRequest) XXX_Merge(src proto.Message)
- func (m *InitializeRequest) XXX_Size() int
- func (m *InitializeRequest) XXX_Unmarshal(b []byte) error
- type InitializeRequestRPC
- type RenewUserRequest
- func (*RenewUserRequest) Descriptor() ([]byte, []int)
- func (m *RenewUserRequest) GetExpiration() *timestamp.Timestamp
- func (m *RenewUserRequest) GetStatements() *Statements
- func (m *RenewUserRequest) GetUsername() string
- func (*RenewUserRequest) ProtoMessage()
- func (m *RenewUserRequest) Reset()
- func (m *RenewUserRequest) String() string
- func (m *RenewUserRequest) XXX_DiscardUnknown()
- func (m *RenewUserRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RenewUserRequest) XXX_Merge(src proto.Message)
- func (m *RenewUserRequest) XXX_Size() int
- func (m *RenewUserRequest) XXX_Unmarshal(b []byte) error
- type RenewUserRequestRPC
- type RevokeUserRequest
- func (*RevokeUserRequest) Descriptor() ([]byte, []int)
- func (m *RevokeUserRequest) GetStatements() *Statements
- func (m *RevokeUserRequest) GetUsername() string
- func (*RevokeUserRequest) ProtoMessage()
- func (m *RevokeUserRequest) Reset()
- func (m *RevokeUserRequest) String() string
- func (m *RevokeUserRequest) XXX_DiscardUnknown()
- func (m *RevokeUserRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RevokeUserRequest) XXX_Merge(src proto.Message)
- func (m *RevokeUserRequest) XXX_Size() int
- func (m *RevokeUserRequest) XXX_Unmarshal(b []byte) error
- type RevokeUserRequestRPC
- type RotateRootCredentialsRequest
- func (*RotateRootCredentialsRequest) Descriptor() ([]byte, []int)
- func (m *RotateRootCredentialsRequest) GetStatements() []string
- func (*RotateRootCredentialsRequest) ProtoMessage()
- func (m *RotateRootCredentialsRequest) Reset()
- func (m *RotateRootCredentialsRequest) String() string
- func (m *RotateRootCredentialsRequest) XXX_DiscardUnknown()
- func (m *RotateRootCredentialsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RotateRootCredentialsRequest) XXX_Merge(src proto.Message)
- func (m *RotateRootCredentialsRequest) XXX_Size() int
- func (m *RotateRootCredentialsRequest) XXX_Unmarshal(b []byte) error
- type RotateRootCredentialsRequestRPC
- type RotateRootCredentialsResponse
- func (*RotateRootCredentialsResponse) Descriptor() ([]byte, []int)
- func (m *RotateRootCredentialsResponse) GetConfig() []byte
- func (*RotateRootCredentialsResponse) ProtoMessage()
- func (m *RotateRootCredentialsResponse) Reset()
- func (m *RotateRootCredentialsResponse) String() string
- func (m *RotateRootCredentialsResponse) XXX_DiscardUnknown()
- func (m *RotateRootCredentialsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RotateRootCredentialsResponse) XXX_Merge(src proto.Message)
- func (m *RotateRootCredentialsResponse) XXX_Size() int
- func (m *RotateRootCredentialsResponse) XXX_Unmarshal(b []byte) error
- type Statements
- func (*Statements) Descriptor() ([]byte, []int)
- func (m *Statements) GetCreation() []string
- func (m *Statements) GetCreationStatements() stringdeprecated
- func (m *Statements) GetRenewStatements() stringdeprecated
- func (m *Statements) GetRenewal() []string
- func (m *Statements) GetRevocation() []string
- func (m *Statements) GetRevocationStatements() stringdeprecated
- func (m *Statements) GetRollback() []string
- func (m *Statements) GetRollbackStatements() stringdeprecated
- func (*Statements) ProtoMessage()
- func (m *Statements) Reset()
- func (m *Statements) String() string
- func (m *Statements) XXX_DiscardUnknown()
- func (m *Statements) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Statements) XXX_Merge(src proto.Message)
- func (m *Statements) XXX_Size() int
- func (m *Statements) XXX_Unmarshal(b []byte) error
- type TypeResponse
- func (*TypeResponse) Descriptor() ([]byte, []int)
- func (m *TypeResponse) GetType() string
- func (*TypeResponse) ProtoMessage()
- func (m *TypeResponse) Reset()
- func (m *TypeResponse) String() string
- func (m *TypeResponse) XXX_DiscardUnknown()
- func (m *TypeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TypeResponse) XXX_Merge(src proto.Message)
- func (m *TypeResponse) XXX_Size() int
- func (m *TypeResponse) XXX_Unmarshal(b []byte) error
- type UsernameConfig
- func (*UsernameConfig) Descriptor() ([]byte, []int)
- func (m *UsernameConfig) GetDisplayName() string
- func (m *UsernameConfig) GetRoleName() string
- func (*UsernameConfig) ProtoMessage()
- func (m *UsernameConfig) Reset()
- func (m *UsernameConfig) String() string
- func (m *UsernameConfig) XXX_DiscardUnknown()
- func (m *UsernameConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UsernameConfig) XXX_Merge(src proto.Message)
- func (m *UsernameConfig) XXX_Size() int
- func (m *UsernameConfig) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var (
ErrPluginShutdown = errors.New("plugin shutdown")
)
Functions ¶
func RegisterDatabaseServer ¶
func RegisterDatabaseServer(s *grpc.Server, srv DatabaseServer)
Types ¶
type CreateUserRequest ¶
type CreateUserRequest struct { Statements *Statements `protobuf:"bytes,1,opt,name=statements,proto3" json:"statements,omitempty"` UsernameConfig *UsernameConfig `protobuf:"bytes,2,opt,name=username_config,json=usernameConfig,proto3" json:"username_config,omitempty"` Expiration *timestamp.Timestamp `protobuf:"bytes,3,opt,name=expiration,proto3" json:"expiration,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateUserRequest) Descriptor ¶
func (*CreateUserRequest) Descriptor() ([]byte, []int)
func (*CreateUserRequest) GetExpiration ¶
func (m *CreateUserRequest) GetExpiration() *timestamp.Timestamp
func (*CreateUserRequest) GetStatements ¶
func (m *CreateUserRequest) GetStatements() *Statements
func (*CreateUserRequest) GetUsernameConfig ¶
func (m *CreateUserRequest) GetUsernameConfig() *UsernameConfig
func (*CreateUserRequest) ProtoMessage ¶
func (*CreateUserRequest) ProtoMessage()
func (*CreateUserRequest) Reset ¶
func (m *CreateUserRequest) Reset()
func (*CreateUserRequest) String ¶
func (m *CreateUserRequest) String() string
func (*CreateUserRequest) XXX_DiscardUnknown ¶
func (m *CreateUserRequest) XXX_DiscardUnknown()
func (*CreateUserRequest) XXX_Marshal ¶
func (m *CreateUserRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateUserRequest) XXX_Merge ¶
func (m *CreateUserRequest) XXX_Merge(src proto.Message)
func (*CreateUserRequest) XXX_Size ¶
func (m *CreateUserRequest) XXX_Size() int
func (*CreateUserRequest) XXX_Unmarshal ¶
func (m *CreateUserRequest) XXX_Unmarshal(b []byte) error
type CreateUserRequestRPC ¶
type CreateUserRequestRPC struct { Statements Statements UsernameConfig UsernameConfig Expiration time.Time }
type CreateUserResponse ¶
type CreateUserResponse 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 (*CreateUserResponse) Descriptor ¶
func (*CreateUserResponse) Descriptor() ([]byte, []int)
func (*CreateUserResponse) GetPassword ¶
func (m *CreateUserResponse) GetPassword() string
func (*CreateUserResponse) GetUsername ¶
func (m *CreateUserResponse) GetUsername() string
func (*CreateUserResponse) ProtoMessage ¶
func (*CreateUserResponse) ProtoMessage()
func (*CreateUserResponse) Reset ¶
func (m *CreateUserResponse) Reset()
func (*CreateUserResponse) String ¶
func (m *CreateUserResponse) String() string
func (*CreateUserResponse) XXX_DiscardUnknown ¶
func (m *CreateUserResponse) XXX_DiscardUnknown()
func (*CreateUserResponse) XXX_Marshal ¶
func (m *CreateUserResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateUserResponse) XXX_Merge ¶
func (m *CreateUserResponse) XXX_Merge(src proto.Message)
func (*CreateUserResponse) XXX_Size ¶
func (m *CreateUserResponse) XXX_Size() int
func (*CreateUserResponse) XXX_Unmarshal ¶
func (m *CreateUserResponse) XXX_Unmarshal(b []byte) error
type Database ¶
type Database interface { Type() (string, error) CreateUser(ctx context.Context, statements Statements, usernameConfig UsernameConfig, expiration time.Time) (username string, password string, err error) RenewUser(ctx context.Context, statements Statements, username string, expiration time.Time) error RevokeUser(ctx context.Context, statements Statements, username string) error RotateRootCredentials(ctx context.Context, statements []string) (config map[string]interface{}, err error) Init(ctx context.Context, config map[string]interface{}, verifyConnection bool) (saveConfig map[string]interface{}, err error) Close() error // DEPRECATED, will be removed in 0.13 Initialize(ctx context.Context, config map[string]interface{}, verifyConnection bool) (err error) }
Database is the interface that all database objects must implement.
func NewPluginClient ¶
func NewPluginClient(ctx context.Context, sys pluginutil.RunnerUtil, pluginRunner *pluginutil.PluginRunner, logger log.Logger, isMetadataMode bool) (Database, error)
NewPluginClient returns a databaseRPCClient with a connection to a running plugin. The client is wrapped in a DatabasePluginClient object to ensure the plugin is killed on call of Close().
func PluginFactory ¶
func PluginFactory(ctx context.Context, pluginName string, sys pluginutil.LookRunnerUtil, logger log.Logger) (Database, error)
PluginFactory is used to build plugin database types. It wraps the database object in a logging and metrics middleware.
type DatabaseClient ¶
type DatabaseClient interface { Type(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*TypeResponse, error) CreateUser(ctx context.Context, in *CreateUserRequest, opts ...grpc.CallOption) (*CreateUserResponse, error) RenewUser(ctx context.Context, in *RenewUserRequest, opts ...grpc.CallOption) (*Empty, error) RevokeUser(ctx context.Context, in *RevokeUserRequest, opts ...grpc.CallOption) (*Empty, error) RotateRootCredentials(ctx context.Context, in *RotateRootCredentialsRequest, opts ...grpc.CallOption) (*RotateRootCredentialsResponse, error) Init(ctx context.Context, in *InitRequest, opts ...grpc.CallOption) (*InitResponse, error) Close(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) Initialize(ctx context.Context, in *InitializeRequest, opts ...grpc.CallOption) (*Empty, error) }
DatabaseClient is the client API for Database service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewDatabaseClient ¶
func NewDatabaseClient(cc *grpc.ClientConn) DatabaseClient
type DatabaseErrorSanitizerMiddleware ¶
type DatabaseErrorSanitizerMiddleware struct {
// contains filtered or unexported fields
}
DatabaseErrorSanitizerMiddleware wraps an implementation of Databases and sanitizes returned error messages
func NewDatabaseErrorSanitizerMiddleware ¶
func NewDatabaseErrorSanitizerMiddleware(next Database, secretsFn func() map[string]interface{}) *DatabaseErrorSanitizerMiddleware
func (*DatabaseErrorSanitizerMiddleware) Close ¶
func (mw *DatabaseErrorSanitizerMiddleware) Close() (err error)
func (*DatabaseErrorSanitizerMiddleware) CreateUser ¶
func (mw *DatabaseErrorSanitizerMiddleware) CreateUser(ctx context.Context, statements Statements, usernameConfig UsernameConfig, expiration time.Time) (username string, password string, err error)
func (*DatabaseErrorSanitizerMiddleware) Initialize ¶
func (*DatabaseErrorSanitizerMiddleware) RenewUser ¶
func (mw *DatabaseErrorSanitizerMiddleware) RenewUser(ctx context.Context, statements Statements, username string, expiration time.Time) (err error)
func (*DatabaseErrorSanitizerMiddleware) RevokeUser ¶
func (mw *DatabaseErrorSanitizerMiddleware) RevokeUser(ctx context.Context, statements Statements, username string) (err error)
func (*DatabaseErrorSanitizerMiddleware) RotateRootCredentials ¶
func (*DatabaseErrorSanitizerMiddleware) Type ¶
func (mw *DatabaseErrorSanitizerMiddleware) Type() (string, error)
type DatabasePlugin ¶
type DatabasePlugin struct {
*GRPCDatabasePlugin
}
DatabasePlugin implements go-plugin's Plugin interface. It has methods for retrieving a server and a client instance of the plugin.
func (DatabasePlugin) Client ¶
func (DatabasePlugin) Client(b *plugin.MuxBroker, c *rpc.Client) (interface{}, error)
func (DatabasePlugin) Server ¶
func (d DatabasePlugin) Server(*plugin.MuxBroker) (interface{}, error)
type DatabasePluginClient ¶
DatabasePluginClient embeds a databasePluginRPCClient and wraps it's Close method to also call Kill() on the plugin.Client.
func (*DatabasePluginClient) Close ¶
func (dc *DatabasePluginClient) Close() error
This wraps the Close call and ensures we both close the database connection and kill the plugin.
type DatabaseServer ¶
type DatabaseServer interface { Type(context.Context, *Empty) (*TypeResponse, error) CreateUser(context.Context, *CreateUserRequest) (*CreateUserResponse, error) RenewUser(context.Context, *RenewUserRequest) (*Empty, error) RevokeUser(context.Context, *RevokeUserRequest) (*Empty, error) RotateRootCredentials(context.Context, *RotateRootCredentialsRequest) (*RotateRootCredentialsResponse, error) Init(context.Context, *InitRequest) (*InitResponse, error) Close(context.Context, *Empty) (*Empty, error) Initialize(context.Context, *InitializeRequest) (*Empty, error) }
DatabaseServer is the server API for Database service.
type Empty ¶
type Empty struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Empty) Descriptor ¶
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) XXX_DiscardUnknown ¶
func (m *Empty) XXX_DiscardUnknown()
func (*Empty) XXX_Marshal ¶
func (*Empty) XXX_Unmarshal ¶
type GRPCDatabasePlugin ¶
type GRPCDatabasePlugin struct { Impl Database // Embeding this will disable the netRPC protocol plugin.NetRPCUnsupportedPlugin }
GRPCDatabasePlugin is the plugin.Plugin implementation that only supports GRPC transport
func (GRPCDatabasePlugin) GRPCClient ¶
func (GRPCDatabasePlugin) GRPCClient(doneCtx context.Context, _ *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)
func (GRPCDatabasePlugin) GRPCServer ¶
func (d GRPCDatabasePlugin) GRPCServer(_ *plugin.GRPCBroker, s *grpc.Server) error
type InitRequest ¶
type InitRequest struct { Config []byte `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"` VerifyConnection bool `protobuf:"varint,2,opt,name=verify_connection,json=verifyConnection,proto3" json:"verify_connection,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*InitRequest) Descriptor ¶
func (*InitRequest) Descriptor() ([]byte, []int)
func (*InitRequest) GetConfig ¶
func (m *InitRequest) GetConfig() []byte
func (*InitRequest) GetVerifyConnection ¶
func (m *InitRequest) GetVerifyConnection() bool
func (*InitRequest) ProtoMessage ¶
func (*InitRequest) ProtoMessage()
func (*InitRequest) Reset ¶
func (m *InitRequest) Reset()
func (*InitRequest) String ¶
func (m *InitRequest) String() string
func (*InitRequest) XXX_DiscardUnknown ¶
func (m *InitRequest) XXX_DiscardUnknown()
func (*InitRequest) XXX_Marshal ¶
func (m *InitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InitRequest) XXX_Merge ¶
func (m *InitRequest) XXX_Merge(src proto.Message)
func (*InitRequest) XXX_Size ¶
func (m *InitRequest) XXX_Size() int
func (*InitRequest) XXX_Unmarshal ¶
func (m *InitRequest) XXX_Unmarshal(b []byte) error
type InitRequestRPC ¶
type InitResponse ¶
type InitResponse struct { Config []byte `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*InitResponse) Descriptor ¶
func (*InitResponse) Descriptor() ([]byte, []int)
func (*InitResponse) GetConfig ¶
func (m *InitResponse) GetConfig() []byte
func (*InitResponse) ProtoMessage ¶
func (*InitResponse) ProtoMessage()
func (*InitResponse) Reset ¶
func (m *InitResponse) Reset()
func (*InitResponse) String ¶
func (m *InitResponse) String() string
func (*InitResponse) XXX_DiscardUnknown ¶
func (m *InitResponse) XXX_DiscardUnknown()
func (*InitResponse) XXX_Marshal ¶
func (m *InitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InitResponse) XXX_Merge ¶
func (m *InitResponse) XXX_Merge(src proto.Message)
func (*InitResponse) XXX_Size ¶
func (m *InitResponse) XXX_Size() int
func (*InitResponse) XXX_Unmarshal ¶
func (m *InitResponse) XXX_Unmarshal(b []byte) error
type InitializeRequest
deprecated
type InitializeRequest struct { Config []byte `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"` VerifyConnection bool `protobuf:"varint,2,opt,name=verify_connection,json=verifyConnection,proto3" json:"verify_connection,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Deprecated: Do not use.
func (*InitializeRequest) Descriptor ¶
func (*InitializeRequest) Descriptor() ([]byte, []int)
func (*InitializeRequest) GetConfig ¶
func (m *InitializeRequest) GetConfig() []byte
func (*InitializeRequest) GetVerifyConnection ¶
func (m *InitializeRequest) GetVerifyConnection() bool
func (*InitializeRequest) ProtoMessage ¶
func (*InitializeRequest) ProtoMessage()
func (*InitializeRequest) Reset ¶
func (m *InitializeRequest) Reset()
func (*InitializeRequest) String ¶
func (m *InitializeRequest) String() string
func (*InitializeRequest) XXX_DiscardUnknown ¶
func (m *InitializeRequest) XXX_DiscardUnknown()
func (*InitializeRequest) XXX_Marshal ¶
func (m *InitializeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InitializeRequest) XXX_Merge ¶
func (m *InitializeRequest) XXX_Merge(src proto.Message)
func (*InitializeRequest) XXX_Size ¶
func (m *InitializeRequest) XXX_Size() int
func (*InitializeRequest) XXX_Unmarshal ¶
func (m *InitializeRequest) XXX_Unmarshal(b []byte) error
type InitializeRequestRPC ¶
type RenewUserRequest ¶
type RenewUserRequest struct { Statements *Statements `protobuf:"bytes,1,opt,name=statements,proto3" json:"statements,omitempty"` Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"` Expiration *timestamp.Timestamp `protobuf:"bytes,3,opt,name=expiration,proto3" json:"expiration,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RenewUserRequest) Descriptor ¶
func (*RenewUserRequest) Descriptor() ([]byte, []int)
func (*RenewUserRequest) GetExpiration ¶
func (m *RenewUserRequest) GetExpiration() *timestamp.Timestamp
func (*RenewUserRequest) GetStatements ¶
func (m *RenewUserRequest) GetStatements() *Statements
func (*RenewUserRequest) GetUsername ¶
func (m *RenewUserRequest) GetUsername() string
func (*RenewUserRequest) ProtoMessage ¶
func (*RenewUserRequest) ProtoMessage()
func (*RenewUserRequest) Reset ¶
func (m *RenewUserRequest) Reset()
func (*RenewUserRequest) String ¶
func (m *RenewUserRequest) String() string
func (*RenewUserRequest) XXX_DiscardUnknown ¶
func (m *RenewUserRequest) XXX_DiscardUnknown()
func (*RenewUserRequest) XXX_Marshal ¶
func (m *RenewUserRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RenewUserRequest) XXX_Merge ¶
func (m *RenewUserRequest) XXX_Merge(src proto.Message)
func (*RenewUserRequest) XXX_Size ¶
func (m *RenewUserRequest) XXX_Size() int
func (*RenewUserRequest) XXX_Unmarshal ¶
func (m *RenewUserRequest) XXX_Unmarshal(b []byte) error
type RenewUserRequestRPC ¶
type RenewUserRequestRPC struct { Statements Statements Username string Expiration time.Time }
type RevokeUserRequest ¶
type RevokeUserRequest struct { Statements *Statements `protobuf:"bytes,1,opt,name=statements,proto3" json:"statements,omitempty"` Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RevokeUserRequest) Descriptor ¶
func (*RevokeUserRequest) Descriptor() ([]byte, []int)
func (*RevokeUserRequest) GetStatements ¶
func (m *RevokeUserRequest) GetStatements() *Statements
func (*RevokeUserRequest) GetUsername ¶
func (m *RevokeUserRequest) GetUsername() string
func (*RevokeUserRequest) ProtoMessage ¶
func (*RevokeUserRequest) ProtoMessage()
func (*RevokeUserRequest) Reset ¶
func (m *RevokeUserRequest) Reset()
func (*RevokeUserRequest) String ¶
func (m *RevokeUserRequest) String() string
func (*RevokeUserRequest) XXX_DiscardUnknown ¶
func (m *RevokeUserRequest) XXX_DiscardUnknown()
func (*RevokeUserRequest) XXX_Marshal ¶
func (m *RevokeUserRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RevokeUserRequest) XXX_Merge ¶
func (m *RevokeUserRequest) XXX_Merge(src proto.Message)
func (*RevokeUserRequest) XXX_Size ¶
func (m *RevokeUserRequest) XXX_Size() int
func (*RevokeUserRequest) XXX_Unmarshal ¶
func (m *RevokeUserRequest) XXX_Unmarshal(b []byte) error
type RevokeUserRequestRPC ¶
type RevokeUserRequestRPC struct { Statements Statements Username string }
type RotateRootCredentialsRequest ¶
type RotateRootCredentialsRequest struct { Statements []string `protobuf:"bytes,1,rep,name=statements,proto3" json:"statements,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RotateRootCredentialsRequest) Descriptor ¶
func (*RotateRootCredentialsRequest) Descriptor() ([]byte, []int)
func (*RotateRootCredentialsRequest) GetStatements ¶
func (m *RotateRootCredentialsRequest) GetStatements() []string
func (*RotateRootCredentialsRequest) ProtoMessage ¶
func (*RotateRootCredentialsRequest) ProtoMessage()
func (*RotateRootCredentialsRequest) Reset ¶
func (m *RotateRootCredentialsRequest) Reset()
func (*RotateRootCredentialsRequest) String ¶
func (m *RotateRootCredentialsRequest) String() string
func (*RotateRootCredentialsRequest) XXX_DiscardUnknown ¶
func (m *RotateRootCredentialsRequest) XXX_DiscardUnknown()
func (*RotateRootCredentialsRequest) XXX_Marshal ¶
func (m *RotateRootCredentialsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RotateRootCredentialsRequest) XXX_Merge ¶
func (m *RotateRootCredentialsRequest) XXX_Merge(src proto.Message)
func (*RotateRootCredentialsRequest) XXX_Size ¶
func (m *RotateRootCredentialsRequest) XXX_Size() int
func (*RotateRootCredentialsRequest) XXX_Unmarshal ¶
func (m *RotateRootCredentialsRequest) XXX_Unmarshal(b []byte) error
type RotateRootCredentialsRequestRPC ¶
type RotateRootCredentialsRequestRPC struct {
Statements []string
}
type RotateRootCredentialsResponse ¶
type RotateRootCredentialsResponse struct { Config []byte `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RotateRootCredentialsResponse) Descriptor ¶
func (*RotateRootCredentialsResponse) Descriptor() ([]byte, []int)
func (*RotateRootCredentialsResponse) GetConfig ¶
func (m *RotateRootCredentialsResponse) GetConfig() []byte
func (*RotateRootCredentialsResponse) ProtoMessage ¶
func (*RotateRootCredentialsResponse) ProtoMessage()
func (*RotateRootCredentialsResponse) Reset ¶
func (m *RotateRootCredentialsResponse) Reset()
func (*RotateRootCredentialsResponse) String ¶
func (m *RotateRootCredentialsResponse) String() string
func (*RotateRootCredentialsResponse) XXX_DiscardUnknown ¶
func (m *RotateRootCredentialsResponse) XXX_DiscardUnknown()
func (*RotateRootCredentialsResponse) XXX_Marshal ¶
func (m *RotateRootCredentialsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RotateRootCredentialsResponse) XXX_Merge ¶
func (m *RotateRootCredentialsResponse) XXX_Merge(src proto.Message)
func (*RotateRootCredentialsResponse) XXX_Size ¶
func (m *RotateRootCredentialsResponse) XXX_Size() int
func (*RotateRootCredentialsResponse) XXX_Unmarshal ¶
func (m *RotateRootCredentialsResponse) XXX_Unmarshal(b []byte) error
type Statements ¶
type Statements struct { // DEPRECATED, will be removed in 0.12 CreationStatements string `protobuf:"bytes,1,opt,name=creation_statements,json=creationStatements,proto3" json:"creation_statements,omitempty"` // Deprecated: Do not use. // DEPRECATED, will be removed in 0.12 RevocationStatements string `protobuf:"bytes,2,opt,name=revocation_statements,json=revocationStatements,proto3" json:"revocation_statements,omitempty"` // Deprecated: Do not use. // DEPRECATED, will be removed in 0.12 RollbackStatements string `protobuf:"bytes,3,opt,name=rollback_statements,json=rollbackStatements,proto3" json:"rollback_statements,omitempty"` // Deprecated: Do not use. // DEPRECATED, will be removed in 0.12 RenewStatements string `protobuf:"bytes,4,opt,name=renew_statements,json=renewStatements,proto3" json:"renew_statements,omitempty"` // Deprecated: Do not use. Creation []string `protobuf:"bytes,5,rep,name=creation,proto3" json:"creation,omitempty"` Revocation []string `protobuf:"bytes,6,rep,name=revocation,proto3" json:"revocation,omitempty"` Rollback []string `protobuf:"bytes,7,rep,name=rollback,proto3" json:"rollback,omitempty"` Renewal []string `protobuf:"bytes,8,rep,name=renewal,proto3" json:"renewal,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Statements) Descriptor ¶
func (*Statements) Descriptor() ([]byte, []int)
func (*Statements) GetCreation ¶
func (m *Statements) GetCreation() []string
func (*Statements) GetCreationStatements
deprecated
func (m *Statements) GetCreationStatements() string
Deprecated: Do not use.
func (*Statements) GetRenewStatements
deprecated
func (m *Statements) GetRenewStatements() string
Deprecated: Do not use.
func (*Statements) GetRenewal ¶
func (m *Statements) GetRenewal() []string
func (*Statements) GetRevocation ¶
func (m *Statements) GetRevocation() []string
func (*Statements) GetRevocationStatements
deprecated
func (m *Statements) GetRevocationStatements() string
Deprecated: Do not use.
func (*Statements) GetRollback ¶
func (m *Statements) GetRollback() []string
func (*Statements) GetRollbackStatements
deprecated
func (m *Statements) GetRollbackStatements() string
Deprecated: Do not use.
func (*Statements) ProtoMessage ¶
func (*Statements) ProtoMessage()
func (*Statements) Reset ¶
func (m *Statements) Reset()
func (*Statements) String ¶
func (m *Statements) String() string
func (*Statements) XXX_DiscardUnknown ¶
func (m *Statements) XXX_DiscardUnknown()
func (*Statements) XXX_Marshal ¶
func (m *Statements) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Statements) XXX_Merge ¶
func (m *Statements) XXX_Merge(src proto.Message)
func (*Statements) XXX_Size ¶
func (m *Statements) XXX_Size() int
func (*Statements) XXX_Unmarshal ¶
func (m *Statements) XXX_Unmarshal(b []byte) error
type TypeResponse ¶
type TypeResponse struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TypeResponse) Descriptor ¶
func (*TypeResponse) Descriptor() ([]byte, []int)
func (*TypeResponse) GetType ¶
func (m *TypeResponse) GetType() string
func (*TypeResponse) ProtoMessage ¶
func (*TypeResponse) ProtoMessage()
func (*TypeResponse) Reset ¶
func (m *TypeResponse) Reset()
func (*TypeResponse) String ¶
func (m *TypeResponse) String() string
func (*TypeResponse) XXX_DiscardUnknown ¶
func (m *TypeResponse) XXX_DiscardUnknown()
func (*TypeResponse) XXX_Marshal ¶
func (m *TypeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TypeResponse) XXX_Merge ¶
func (m *TypeResponse) XXX_Merge(src proto.Message)
func (*TypeResponse) XXX_Size ¶
func (m *TypeResponse) XXX_Size() int
func (*TypeResponse) XXX_Unmarshal ¶
func (m *TypeResponse) XXX_Unmarshal(b []byte) error
type UsernameConfig ¶
type UsernameConfig struct { DisplayName string `protobuf:"bytes,1,opt,name=DisplayName,proto3" json:"DisplayName,omitempty"` RoleName string `protobuf:"bytes,2,opt,name=RoleName,proto3" json:"RoleName,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UsernameConfig) Descriptor ¶
func (*UsernameConfig) Descriptor() ([]byte, []int)
func (*UsernameConfig) GetDisplayName ¶
func (m *UsernameConfig) GetDisplayName() string
func (*UsernameConfig) GetRoleName ¶
func (m *UsernameConfig) GetRoleName() string
func (*UsernameConfig) ProtoMessage ¶
func (*UsernameConfig) ProtoMessage()
func (*UsernameConfig) Reset ¶
func (m *UsernameConfig) Reset()
func (*UsernameConfig) String ¶
func (m *UsernameConfig) String() string
func (*UsernameConfig) XXX_DiscardUnknown ¶
func (m *UsernameConfig) XXX_DiscardUnknown()
func (*UsernameConfig) XXX_Marshal ¶
func (m *UsernameConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UsernameConfig) XXX_Merge ¶
func (m *UsernameConfig) XXX_Merge(src proto.Message)
func (*UsernameConfig) XXX_Size ¶
func (m *UsernameConfig) XXX_Size() int
func (*UsernameConfig) XXX_Unmarshal ¶
func (m *UsernameConfig) XXX_Unmarshal(b []byte) error