keyspacepb

package
v0.0.0-...-3b3056d Latest Latest
Warning

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

 Go to latest Published: Nov 29, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthKeyspacepb        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowKeyspacepb          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupKeyspacepb = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var KeyspaceState_name = map[int32]string{
	0: "ENABLED",
	1: "DISABLED",
	2: "ARCHIVED",
}
View Source 
var KeyspaceState_value = map[string]int32{
	"ENABLED":  0,
	"DISABLED": 1,
	"ARCHIVED": 2,
}

Functions

func RegisterKeyspaceServer 

func RegisterKeyspaceServer(s *grpc.Server, srv KeyspaceServer)

Types

type KeyspaceClient 

type KeyspaceClient interface {
	LoadKeyspace(ctx context.Context, in *LoadKeyspaceRequest, opts ...grpc.CallOption) (*LoadKeyspaceResponse, error)
	// WatchKeyspaces first return all current keyspaces' metadata as its first response.
	// Then, it returns responses containing keyspaces that had their metadata changed.
	WatchKeyspaces(ctx context.Context, in *WatchKeyspacesRequest, opts ...grpc.CallOption) (Keyspace_WatchKeyspacesClient, error)
}

KeyspaceClient is the client API for Keyspace service.

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

func NewKeyspaceClient 

func NewKeyspaceClient(cc *grpc.ClientConn) KeyspaceClient

type KeyspaceMeta 

type KeyspaceMeta struct {
	Id                   uint32            `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	State                KeyspaceState     `protobuf:"varint,3,opt,name=state,proto3,enum=keyspacepb.KeyspaceState" json:"state,omitempty"`
	CreatedAt            int64             `protobuf:"varint,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	StateChangedAt       int64             `protobuf:"varint,5,opt,name=state_changed_at,json=stateChangedAt,proto3" json:"state_changed_at,omitempty"`
	Config               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*KeyspaceMeta) Descriptor 

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

func (*KeyspaceMeta) GetConfig 

func (m *KeyspaceMeta) GetConfig() map[string]string

func (*KeyspaceMeta) GetCreatedAt 

func (m *KeyspaceMeta) GetCreatedAt() int64

func (*KeyspaceMeta) GetId 

func (m *KeyspaceMeta) GetId() uint32

func (*KeyspaceMeta) GetName 

func (m *KeyspaceMeta) GetName() string

func (*KeyspaceMeta) GetState 

func (m *KeyspaceMeta) GetState() KeyspaceState

func (*KeyspaceMeta) GetStateChangedAt 

func (m *KeyspaceMeta) GetStateChangedAt() int64

func (*KeyspaceMeta) Marshal 

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

func (*KeyspaceMeta) MarshalTo 

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

func (*KeyspaceMeta) MarshalToSizedBuffer 

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

func (*KeyspaceMeta) ProtoMessage 

func (*KeyspaceMeta) ProtoMessage()

func (*KeyspaceMeta) Reset 

func (m *KeyspaceMeta) Reset()

func (*KeyspaceMeta) Size 

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

func (*KeyspaceMeta) String 

func (m *KeyspaceMeta) String() string

func (*KeyspaceMeta) Unmarshal 

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

func (*KeyspaceMeta) XXX_DiscardUnknown 

func (m *KeyspaceMeta) XXX_DiscardUnknown()

func (*KeyspaceMeta) XXX_Marshal 

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

func (*KeyspaceMeta) XXX_Merge 

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

func (*KeyspaceMeta) XXX_Size 

func (m *KeyspaceMeta) XXX_Size() int

func (*KeyspaceMeta) XXX_Unmarshal 

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

type KeyspaceServer 

type KeyspaceServer interface {
	LoadKeyspace(context.Context, *LoadKeyspaceRequest) (*LoadKeyspaceResponse, error)
	// WatchKeyspaces first return all current keyspaces' metadata as its first response.
	// Then, it returns responses containing keyspaces that had their metadata changed.
	WatchKeyspaces(*WatchKeyspacesRequest, Keyspace_WatchKeyspacesServer) error
}

