dbplugin

package

Go to main page

Versions in this module

v0

v0.9.1

Dec 21, 2017

Changes in this version

+ var ErrPluginShutdown = errors.New("plugin shutdown")

+ func RegisterDatabaseServer(s *grpc.Server, srv DatabaseServer)

+ func ServeConfig(db Database, tlsProvider func() (*tls.Config, error)) *plugin.ServeConfig

type CreateUserRequest

+ func (*CreateUserRequest) Descriptor() ([]byte, []int)

+ func (*CreateUserRequest) ProtoMessage()

+ func (m *CreateUserRequest) GetExpiration() *google_protobuf.Timestamp

+ func (m *CreateUserRequest) GetStatements() *Statements

+ func (m *CreateUserRequest) GetUsernameConfig() *UsernameConfig

+ func (m *CreateUserRequest) Reset()

+ func (m *CreateUserRequest) String() string

+ type CreateUserRequestRPC struct

+ Expiration time.Time

+ Statements Statements

+ UsernameConfig UsernameConfig

type CreateUserResponse

+ func (*CreateUserResponse) Descriptor() ([]byte, []int)

+ func (*CreateUserResponse) ProtoMessage()

+ func (m *CreateUserResponse) GetPassword() string

+ func (m *CreateUserResponse) GetUsername() string

+ func (m *CreateUserResponse) Reset()

+ func (m *CreateUserResponse) String() string

+ type DatabaseClient interface

+ Close func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)

+ CreateUser func(ctx context.Context, in *CreateUserRequest, opts ...grpc.CallOption) (*CreateUserResponse, error)

+ Initialize func(ctx context.Context, in *InitializeRequest, opts ...grpc.CallOption) (*Empty, error)

+ RenewUser func(ctx context.Context, in *RenewUserRequest, opts ...grpc.CallOption) (*Empty, error)

+ RevokeUser func(ctx context.Context, in *RevokeUserRequest, opts ...grpc.CallOption) (*Empty, error)

+ Type func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*TypeResponse, error)

+ func NewDatabaseClient(cc *grpc.ClientConn) DatabaseClient

type DatabasePlugin

+ func (DatabasePlugin) GRPCClient(c *grpc.ClientConn) (interface{}, error)

+ func (d DatabasePlugin) GRPCServer(s *grpc.Server) error

+ type DatabaseServer interface

+ Close func(context.Context, *Empty) (*Empty, error)

+ CreateUser func(context.Context, *CreateUserRequest) (*CreateUserResponse, error)

+ Initialize func(context.Context, *InitializeRequest) (*Empty, error)

+ RenewUser func(context.Context, *RenewUserRequest) (*Empty, error)

+ RevokeUser func(context.Context, *RevokeUserRequest) (*Empty, error)

+ Type func(context.Context, *Empty) (*TypeResponse, error)

+ type Empty struct

+ func (*Empty) Descriptor() ([]byte, []int)

+ func (*Empty) ProtoMessage()

+ func (m *Empty) Reset()

+ func (m *Empty) String() string

type InitializeRequest

+ func (*InitializeRequest) Descriptor() ([]byte, []int)

+ func (*InitializeRequest) ProtoMessage()

+ func (m *InitializeRequest) GetConfig() []byte

+ func (m *InitializeRequest) GetVerifyConnection() bool

+ func (m *InitializeRequest) Reset()

+ func (m *InitializeRequest) String() string

+ type InitializeRequestRPC struct

+ Config map[string]interface{}

+ VerifyConnection bool

type RenewUserRequest

+ func (*RenewUserRequest) Descriptor() ([]byte, []int)

+ func (*RenewUserRequest) ProtoMessage()

+ func (m *RenewUserRequest) GetExpiration() *google_protobuf.Timestamp

+ func (m *RenewUserRequest) GetStatements() *Statements

+ func (m *RenewUserRequest) GetUsername() string

+ func (m *RenewUserRequest) Reset()

+ func (m *RenewUserRequest) String() string

+ type RenewUserRequestRPC struct

+ Expiration time.Time

+ Statements Statements

+ Username string

type RevokeUserRequest

