database

package
v0.3.3 Latest Latest
Warning

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

 Go to latest Published: Nov 17, 2020 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthDatabase        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDatabase          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDatabase = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterDatabaseServiceServer 

func RegisterDatabaseServiceServer(s *grpc.Server, srv DatabaseServiceServer)

Types

type Database 

type Database struct {
	// id is the database identifier
	ID DatabaseId `protobuf:"bytes,1,opt,name=id,proto3" json:"id"`
	// partitions is a list of partitions in the cluster
	Partitions []Partition `protobuf:"bytes,2,rep,name=partitions,proto3" json:"partitions"`
}

Database configuration

func (*Database) Descriptor 

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

func (*Database) GetID 

func (m *Database) GetID() DatabaseId

func (*Database) GetPartitions 

func (m *Database) GetPartitions() []Partition

func (*Database) Marshal 

func (m *Database) Marshal() (dAtA []byte, err error)

func (*Database) MarshalTo 

func (m *Database) MarshalTo(dAtA []byte) (int, error)

func (*Database) MarshalToSizedBuffer 

func (m *Database) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Database) ProtoMessage 

func (*Database) ProtoMessage()

func (*Database) Reset 

func (m *Database) Reset()

func (*Database) Size 

func (m *Database) Size() (n int)

func (*Database) String 

func (m *Database) String() string

func (*Database) Unmarshal 

func (m *Database) Unmarshal(dAtA []byte) error

func (*Database) XXX_DiscardUnknown 

func (m *Database) XXX_DiscardUnknown()

func (*Database) XXX_Marshal 

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

func (*Database) XXX_Merge 

func (m *Database) XXX_Merge(src proto.Message)

func (*Database) XXX_Size 

func (m *Database) XXX_Size() int

func (*Database) XXX_Unmarshal 

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

type DatabaseConfig 

type DatabaseConfig struct {
	// nodes is a list of database replicas
	Replicas []ReplicaConfig `protobuf:"bytes,1,rep,name=replicas,proto3" json:"replicas"`
	// partitions is a list of partitions owned by the replicas
	Partitions []PartitionId `protobuf:"bytes,2,rep,name=partitions,proto3" json:"partitions"`
}

Database configuration

func (*DatabaseConfig) Descriptor 

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

func (*DatabaseConfig) GetPartitions 

func (m *DatabaseConfig) GetPartitions() []PartitionId

func (*DatabaseConfig) GetReplicas 

func (m *DatabaseConfig) GetReplicas() []ReplicaConfig

func (*DatabaseConfig) Marshal 

func (m *DatabaseConfig) Marshal() (dAtA []byte, err error)

func (*DatabaseConfig) MarshalTo 

func (m *DatabaseConfig) MarshalTo(dAtA []byte) (int, error)

func (*DatabaseConfig) MarshalToSizedBuffer 

func (m *DatabaseConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DatabaseConfig) ProtoMessage 

func (*DatabaseConfig) ProtoMessage()

func (*DatabaseConfig) Reset 

func (m *DatabaseConfig) Reset()

func (*DatabaseConfig) Size 

func (m *DatabaseConfig) Size() (n int)

func (*DatabaseConfig) String 

func (m *DatabaseConfig) String() string

func (*DatabaseConfig) Unmarshal 

func (m *DatabaseConfig) Unmarshal(dAtA []byte) error

func (*DatabaseConfig) XXX_DiscardUnknown 

func (m *DatabaseConfig) XXX_DiscardUnknown()

func (*DatabaseConfig) XXX_Marshal 

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

func (*DatabaseConfig) XXX_Merge 

func (m *DatabaseConfig) XXX_Merge(src proto.Message)

func (*DatabaseConfig) XXX_Size 

func (m *DatabaseConfig) XXX_Size() int

func (*DatabaseConfig) XXX_Unmarshal 

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

type DatabaseId 

type DatabaseId struct {
	// name is the name of the database
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// namespace is the namespace to which the database belongs
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
}

Database identifier

func (*DatabaseId) Descriptor 

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

func (*DatabaseId) GetName 

func (m *DatabaseId) GetName() string

func (*DatabaseId) GetNamespace 

func (m *DatabaseId) GetNamespace() string

func (*DatabaseId) Marshal 