KeyspaceServer is the server API for Keyspace service.

type KeyspaceState 

type KeyspaceState int32
const (
	KeyspaceState_ENABLED  KeyspaceState = 0
	KeyspaceState_DISABLED KeyspaceState = 1
	KeyspaceState_ARCHIVED KeyspaceState = 2
)

func (KeyspaceState) EnumDescriptor 

func (KeyspaceState) EnumDescriptor() ([]byte, []int)

func (KeyspaceState) String 

func (x KeyspaceState) String() string

type Keyspace_WatchKeyspacesClient 

type Keyspace_WatchKeyspacesClient interface {
	Recv() (*WatchKeyspacesResponse, error)
	grpc.ClientStream
}

type Keyspace_WatchKeyspacesServer 

type Keyspace_WatchKeyspacesServer interface {
	Send(*WatchKeyspacesResponse) error
	grpc.ServerStream
}

type LoadKeyspaceRequest 

type LoadKeyspaceRequest struct {
	Header               *pdpb.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Name                 string              `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*LoadKeyspaceRequest) Descriptor 

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

func (*LoadKeyspaceRequest) GetHeader 

func (m *LoadKeyspaceRequest) GetHeader() *pdpb.RequestHeader

func (*LoadKeyspaceRequest) GetName 

func (m *LoadKeyspaceRequest) GetName() string

func (*LoadKeyspaceRequest) Marshal 

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

func (*LoadKeyspaceRequest) MarshalTo 

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

func (*LoadKeyspaceRequest) MarshalToSizedBuffer 

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

func (*LoadKeyspaceRequest) ProtoMessage 

func (*LoadKeyspaceRequest) ProtoMessage()

func (*LoadKeyspaceRequest) Reset 

func (m *LoadKeyspaceRequest) Reset()

func (*LoadKeyspaceRequest) Size 

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

func (*LoadKeyspaceRequest) String 

func (m *LoadKeyspaceRequest) String() string

func (*LoadKeyspaceRequest) Unmarshal 

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

func (*LoadKeyspaceRequest) XXX_DiscardUnknown 

func (m *LoadKeyspaceRequest) XXX_DiscardUnknown()

func (*LoadKeyspaceRequest) XXX_Marshal 

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

func (*LoadKeyspaceRequest) XXX_Merge 

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

func (*LoadKeyspaceRequest) XXX_Size 

func (m *LoadKeyspaceRequest) XXX_Size() int

func (*LoadKeyspaceRequest) XXX_Unmarshal 

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

type LoadKeyspaceResponse 

type LoadKeyspaceResponse struct {
	Header               *pdpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Keyspace             *KeyspaceMeta        `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*LoadKeyspaceResponse) Descriptor 

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

func (*LoadKeyspaceResponse) GetHeader 

func (m *LoadKeyspaceResponse) GetHeader() *pdpb.ResponseHeader

func (*LoadKeyspaceResponse) GetKeyspace 

func (m *LoadKeyspaceResponse) GetKeyspace() *KeyspaceMeta

func (*LoadKeyspaceResponse) Marshal 

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

func (*LoadKeyspaceResponse) MarshalTo 

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

func (*LoadKeyspaceResponse) MarshalToSizedBuffer 

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

func (*LoadKeyspaceResponse) ProtoMessage 

func (*LoadKeyspaceResponse) ProtoMessage()

func (*LoadKeyspaceResponse) Reset 

func (m *LoadKeyspaceResponse) Reset()

func (*LoadKeyspaceResponse) Size 

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

func (*LoadKeyspaceResponse) String 

func (m *LoadKeyspaceResponse) String() string

func (*LoadKeyspaceResponse) Unmarshal 

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

func (*LoadKeyspaceResponse) XXX_DiscardUnknown 

func (m *LoadKeyspaceResponse) XXX_DiscardUnknown()

func (*LoadKeyspaceResponse) XXX_Marshal 

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

func (*LoadKeyspaceResponse) XXX_Merge 

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

func (*LoadKeyspaceResponse) XXX_Size 

func (m *LoadKeyspaceResponse) XXX_Size() int