+ func (*RevokeUserRequest) Descriptor() ([]byte, []int)

+ func (*RevokeUserRequest) ProtoMessage()

+ func (m *RevokeUserRequest) GetStatements() *Statements

+ func (m *RevokeUserRequest) GetUsername() string

+ func (m *RevokeUserRequest) Reset()

+ func (m *RevokeUserRequest) String() string

+ type RevokeUserRequestRPC struct

+ Statements Statements

+ Username string

type Statements

+ func (*Statements) Descriptor() ([]byte, []int)

+ func (*Statements) ProtoMessage()

+ func (m *Statements) GetCreationStatements() string

+ func (m *Statements) GetRenewStatements() string

+ func (m *Statements) GetRevocationStatements() string

+ func (m *Statements) GetRollbackStatements() string

+ func (m *Statements) Reset()

+ func (m *Statements) String() string

+ type TypeResponse struct

+ Type string

+ func (*TypeResponse) Descriptor() ([]byte, []int)

+ func (*TypeResponse) ProtoMessage()

+ func (m *TypeResponse) GetType() string

+ func (m *TypeResponse) Reset()

+ func (m *TypeResponse) String() string

type UsernameConfig

+ func (*UsernameConfig) Descriptor() ([]byte, []int)

+ func (*UsernameConfig) ProtoMessage()

+ func (m *UsernameConfig) GetDisplayName() string

+ func (m *UsernameConfig) GetRoleName() string

+ func (m *UsernameConfig) Reset()

+ func (m *UsernameConfig) String() string

v0.9.0

Nov 14, 2017

v0.8.3

Sep 19, 2017

v0.8.2

Sep 5, 2017

v0.8.1

Aug 16, 2017

v0.8.0

Aug 9, 2017

v0.8.0-rc1

Aug 3, 2017

v0.8.0-beta1

Jul 25, 2017

v0.7.3

Jun 7, 2017

Changes in this version

type CreateUserRequest

+ UsernameConfig UsernameConfig

+ type UsernameConfig struct

+ DisplayName string

+ RoleName string

v0.7.2

May 8, 2017

v0.7.1

May 5, 2017

Changes in this version

+ func Serve(db Database, tlsProvider func() (*tls.Config, error))

+ type CreateUserRequest struct

+ Expiration time.Time

+ Statements Statements

+ UsernamePrefix string

+ type CreateUserResponse struct

+ Password string

+ Username string

+ type Database interface

+ Close func() error

+ CreateUser func(statements Statements, usernamePrefix string, expiration time.Time) (username string, password string, err error)

+ Initialize func(config map[string]interface{}, verifyConnection bool) error

+ RenewUser func(statements Statements, username string, expiration time.Time) error

+ RevokeUser func(statements Statements, username string) error

+ Type func() (string, error)

+ func PluginFactory(pluginName string, sys pluginutil.LookRunnerUtil, logger log.Logger) (Database, error)

+ type DatabasePlugin struct

+ func (DatabasePlugin) Client(b *plugin.MuxBroker, c *rpc.Client) (interface{}, error)

+ func (d DatabasePlugin) Server(*plugin.MuxBroker) (interface{}, error)

+ type DatabasePluginClient struct

+ func (dc *DatabasePluginClient) Close() error

+ func (dr DatabasePluginClient) CreateUser(statements Statements, usernamePrefix string, expiration time.Time) (username string, password string, err error)

+ func (dr DatabasePluginClient) Initialize(conf map[string]interface{}, verifyConnection bool) error

+ func (dr DatabasePluginClient) RenewUser(statements Statements, username string, expiration time.Time) error

+ func (dr DatabasePluginClient) RevokeUser(statements Statements, username string) error

+ func (dr DatabasePluginClient) Type() (string, error)

+ type InitializeRequest struct

+ Config map[string]interface{}

+ VerifyConnection bool

+ type RenewUserRequest struct

+ Expiration time.Time

+ Statements Statements

+ Username string

+ type RevokeUserRequest struct

+ Statements Statements

+ Username string

+ type Statements struct

+ CreationStatements string

+ RenewStatements string

+ RevocationStatements string

+ RollbackStatements string

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