func (m *DatabaseId) Marshal() (dAtA []byte, err error)

func (*DatabaseId) MarshalTo 

func (m *DatabaseId) MarshalTo(dAtA []byte) (int, error)

func (*DatabaseId) MarshalToSizedBuffer 

func (m *DatabaseId) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DatabaseId) ProtoMessage 

func (*DatabaseId) ProtoMessage()

func (*DatabaseId) Reset 

func (m *DatabaseId) Reset()

func (*DatabaseId) Size 

func (m *DatabaseId) Size() (n int)

func (*DatabaseId) String 

func (m *DatabaseId) String() string

func (*DatabaseId) Unmarshal 

func (m *DatabaseId) Unmarshal(dAtA []byte) error

func (*DatabaseId) XXX_DiscardUnknown 

func (m *DatabaseId) XXX_DiscardUnknown()

func (*DatabaseId) XXX_Marshal 

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

func (*DatabaseId) XXX_Merge 

func (m *DatabaseId) XXX_Merge(src proto.Message)

func (*DatabaseId) XXX_Size 

func (m *DatabaseId) XXX_Size() int

func (*DatabaseId) XXX_Unmarshal 

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

type DatabaseServiceClient 

type DatabaseServiceClient interface {
	// GetDatabase gets a database controlled by the controller
	GetDatabase(ctx context.Context, in *GetDatabaseRequest, opts ...grpc.CallOption) (*GetDatabaseResponse, error)
	// GetDatabases gets a list of databases controlled by the controller
	GetDatabases(ctx context.Context, in *GetDatabasesRequest, opts ...grpc.CallOption) (*GetDatabasesResponse, error)
}

DatabaseServiceClient is the client API for DatabaseService service.

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

func NewDatabaseServiceClient 

func NewDatabaseServiceClient(cc *grpc.ClientConn) DatabaseServiceClient

type DatabaseServiceServer 

type DatabaseServiceServer interface {
	// GetDatabase gets a database controlled by the controller
	GetDatabase(context.Context, *GetDatabaseRequest) (*GetDatabaseResponse, error)
	// GetDatabases gets a list of databases controlled by the controller
	GetDatabases(context.Context, *GetDatabasesRequest) (*GetDatabasesResponse, error)
}

DatabaseServiceServer is the server API for DatabaseService service.

type GetDatabaseRequest 

type GetDatabaseRequest struct {
	ID DatabaseId `protobuf:"bytes,1,opt,name=id,proto3" json:"id"`
}

Gets a database in a namespace

func (*GetDatabaseRequest) Descriptor 

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

func (*GetDatabaseRequest) GetID 

func (m *GetDatabaseRequest) GetID() DatabaseId

func (*GetDatabaseRequest) Marshal 

func (m *GetDatabaseRequest) Marshal() (dAtA []byte, err error)

func (*GetDatabaseRequest) MarshalTo 

func (m *GetDatabaseRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetDatabaseRequest) MarshalToSizedBuffer 

func (m *GetDatabaseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetDatabaseRequest) ProtoMessage 

func (*GetDatabaseRequest) ProtoMessage()

func (*GetDatabaseRequest) Reset 

func (m *GetDatabaseRequest) Reset()

func (*GetDatabaseRequest) Size 

func (m *GetDatabaseRequest) Size() (n int)

func (*GetDatabaseRequest) String 

func (m *GetDatabaseRequest) String() string

func (*GetDatabaseRequest) Unmarshal 

func (m *GetDatabaseRequest) Unmarshal(dAtA []byte) error

func (*GetDatabaseRequest) XXX_DiscardUnknown 

func (m *GetDatabaseRequest) XXX_DiscardUnknown()

func (*GetDatabaseRequest) XXX_Marshal 

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

func (*GetDatabaseRequest) XXX_Merge 

func (m *GetDatabaseRequest) XXX_Merge(src proto.Message)

func (*GetDatabaseRequest) XXX_Size 

func (m *GetDatabaseRequest) XXX_Size() int

func (*GetDatabaseRequest) XXX_Unmarshal 

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

type GetDatabaseResponse 