func (*LoadKeyspaceResponse) XXX_Unmarshal 

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

type UnimplementedKeyspaceServer 

type UnimplementedKeyspaceServer struct {
}

UnimplementedKeyspaceServer can be embedded to have forward compatible implementations.

func (*UnimplementedKeyspaceServer) LoadKeyspace 

func (*UnimplementedKeyspaceServer) LoadKeyspace(ctx context.Context, req *LoadKeyspaceRequest) (*LoadKeyspaceResponse, error)

func (*UnimplementedKeyspaceServer) WatchKeyspaces 

func (*UnimplementedKeyspaceServer) WatchKeyspaces(req *WatchKeyspacesRequest, srv Keyspace_WatchKeyspacesServer) error

type WatchKeyspacesRequest 

type WatchKeyspacesRequest struct {
	Header               *pdpb.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*WatchKeyspacesRequest) Descriptor 

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

func (*WatchKeyspacesRequest) GetHeader 

func (m *WatchKeyspacesRequest) GetHeader() *pdpb.RequestHeader

func (*WatchKeyspacesRequest) Marshal 

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

func (*WatchKeyspacesRequest) MarshalTo 

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

func (*WatchKeyspacesRequest) MarshalToSizedBuffer 

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

func (*WatchKeyspacesRequest) ProtoMessage 

func (*WatchKeyspacesRequest) ProtoMessage()

func (*WatchKeyspacesRequest) Reset 

func (m *WatchKeyspacesRequest) Reset()

func (*WatchKeyspacesRequest) Size 

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

func (*WatchKeyspacesRequest) String 

func (m *WatchKeyspacesRequest) String() string

func (*WatchKeyspacesRequest) Unmarshal 

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

func (*WatchKeyspacesRequest) XXX_DiscardUnknown 

func (m *WatchKeyspacesRequest) XXX_DiscardUnknown()

func (*WatchKeyspacesRequest) XXX_Marshal 

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

func (*WatchKeyspacesRequest) XXX_Merge 

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

func (*WatchKeyspacesRequest) XXX_Size 

func (m *WatchKeyspacesRequest) XXX_Size() int

func (*WatchKeyspacesRequest) XXX_Unmarshal 

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

type WatchKeyspacesResponse 

type WatchKeyspacesResponse struct {
	Header               *pdpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Keyspaces            []*KeyspaceMeta      `protobuf:"bytes,2,rep,name=keyspaces,proto3" json:"keyspaces,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*WatchKeyspacesResponse) Descriptor 

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

func (*WatchKeyspacesResponse) GetHeader 

func (m *WatchKeyspacesResponse) GetHeader() *pdpb.ResponseHeader

func (*WatchKeyspacesResponse) GetKeyspaces 

func (m *WatchKeyspacesResponse) GetKeyspaces() []*KeyspaceMeta

func (*WatchKeyspacesResponse) Marshal 

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

func (*WatchKeyspacesResponse) MarshalTo 

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

func (*WatchKeyspacesResponse) MarshalToSizedBuffer 

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

func (*WatchKeyspacesResponse) ProtoMessage 

func (*WatchKeyspacesResponse) ProtoMessage()

func (*WatchKeyspacesResponse) Reset 

func (m *WatchKeyspacesResponse) Reset()

func (*WatchKeyspacesResponse) Size 

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

func (*WatchKeyspacesResponse) String 

func (m *WatchKeyspacesResponse) String() string

func (*WatchKeyspacesResponse) Unmarshal 

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

func (*WatchKeyspacesResponse) XXX_DiscardUnknown 

func (m *WatchKeyspacesResponse) XXX_DiscardUnknown()

func (*WatchKeyspacesResponse) XXX_Marshal 

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

func (*WatchKeyspacesResponse) XXX_Merge 

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

func (*WatchKeyspacesResponse) XXX_Size 

func (m *WatchKeyspacesResponse) XXX_Size() int

func (*WatchKeyspacesResponse) XXX_Unmarshal 

func (m *WatchKeyspacesResponse) XXX_Unmarshal(b []byte) 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.