open-vault/sdk/database/dbplugin/database.pb.go

// Code generated by protoc-gen-go. DO NOT EDIT.
// source: sdk/database/dbplugin/database.proto

package dbplugin

import (
	context "context"
	fmt "fmt"
	math "math"

	proto "github.com/golang/protobuf/proto"
	timestamp "github.com/golang/protobuf/ptypes/timestamp"
	grpc "google.golang.org/grpc"
	codes "google.golang.org/grpc/codes"
	status "google.golang.org/grpc/status"
)

// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf

// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package

// Deprecated: Do not use.
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:"-"`
}

func (m *InitializeRequest) Reset()         { *m = InitializeRequest{} }
func (m *InitializeRequest) String() string { return proto.CompactTextString(m) }
func (*InitializeRequest) ProtoMessage()    {}
func (*InitializeRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_02295ede278ca775, []int{0}
}

func (m *InitializeRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_InitializeRequest.Unmarshal(m, b)
}
func (m *InitializeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_InitializeRequest.Marshal(b, m, deterministic)
}
func (m *InitializeRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_InitializeRequest.Merge(m, src)
}
func (m *InitializeRequest) XXX_Size() int {
	return xxx_messageInfo_InitializeRequest.Size(m)
}
func (m *InitializeRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_InitializeRequest.DiscardUnknown(m)
}

var xxx_messageInfo_InitializeRequest proto.InternalMessageInfo

func (m *InitializeRequest) GetConfig() []byte {
	if m != nil {
		return m.Config
	}
	return nil
}

func (m *InitializeRequest) GetVerifyConnection() bool {
	if m != nil {
		return m.VerifyConnection
	}
	return false
}

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 (m *InitRequest) Reset()         { *m = InitRequest{} }
func (m *InitRequest) String() string { return proto.CompactTextString(m) }
func (*InitRequest) ProtoMessage()    {}
func (*InitRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_02295ede278ca775, []int{1}
}

func (m *InitRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_InitRequest.Unmarshal(m, b)
}
func (m *InitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_InitRequest.Marshal(b, m, deterministic)
}
func (m *InitRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_InitRequest.Merge(m, src)
}
func (m *InitRequest) XXX_Size() int {
	return xxx_messageInfo_InitRequest.Size(m)
}
func (m *InitRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_InitRequest.DiscardUnknown(m)
}

var xxx_messageInfo_InitRequest proto.InternalMessageInfo

func (m *InitRequest) GetConfig() []byte {
	if m != nil {
		return m.Config
	}
	return nil
}

func (m *InitRequest) GetVerifyConnection() bool {
	if m != nil {
		return m.VerifyConnection
	}
	return false
}

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 (m *CreateUserRequest) Reset()         { *m = CreateUserRequest{} }
func (m *CreateUserRequest) String() string { return proto.CompactTextString(m) }
func (*CreateUserRequest) ProtoMessage()    {}
func (*CreateUserRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_02295ede278ca775, []int{2}
}

func (m *CreateUserRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_CreateUserRequest.Unmarshal(m, b)
}
func (m *CreateUserRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_CreateUserRequest.Marshal(b, m, deterministic)
}
func (m *CreateUserRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_CreateUserRequest.Merge(m, src)
}
func (m *CreateUserRequest) XXX_Size() int {
	return xxx_messageInfo_CreateUserRequest.Size(m)
}
func (m *CreateUserRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_CreateUserRequest.DiscardUnknown(m)
}

var xxx_messageInfo_CreateUserRequest proto.InternalMessageInfo

func (m *CreateUserRequest) GetStatements() *Statements {
	if m != nil {
		return m.Statements
	}
	return nil
}

func (m *CreateUserRequest) GetUsernameConfig() *UsernameConfig {
	if m != nil {
		return m.UsernameConfig
	}
	return nil
}

func (m *CreateUserRequest) GetExpiration() *timestamp.Timestamp {
	if m != nil {
		return m.Expiration
	}
	return nil
}

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 (m *RenewUserRequest) Reset()         { *m = RenewUserRequest{} }
func (m *RenewUserRequest) String() string { return proto.CompactTextString(m) }
func (*RenewUserRequest) ProtoMessage()    {}
func (*RenewUserRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_02295ede278ca775, []int{3}
}

func (m *RenewUserRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_RenewUserRequest.Unmarshal(m, b)
}
func (m *RenewUserRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_RenewUserRequest.Marshal(b, m, deterministic)
}
func (m *RenewUserRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_RenewUserRequest.Merge(m, src)
}
func (m *RenewUserRequest) XXX_Size() int {
	return xxx_messageInfo_RenewUserRequest.Size(m)
}
func (m *RenewUserRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_RenewUserRequest.DiscardUnknown(m)
}

var xxx_messageInfo_RenewUserRequest proto.InternalMessageInfo

func (m *RenewUserRequest) GetStatements() *Statements {
	if m != nil {
		return m.Statements
	}
	return nil
}

func (m *RenewUserRequest) GetUsername() string {
	if m != nil {
		return m.Username
	}
	return ""
}

func (m *RenewUserRequest) GetExpiration() *timestamp.Timestamp {
	if m != nil {
		return m.Expiration
	}
	return nil
}

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 (m *RevokeUserRequest) Reset()         { *m = RevokeUserRequest{} }
func (m *RevokeUserRequest) String() string { return proto.CompactTextString(m) }
func (*RevokeUserRequest) ProtoMessage()    {}
func (*RevokeUserRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_02295ede278ca775, []int{4}
}

func (m *RevokeUserRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_RevokeUserRequest.Unmarshal(m, b)
}
func (m *RevokeUserRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_RevokeUserRequest.Marshal(b, m, deterministic)
}
func (m *RevokeUserRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_RevokeUserRequest.Merge(m, src)
}
func (m *RevokeUserRequest) XXX_Size() int {
	return xxx_messageInfo_RevokeUserRequest.Size(m)
}
func (m *RevokeUserRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_RevokeUserRequest.DiscardUnknown(m)
}

var xxx_messageInfo_RevokeUserRequest proto.InternalMessageInfo

func (m *RevokeUserRequest) GetStatements() *Statements {
	if m != nil {
		return m.Statements
	}
	return nil
}

func (m *RevokeUserRequest) GetUsername() string {
	if m != nil {
		return m.Username
	}
	return ""
}

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 (m *RotateRootCredentialsRequest) Reset()         { *m = RotateRootCredentialsRequest{} }
func (m *RotateRootCredentialsRequest) String() string { return proto.CompactTextString(m) }
func (*RotateRootCredentialsRequest) ProtoMessage()    {}
func (*RotateRootCredentialsRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_02295ede278ca775, []int{5}
}

func (m *RotateRootCredentialsRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_RotateRootCredentialsRequest.Unmarshal(m, b)
}
func (m *RotateRootCredentialsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_RotateRootCredentialsRequest.Marshal(b, m, deterministic)
}
func (m *RotateRootCredentialsRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_RotateRootCredentialsRequest.Merge(m, src)
}
func (m *RotateRootCredentialsRequest) XXX_Size() int {
	return xxx_messageInfo_RotateRootCredentialsRequest.Size(m)
}
func (m *RotateRootCredentialsRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_RotateRootCredentialsRequest.DiscardUnknown(m)
}

var xxx_messageInfo_RotateRootCredentialsRequest proto.InternalMessageInfo

func (m *RotateRootCredentialsRequest) GetStatements() []string {
	if m != nil {
		return m.Statements
	}
	return nil
}

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 (m *Statements) Reset()         { *m = Statements{} }
func (m *Statements) String() string { return proto.CompactTextString(m) }
func (*Statements) ProtoMessage()    {}
func (*Statements) Descriptor() ([]byte, []int) {
	return fileDescriptor_02295ede278ca775, []int{6}
}

func (m *Statements) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_Statements.Unmarshal(m, b)
}
func (m *Statements) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_Statements.Marshal(b, m, deterministic)
}
func (m *Statements) XXX_Merge(src proto.Message) {
	xxx_messageInfo_Statements.Merge(m, src)
}
func (m *Statements) XXX_Size() int {
	return xxx_messageInfo_Statements.Size(m)
}
func (m *Statements) XXX_DiscardUnknown() {
	xxx_messageInfo_Statements.DiscardUnknown(m)
}

var xxx_messageInfo_Statements proto.InternalMessageInfo

// Deprecated: Do not use.
func (m *Statements) GetCreationStatements() string {
	if m != nil {
		return m.CreationStatements
	}
	return ""
}

// Deprecated: Do not use.
func (m *Statements) GetRevocationStatements() string {
	if m != nil {
		return m.RevocationStatements
	}
	return ""
}

// Deprecated: Do not use.
func (m *Statements) GetRollbackStatements() string {
	if m != nil {
		return m.RollbackStatements
	}
	return ""
}

// Deprecated: Do not use.
func (m *Statements) GetRenewStatements() string {
	if m != nil {
		return m.RenewStatements
	}
	return ""
}

func (m *Statements) GetCreation() []string {
	if m != nil {
		return m.Creation
	}
	return nil
}

func (m *Statements) GetRevocation() []string {
	if m != nil {
		return m.Revocation
	}
	return nil
}

func (m *Statements) GetRollback() []string {
	if m != nil {
		return m.Rollback
	}
	return nil
}

func (m *Statements) GetRenewal() []string {
	if m != nil {
		return m.Renewal
	}
	return nil
}

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 (m *UsernameConfig) Reset()         { *m = UsernameConfig{} }
func (m *UsernameConfig) String() string { return proto.CompactTextString(m) }
func (*UsernameConfig) ProtoMessage()    {}
func (*UsernameConfig) Descriptor() ([]byte, []int) {
	return fileDescriptor_02295ede278ca775, []int{7}
}

func (m *UsernameConfig) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_UsernameConfig.Unmarshal(m, b)
}
func (m *UsernameConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_UsernameConfig.Marshal(b, m, deterministic)
}
func (m *UsernameConfig) XXX_Merge(src proto.Message) {
	xxx_messageInfo_UsernameConfig.Merge(m, src)
}
func (m *UsernameConfig) XXX_Size() int {
	return xxx_messageInfo_UsernameConfig.Size(m)
}
func (m *UsernameConfig) XXX_DiscardUnknown() {
	xxx_messageInfo_UsernameConfig.DiscardUnknown(m)
}

var xxx_messageInfo_UsernameConfig proto.InternalMessageInfo

func (m *UsernameConfig) GetDisplayName() string {
	if m != nil {
		return m.DisplayName
	}
	return ""
}

func (m *UsernameConfig) GetRoleName() string {
	if m != nil {
		return m.RoleName
	}
	return ""
}

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 (m *InitResponse) Reset()         { *m = InitResponse{} }
func (m *InitResponse) String() string { return proto.CompactTextString(m) }
func (*InitResponse) ProtoMessage()    {}
func (*InitResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_02295ede278ca775, []int{8}
}

func (m *InitResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_InitResponse.Unmarshal(m, b)
}
func (m *InitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_InitResponse.Marshal(b, m, deterministic)
}
func (m *InitResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_InitResponse.Merge(m, src)
}
func (m *InitResponse) XXX_Size() int {
	return xxx_messageInfo_InitResponse.Size(m)
}
func (m *InitResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_InitResponse.DiscardUnknown(m)
}

var xxx_messageInfo_InitResponse proto.InternalMessageInfo

func (m *InitResponse) GetConfig() []byte {
	if m != nil {
		return m.Config
	}
	return nil
}

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 (m *CreateUserResponse) Reset()         { *m = CreateUserResponse{} }
func (m *CreateUserResponse) String() string { return proto.CompactTextString(m) }
func (*CreateUserResponse) ProtoMessage()    {}
func (*CreateUserResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_02295ede278ca775, []int{9}
}

func (m *CreateUserResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_CreateUserResponse.Unmarshal(m, b)
}
func (m *CreateUserResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_CreateUserResponse.Marshal(b, m, deterministic)
}
func (m *CreateUserResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_CreateUserResponse.Merge(m, src)
}
func (m *CreateUserResponse) XXX_Size() int {
	return xxx_messageInfo_CreateUserResponse.Size(m)
}
func (m *CreateUserResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_CreateUserResponse.DiscardUnknown(m)
}

var xxx_messageInfo_CreateUserResponse proto.InternalMessageInfo

func (m *CreateUserResponse) GetUsername() string {
	if m != nil {
		return m.Username
	}
	return ""
}

func (m *CreateUserResponse) GetPassword() string {
	if m != nil {
		return m.Password
	}
	return ""
}

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 (m *TypeResponse) Reset()         { *m = TypeResponse{} }
func (m *TypeResponse) String() string { return proto.CompactTextString(m) }
func (*TypeResponse) ProtoMessage()    {}
func (*TypeResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_02295ede278ca775, []int{10}
}

func (m *TypeResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_TypeResponse.Unmarshal(m, b)
}
func (m *TypeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_TypeResponse.Marshal(b, m, deterministic)
}
func (m *TypeResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_TypeResponse.Merge(m, src)
}
func (m *TypeResponse) XXX_Size() int {
	return xxx_messageInfo_TypeResponse.Size(m)
}
func (m *TypeResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_TypeResponse.DiscardUnknown(m)
}

var xxx_messageInfo_TypeResponse proto.InternalMessageInfo

func (m *TypeResponse) GetType() string {
	if m != nil {
		return m.Type
	}
	return ""
}

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 (m *RotateRootCredentialsResponse) Reset()         { *m = RotateRootCredentialsResponse{} }
func (m *RotateRootCredentialsResponse) String() string { return proto.CompactTextString(m) }
func (*RotateRootCredentialsResponse) ProtoMessage()    {}
func (*RotateRootCredentialsResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_02295ede278ca775, []int{11}
}

func (m *RotateRootCredentialsResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_RotateRootCredentialsResponse.Unmarshal(m, b)
}
func (m *RotateRootCredentialsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_RotateRootCredentialsResponse.Marshal(b, m, deterministic)
}
func (m *RotateRootCredentialsResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_RotateRootCredentialsResponse.Merge(m, src)
}
func (m *RotateRootCredentialsResponse) XXX_Size() int {
	return xxx_messageInfo_RotateRootCredentialsResponse.Size(m)
}
func (m *RotateRootCredentialsResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_RotateRootCredentialsResponse.DiscardUnknown(m)
}

var xxx_messageInfo_RotateRootCredentialsResponse proto.InternalMessageInfo

func (m *RotateRootCredentialsResponse) GetConfig() []byte {
	if m != nil {
		return m.Config
	}
	return nil
}

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

func (m *Empty) Reset()         { *m = Empty{} }
func (m *Empty) String() string { return proto.CompactTextString(m) }
func (*Empty) ProtoMessage()    {}
func (*Empty) Descriptor() ([]byte, []int) {
	return fileDescriptor_02295ede278ca775, []int{12}
}

func (m *Empty) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_Empty.Unmarshal(m, b)
}
func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_Empty.Marshal(b, m, deterministic)
}
func (m *Empty) XXX_Merge(src proto.Message) {
	xxx_messageInfo_Empty.Merge(m, src)
}
func (m *Empty) XXX_Size() int {
	return xxx_messageInfo_Empty.Size(m)
}
func (m *Empty) XXX_DiscardUnknown() {
	xxx_messageInfo_Empty.DiscardUnknown(m)
}

var xxx_messageInfo_Empty proto.InternalMessageInfo

func init() {
	proto.RegisterType((*InitializeRequest)(nil), "dbplugin.InitializeRequest")
	proto.RegisterType((*InitRequest)(nil), "dbplugin.InitRequest")
	proto.RegisterType((*CreateUserRequest)(nil), "dbplugin.CreateUserRequest")
	proto.RegisterType((*RenewUserRequest)(nil), "dbplugin.RenewUserRequest")
	proto.RegisterType((*RevokeUserRequest)(nil), "dbplugin.RevokeUserRequest")
	proto.RegisterType((*RotateRootCredentialsRequest)(nil), "dbplugin.RotateRootCredentialsRequest")
	proto.RegisterType((*Statements)(nil), "dbplugin.Statements")
	proto.RegisterType((*UsernameConfig)(nil), "dbplugin.UsernameConfig")
	proto.RegisterType((*InitResponse)(nil), "dbplugin.InitResponse")
	proto.RegisterType((*CreateUserResponse)(nil), "dbplugin.CreateUserResponse")
	proto.RegisterType((*TypeResponse)(nil), "dbplugin.TypeResponse")
	proto.RegisterType((*RotateRootCredentialsResponse)(nil), "dbplugin.RotateRootCredentialsResponse")
	proto.RegisterType((*Empty)(nil), "dbplugin.Empty")
}

func init() { proto.RegisterFile("sdk/database/dbplugin/database.proto", fileDescriptor_02295ede278ca775) }

var fileDescriptor_02295ede278ca775 = []byte{
	// 713 bytes of a gzipped FileDescriptorProto
	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x55, 0xdd, 0x4e, 0xdb, 0x4a,
	0x10, 0x96, 0x93, 0x00, 0xc9, 0x80, 0x80, 0xec, 0x01, 0x64, 0x19, 0xce, 0x39, 0xc8, 0x17, 0xfc,
	0xa8, 0xaa, 0x2d, 0x41, 0x2b, 0x2a, 0x2e, 0x5a, 0x95, 0x50, 0x55, 0x95, 0x2a, 0x2e, 0x16, 0xb8,
	0xa9, 0x2a, 0xa1, 0x8d, 0xb3, 0x24, 0x16, 0x8e, 0xd7, 0xf5, 0xae, 0x43, 0xd3, 0x17, 0x68, 0x1f,
	0xa3, 0x8f, 0xd3, 0xcb, 0x3e, 0x52, 0xe5, 0x8d, 0xd7, 0xbb, 0x89, 0xa1, 0x5c, 0xd0, 0xde, 0x79,
	0x76, 0xe6, 0x9b, 0xf9, 0xe6, 0xf3, 0xec, 0x2c, 0x6c, 0xf2, 0xde, 0x8d, 0xdf, 0xeb, 0x26, 0x51,
	0xd6, 0x0f, 0x63, 0xbf, 0x47, 0x04, 0xe9, 0x12, 0x4e, 0xbd, 0x24, 0x65, 0x82, 0xa1, 0xa6, 0x72,
	0x38, 0xff, 0xf7, 0x19, 0xeb, 0x47, 0xd4, 0x97, 0xe7, 0xdd, 0xec, 0xda, 0x17, 0xe1, 0x90, 0x72,
	0x41, 0x86, 0xc9, 0x24, 0xd4, 0xfd, 0x08, 0xed, 0x77, 0x71, 0x28, 0x42, 0x12, 0x85, 0x5f, 0x28,
	0xa6, 0x9f, 0x32, 0xca, 0x05, 0xda, 0x80, 0xf9, 0x80, 0xc5, 0xd7, 0x61, 0xdf, 0xb6, 0xb6, 0xad,
	0xbd, 0x25, 0x5c, 0x58, 0xe8, 0x09, 0xb4, 0x47, 0x34, 0x0d, 0xaf, 0xc7, 0x57, 0x01, 0x8b, 0x63,
	0x1a, 0x88, 0x90, 0xc5, 0x76, 0x6d, 0xdb, 0xda, 0x6b, 0xe2, 0xd5, 0x89, 0xa3, 0x53, 0x9e, 0x1f,
	0xd7, 0x6c, 0xcb, 0xc5, 0xb0, 0x98, 0x67, 0xff, 0x93, 0x79, 0xdd, 0x1f, 0x16, 0xb4, 0x3b, 0x29,
	0x25, 0x82, 0x5e, 0x72, 0x9a, 0xaa, 0xd4, 0xcf, 0x00, 0xb8, 0x20, 0x82, 0x0e, 0x69, 0x2c, 0xb8,
	0x4c, 0xbf, 0x78, 0xb0, 0xe6, 0x29, 0x1d, 0xbc, 0xf3, 0xd2, 0x87, 0x8d, 0x38, 0xf4, 0x1a, 0x56,
	0x32, 0x4e, 0xd3, 0x98, 0x0c, 0xe9, 0x55, 0xc1, 0xac, 0x26, 0xa1, 0xb6, 0x86, 0x5e, 0x16, 0x01,
	0x1d, 0xe9, 0xc7, 0xcb, 0xd9, 0x94, 0x8d, 0x8e, 0x01, 0xe8, 0xe7, 0x24, 0x4c, 0x89, 0x24, 0x5d,
	0x97, 0x68, 0xc7, 0x9b, 0xc8, 0xee, 0x29, 0xd9, 0xbd, 0x0b, 0x25, 0x3b, 0x36, 0xa2, 0xdd, 0xef,
	0x16, 0xac, 0x62, 0x1a, 0xd3, 0xdb, 0xc7, 0x77, 0xe2, 0x40, 0x53, 0x11, 0x93, 0x2d, 0xb4, 0x70,
	0x69, 0x3f, 0x8a, 0x22, 0x85, 0x36, 0xa6, 0x23, 0x76, 0x43, 0xff, 0x2a, 0x45, 0xf7, 0x25, 0x6c,
	0x61, 0x96, 0x87, 0x62, 0xc6, 0x44, 0x27, 0xa5, 0x3d, 0x1a, 0xe7, 0x33, 0xc9, 0x55, 0xc5, 0xff,
	0x66, 0x2a, 0xd6, 0xf7, 0x5a, 0x66, 0x6e, 0xf7, 0x67, 0x0d, 0x40, 0x97, 0x45, 0x87, 0xf0, 0x4f,
	0x90, 0x8f, 0x48, 0xc8, 0xe2, 0xab, 0x19, 0xa6, 0xad, 0x93, 0x9a, 0x6d, 0x61, 0xa4, 0xdc, 0x06,
	0xe8, 0x08, 0xd6, 0x53, 0x3a, 0x62, 0x41, 0x05, 0x56, 0x2b, 0x61, 0x6b, 0x3a, 0x60, 0xba, 0x5a,
	0xca, 0xa2, 0xa8, 0x4b, 0x82, 0x1b, 0x13, 0x56, 0xd7, 0xd5, 0x94, 0xdb, 0x00, 0x3d, 0x85, 0xd5,
	0x34, 0xff, 0xf5, 0x26, 0xa2, 0x51, 0x22, 0x56, 0xa4, 0xef, 0x7c, 0x4a, 0x3c, 0x45, 0xd9, 0x9e,
	0x93, 0xed, 0x97, 0x76, 0x2e, 0x8e, 0xe6, 0x65, 0xcf, 0x4f, 0xc4, 0xd1, 0x27, 0x39, 0x56, 0x11,
	0xb0, 0x17, 0x26, 0x58, 0x65, 0x23, 0x1b, 0x16, 0x64, 0x29, 0x12, 0xd9, 0x4d, 0xe9, 0x52, 0xa6,
	0x7b, 0x06, 0xcb, 0xd3, 0xa3, 0x8f, 0xb6, 0x61, 0xf1, 0x34, 0xe4, 0x49, 0x44, 0xc6, 0x67, 0xf9,
	0x3f, 0x94, 0x6a, 0x62, 0xf3, 0x28, 0xaf, 0x84, 0x59, 0x44, 0xcf, 0x8c, 0x5f, 0xac, 0x6c, 0x77,
	0x07, 0x96, 0x26, 0xbb, 0x80, 0x27, 0x2c, 0xe6, 0xf4, 0xbe, 0x65, 0xe0, 0xbe, 0x07, 0x64, 0x5e,
	0xef, 0x22, 0xda, 0x1c, 0x1e, 0x6b, 0x66, 0xbe, 0x1d, 0x68, 0x26, 0x84, 0xf3, 0x5b, 0x96, 0xf6,
	0x54, 0x55, 0x65, 0xbb, 0x2e, 0x2c, 0x5d, 0x8c, 0x13, 0x5a, 0xe6, 0x41, 0xd0, 0x10, 0xe3, 0x44,
	0xe5, 0x90, 0xdf, 0xee, 0x11, 0xfc, 0x7b, 0xcf, 0xf0, 0x3d, 0x40, 0x75, 0x01, 0xe6, 0xde, 0x0c,
	0x13, 0x31, 0x3e, 0xf8, 0xda, 0x80, 0xe6, 0x69, 0xb1, 0x83, 0x91, 0x0f, 0x8d, 0xbc, 0x24, 0x5a,
	0xd1, 0x37, 0x42, 0x46, 0x39, 0x1b, 0xfa, 0x60, 0x8a, 0xd3, 0x5b, 0x00, 0xdd, 0x31, 0xda, 0xd4,
	0x51, 0x95, 0x35, 0xe7, 0x6c, 0xdd, 0xed, 0x2c, 0x12, 0xbd, 0x80, 0x56, 0xb9, 0x4e, 0x90, 0xa3,
	0x43, 0x67, 0x77, 0x8c, 0x33, 0x4b, 0x2d, 0x5f, 0x11, 0xfa, 0x9a, 0x9b, 0x14, 0x2a, 0x97, 0xbf,
	0x8a, 0x1d, 0xc0, 0xfa, 0x9d, 0xf2, 0xa1, 0x1d, 0x23, 0xcd, 0x6f, 0x2e, 0xb7, 0xb3, 0xfb, 0x60,
	0x5c, 0xd1, 0xdf, 0x73, 0x68, 0xe4, 0x23, 0x84, 0xd6, 0x35, 0xc0, 0x78, 0x5e, 0x4c, 0x7d, 0xa7,
	0x26, 0x6d, 0x1f, 0xe6, 0x3a, 0x11, 0xe3, 0x77, 0xfc, 0x91, 0x4a, 0x2f, 0xaf, 0x00, 0xf4, 0x73,
	0x68, 0xea, 0x50, 0x79, 0x24, 0x2b, 0x58, 0xb7, 0xfe, 0xad, 0x66, 0x9d, 0xec, 0x7f, 0xd8, 0xed,
	0x87, 0x62, 0x90, 0x75, 0xbd, 0x80, 0x0d, 0xfd, 0x01, 0xe1, 0x83, 0x30, 0x60, 0x69, 0xe2, 0x8f,
	0x48, 0x16, 0x09, 0xdf, 0x7c, 0xb4, 0xbb, 0xf3, 0x72, 0xf5, 0x1e, 0xfe, 0x0a, 0x00, 0x00, 0xff,
	0xff, 0x52, 0xc0, 0xd3, 0x64, 0xcb, 0x07, 0x00, 0x00,
}

// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConn

// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion4

// 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.
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)
}

type databaseClient struct {
	cc *grpc.ClientConn
}

func NewDatabaseClient(cc *grpc.ClientConn) DatabaseClient {
	return &databaseClient{cc}
}

func (c *databaseClient) Type(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*TypeResponse, error) {
	out := new(TypeResponse)
	err := c.cc.Invoke(ctx, "/dbplugin.Database/Type", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseClient) CreateUser(ctx context.Context, in *CreateUserRequest, opts ...grpc.CallOption) (*CreateUserResponse, error) {
	out := new(CreateUserResponse)
	err := c.cc.Invoke(ctx, "/dbplugin.Database/CreateUser", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseClient) RenewUser(ctx context.Context, in *RenewUserRequest, opts ...grpc.CallOption) (*Empty, error) {
	out := new(Empty)
	err := c.cc.Invoke(ctx, "/dbplugin.Database/RenewUser", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseClient) RevokeUser(ctx context.Context, in *RevokeUserRequest, opts ...grpc.CallOption) (*Empty, error) {
	out := new(Empty)
	err := c.cc.Invoke(ctx, "/dbplugin.Database/RevokeUser", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseClient) RotateRootCredentials(ctx context.Context, in *RotateRootCredentialsRequest, opts ...grpc.CallOption) (*RotateRootCredentialsResponse, error) {
	out := new(RotateRootCredentialsResponse)
	err := c.cc.Invoke(ctx, "/dbplugin.Database/RotateRootCredentials", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseClient) Init(ctx context.Context, in *InitRequest, opts ...grpc.CallOption) (*InitResponse, error) {
	out := new(InitResponse)
	err := c.cc.Invoke(ctx, "/dbplugin.Database/Init", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseClient) Close(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) {
	out := new(Empty)
	err := c.cc.Invoke(ctx, "/dbplugin.Database/Close", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// Deprecated: Do not use.
func (c *databaseClient) Initialize(ctx context.Context, in *InitializeRequest, opts ...grpc.CallOption) (*Empty, error) {
	out := new(Empty)
	err := c.cc.Invoke(ctx, "/dbplugin.Database/Initialize", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// DatabaseServer is the server API for Database service.
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)
}

// UnimplementedDatabaseServer can be embedded to have forward compatible implementations.
type UnimplementedDatabaseServer struct {
}

func (*UnimplementedDatabaseServer) Type(ctx context.Context, req *Empty) (*TypeResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Type not implemented")
}
func (*UnimplementedDatabaseServer) CreateUser(ctx context.Context, req *CreateUserRequest) (*CreateUserResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateUser not implemented")
}
func (*UnimplementedDatabaseServer) RenewUser(ctx context.Context, req *RenewUserRequest) (*Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RenewUser not implemented")
}
func (*UnimplementedDatabaseServer) RevokeUser(ctx context.Context, req *RevokeUserRequest) (*Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RevokeUser not implemented")
}
func (*UnimplementedDatabaseServer) RotateRootCredentials(ctx context.Context, req *RotateRootCredentialsRequest) (*RotateRootCredentialsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RotateRootCredentials not implemented")
}
func (*UnimplementedDatabaseServer) Init(ctx context.Context, req *InitRequest) (*InitResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Init not implemented")
}
func (*UnimplementedDatabaseServer) Close(ctx context.Context, req *Empty) (*Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Close not implemented")
}
func (*UnimplementedDatabaseServer) Initialize(ctx context.Context, req *InitializeRequest) (*Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Initialize not implemented")
}

func RegisterDatabaseServer(s *grpc.Server, srv DatabaseServer) {
	s.RegisterService(&_Database_serviceDesc, srv)
}

func _Database_Type_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServer).Type(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dbplugin.Database/Type",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServer).Type(ctx, req.(*Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _Database_CreateUser_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateUserRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServer).CreateUser(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dbplugin.Database/CreateUser",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServer).CreateUser(ctx, req.(*CreateUserRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Database_RenewUser_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RenewUserRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServer).RenewUser(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dbplugin.Database/RenewUser",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServer).RenewUser(ctx, req.(*RenewUserRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Database_RevokeUser_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RevokeUserRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServer).RevokeUser(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dbplugin.Database/RevokeUser",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServer).RevokeUser(ctx, req.(*RevokeUserRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Database_RotateRootCredentials_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RotateRootCredentialsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServer).RotateRootCredentials(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dbplugin.Database/RotateRootCredentials",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServer).RotateRootCredentials(ctx, req.(*RotateRootCredentialsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Database_Init_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(InitRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServer).Init(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dbplugin.Database/Init",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServer).Init(ctx, req.(*InitRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Database_Close_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServer).Close(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dbplugin.Database/Close",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServer).Close(ctx, req.(*Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _Database_Initialize_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(InitializeRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServer).Initialize(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dbplugin.Database/Initialize",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServer).Initialize(ctx, req.(*InitializeRequest))
	}
	return interceptor(ctx, in, info, handler)
}

var _Database_serviceDesc = grpc.ServiceDesc{
	ServiceName: "dbplugin.Database",
	HandlerType: (*DatabaseServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Type",
			Handler:    _Database_Type_Handler,
		},
		{
			MethodName: "CreateUser",
			Handler:    _Database_CreateUser_Handler,
		},
		{
			MethodName: "RenewUser",
			Handler:    _Database_RenewUser_Handler,
		},
		{
			MethodName: "RevokeUser",
			Handler:    _Database_RevokeUser_Handler,
		},
		{
			MethodName: "RotateRootCredentials",
			Handler:    _Database_RotateRootCredentials_Handler,
		},
		{
			MethodName: "Init",
			Handler:    _Database_Init_Handler,
		},
		{
			MethodName: "Close",
			Handler:    _Database_Close_Handler,
		},
		{
			MethodName: "Initialize",
			Handler:    _Database_Initialize_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "sdk/database/dbplugin/database.proto",
}