type GetDatabaseResponse struct {
	Database *Database `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
}

Returns a database in a namespace

func (*GetDatabaseResponse) Descriptor 

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

func (*GetDatabaseResponse) GetDatabase 

func (m *GetDatabaseResponse) GetDatabase() *Database

func (*GetDatabaseResponse) Marshal 

func (m *GetDatabaseResponse) Marshal() (dAtA []byte, err error)

func (*GetDatabaseResponse) MarshalTo 

func (m *GetDatabaseResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetDatabaseResponse) MarshalToSizedBuffer 

func (m *GetDatabaseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetDatabaseResponse) ProtoMessage 

func (*GetDatabaseResponse) ProtoMessage()

func (*GetDatabaseResponse) Reset 

func (m *GetDatabaseResponse) Reset()

func (*GetDatabaseResponse) Size 

func (m *GetDatabaseResponse) Size() (n int)

func (*GetDatabaseResponse) String 

func (m *GetDatabaseResponse) String() string

func (*GetDatabaseResponse) Unmarshal 

func (m *GetDatabaseResponse) Unmarshal(dAtA []byte) error

func (*GetDatabaseResponse) XXX_DiscardUnknown 

func (m *GetDatabaseResponse) XXX_DiscardUnknown()

func (*GetDatabaseResponse) XXX_Marshal 

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

func (*GetDatabaseResponse) XXX_Merge 

func (m *GetDatabaseResponse) XXX_Merge(src proto.Message)

func (*GetDatabaseResponse) XXX_Size 

func (m *GetDatabaseResponse) XXX_Size() int

func (*GetDatabaseResponse) XXX_Unmarshal 

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

type GetDatabasesRequest 

type GetDatabasesRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
}

Gets a list of databases in a namespace

func (*GetDatabasesRequest) Descriptor 

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

func (*GetDatabasesRequest) GetNamespace 

func (m *GetDatabasesRequest) GetNamespace() string

func (*GetDatabasesRequest) Marshal 

func (m *GetDatabasesRequest) Marshal() (dAtA []byte, err error)

func (*GetDatabasesRequest) MarshalTo 

func (m *GetDatabasesRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetDatabasesRequest) MarshalToSizedBuffer 

func (m *GetDatabasesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetDatabasesRequest) ProtoMessage 

func (*GetDatabasesRequest) ProtoMessage()

func (*GetDatabasesRequest) Reset 

func (m *GetDatabasesRequest) Reset()

func (*GetDatabasesRequest) Size 

func (m *GetDatabasesRequest) Size() (n int)

func (*GetDatabasesRequest) String 

func (m *GetDatabasesRequest) String() string

func (*GetDatabasesRequest) Unmarshal 

func (m *GetDatabasesRequest) Unmarshal(dAtA []byte) error

func (*GetDatabasesRequest) XXX_DiscardUnknown 

func (m *GetDatabasesRequest) XXX_DiscardUnknown()

func (*GetDatabasesRequest) XXX_Marshal 

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

func (*GetDatabasesRequest) XXX_Merge 

func (m *GetDatabasesRequest) XXX_Merge(src proto.Message)

func (*GetDatabasesRequest) XXX_Size 

func (m *GetDatabasesRequest) XXX_Size() int

func (*GetDatabasesRequest) XXX_Unmarshal 

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

type GetDatabasesResponse 

type GetDatabasesResponse struct {
	Databases []Database `protobuf:"bytes,1,rep,name=databases,proto3" json:"databases"`
}

Returns a list of databases in a namespace

func (*GetDatabasesResponse) Descriptor 

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

func (*GetDatabasesResponse) GetDatabases 

func (m *GetDatabasesResponse) GetDatabases() []Database

func (*GetDatabasesResponse) Marshal 

func (m *GetDatabasesResponse) Marshal() (dAtA []byte, err error)

func (*GetDatabasesResponse) MarshalTo 

func (m *GetDatabasesResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetDatabasesResponse) MarshalToSizedBuffer 

func (m *GetDatabasesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetDatabasesResponse) ProtoMessage 

func (*GetDatabasesResponse) ProtoMessage()

func (*GetDatabasesResponse) Reset 

func (m *GetDatabasesResponse) Reset()

func (*GetDatabasesResponse) Size 

func (m *GetDatabasesResponse) Size() (n int)

func (*GetDatabasesResponse) String 

func (m *GetDatabasesResponse) String() string

func (*GetDatabasesResponse) Unmarshal 

func (m *GetDatabasesResponse) Unmarshal(dAtA []byte) error

func (*GetDatabasesResponse) XXX_DiscardUnknown 

func (m *GetDatabasesResponse) XXX_DiscardUnknown()

func (*GetDatabasesResponse) XXX_Marshal 

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

func (*GetDatabasesResponse) XXX_Merge 

func (m *GetDatabasesResponse) XXX_Merge(src proto.Message)

func (*GetDatabasesResponse) XXX_Size 

func (m *GetDatabasesResponse) XXX_Size() int

func (*GetDatabasesResponse) XXX_Unmarshal 

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

type Partition 

type Partition struct {
	PartitionID PartitionId         `protobuf:"bytes,1,opt,name=partition_id,json=partitionId,proto3" json:"partition_id"`
	Endpoints   []PartitionEndpoint `protobuf:"bytes,2,rep,name=endpoints,proto3" json:"endpoints"`
}

Partition info

func (*Partition) Descriptor 

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

func (*Partition) GetEndpoints 

func (m *Partition) GetEndpoints() []PartitionEndpoint

func (*Partition) GetPartitionID 

func (m *Partition) GetPartitionID() PartitionId

func (*Partition) Marshal 

func (m *Partition) Marshal() (dAtA []byte, err error)

func (*Partition) MarshalTo 

func (m *Partition) MarshalTo(dAtA []byte) (int, error)

func (*Partition) MarshalToSizedBuffer 

func (m *Partition) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Partition) ProtoMessage 

func (*Partition) ProtoMessage()

func (*Partition) Reset 

func (m *Partition) Reset()

func (*Partition) Size 

func (m *Partition) Size() (n int)

func (*Partition) String 

func (m *Partition) String() string

func (*Partition) Unmarshal 

func (m *Partition) Unmarshal(dAtA []byte) error

func (*Partition) XXX_DiscardUnknown 

func (m *Partition) XXX_DiscardUnknown()

func (*Partition) XXX_Marshal 

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

func (*Partition) XXX_Merge 

func (m *Partition) XXX_Merge(src proto.Message)

func (*Partition) XXX_Size 

func (m *Partition) XXX_Size() int

func (*Partition) XXX_Unmarshal 

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

type PartitionEndpoint 

type PartitionEndpoint struct {
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Port int32  `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
}

Partition endpoint

func (*PartitionEndpoint) Descriptor 

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

func (*PartitionEndpoint) GetHost 

func (m *PartitionEndpoint) GetHost() string

func (*PartitionEndpoint) GetPort 

func (m *PartitionEndpoint) GetPort() int32

func (*PartitionEndpoint) Marshal 

func (m *PartitionEndpoint) Marshal() (dAtA []byte, err error)

func (*PartitionEndpoint) MarshalTo 

func (m *PartitionEndpoint) MarshalTo(dAtA []byte) (int, error)

func (*PartitionEndpoint) MarshalToSizedBuffer 

func (m *PartitionEndpoint) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PartitionEndpoint) ProtoMessage 

func (*PartitionEndpoint) ProtoMessage()

func (*PartitionEndpoint) Reset 

func (m *PartitionEndpoint) Reset()

func (*PartitionEndpoint) Size 

func (m *PartitionEndpoint) Size() (n int)

func (*PartitionEndpoint) String 

func (m *PartitionEndpoint) String() string

func (*PartitionEndpoint) Unmarshal 

func (m *PartitionEndpoint) Unmarshal(dAtA []byte) error

func (*PartitionEndpoint) XXX_DiscardUnknown 

func (m *PartitionEndpoint) XXX_DiscardUnknown()

func (*PartitionEndpoint) XXX_Marshal 

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

func (*PartitionEndpoint) XXX_Merge 

func (m *PartitionEndpoint) XXX_Merge(src proto.Message)

func (*PartitionEndpoint) XXX_Size 

func (m *PartitionEndpoint) XXX_Size() int

func (*PartitionEndpoint) XXX_Unmarshal 

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

type PartitionId 

type PartitionId struct {
	Partition int32 `protobuf:"varint,1,opt,name=partition,proto3" json:"partition,omitempty"`
}

Partition identifier

func (*PartitionId) Descriptor 

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

func (*PartitionId) GetPartition 

func (m *PartitionId) GetPartition() int32

func (*PartitionId) Marshal 

func (m *PartitionId) Marshal() (dAtA []byte, err error)

func (*PartitionId) MarshalTo 

func (m *PartitionId) MarshalTo(dAtA []byte) (int, error)

func (*PartitionId) MarshalToSizedBuffer 

func (m *PartitionId) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PartitionId) ProtoMessage 

func (*PartitionId) ProtoMessage()

func (*PartitionId) Reset 

func (m *PartitionId) Reset()

func (*PartitionId) Size 

func (m *PartitionId) Size() (n int)

func (*PartitionId) String 

func (m *PartitionId) String() string

func (*PartitionId) Unmarshal 

func (m *PartitionId) Unmarshal(dAtA []byte) error

func (*PartitionId) XXX_DiscardUnknown 

func (m *PartitionId) XXX_DiscardUnknown()

func (*PartitionId) XXX_Marshal 

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

func (*PartitionId) XXX_Merge 

func (m *PartitionId) XXX_Merge(src proto.Message)

func (*PartitionId) XXX_Size 

func (m *PartitionId) XXX_Size() int

func (*PartitionId) XXX_Unmarshal 

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

type ReplicaConfig 

type ReplicaConfig struct {
	// id is the unique member identifier
	ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// host is the member host
	Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	// api_port is the port to use for the client API
	APIPort int32 `protobuf:"varint,3,opt,name=api_port,json=apiPort,proto3" json:"apiPort"`
	// protocol_port is the port to use for intra-cluster communication
	ProtocolPort int32 `protobuf:"varint,4,opt,name=protocol_port,json=protocolPort,proto3" json:"protocolPort"`
}

Replica configuration

func (*ReplicaConfig) Descriptor 

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

func (*ReplicaConfig) GetAPIPort 

func (m *ReplicaConfig) GetAPIPort() int32

func (*ReplicaConfig) GetHost 

func (m *ReplicaConfig) GetHost() string

func (*ReplicaConfig) GetID 

func (m *ReplicaConfig) GetID() string

func (*ReplicaConfig) GetProtocolPort 

func (m *ReplicaConfig) GetProtocolPort() int32

func (*ReplicaConfig) Marshal 

func (m *ReplicaConfig) Marshal() (dAtA []byte, err error)

func (*ReplicaConfig) MarshalTo 

func (m *ReplicaConfig) MarshalTo(dAtA []byte) (int, error)

func (*ReplicaConfig) MarshalToSizedBuffer 

func (m *ReplicaConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicaConfig) ProtoMessage 

func (*ReplicaConfig) ProtoMessage()

func (*ReplicaConfig) Reset 

func (m *ReplicaConfig) Reset()

func (*ReplicaConfig) Size 

func (m *ReplicaConfig) Size() (n int)

func (*ReplicaConfig) String 

func (m *ReplicaConfig) String() string

func (*ReplicaConfig) Unmarshal 

func (m *ReplicaConfig) Unmarshal(dAtA []byte) error

func (*ReplicaConfig) XXX_DiscardUnknown 

func (m *ReplicaConfig) XXX_DiscardUnknown()

func (*ReplicaConfig) XXX_Marshal 

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

func (*ReplicaConfig) XXX_Merge 

func (m *ReplicaConfig) XXX_Merge(src proto.Message)

func (*ReplicaConfig) XXX_Size 

func (m *ReplicaConfig) XXX_Size() int

func (*ReplicaConfig) XXX_Unmarshal 

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

type UnimplementedDatabaseServiceServer 

type UnimplementedDatabaseServiceServer struct {
}

UnimplementedDatabaseServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDatabaseServiceServer) GetDatabase 

func (*UnimplementedDatabaseServiceServer) GetDatabase(ctx context.Context, req *GetDatabaseRequest) (*GetDatabaseResponse, error)

func (*UnimplementedDatabaseServiceServer) GetDatabases 

func (*UnimplementedDatabaseServiceServer) GetDatabases(ctx context.Context, req *GetDatabasesRequest) (*GetDatabasesResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.