valuev1

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

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

 Go to latest Published: Nov 16, 2024 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ValueService_Create_FullMethodName      = "/value.v1.ValueService/Create"
	ValueService_ReadByBatch_FullMethodName = "/value.v1.ValueService/ReadByBatch"
	ValueService_ReadAll_FullMethodName     = "/value.v1.ValueService/ReadAll"
	ValueService_Update_FullMethodName      = "/value.v1.ValueService/Update"
	ValueService_Delete_FullMethodName      = "/value.v1.ValueService/Delete"
)

Variables

View Source 
var File_value_v1_data_proto protoreflect.FileDescriptor
View Source 
var File_value_v1_service_proto protoreflect.FileDescriptor
View Source 
var ValueService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "value.v1.ValueService",
	HandlerType: (*ValueServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _ValueService_Create_Handler,
		},
		{
			MethodName: "ReadByBatch",
			Handler:    _ValueService_ReadByBatch_Handler,
		},
		{
			MethodName: "ReadAll",
			Handler:    _ValueService_ReadAll_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _ValueService_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _ValueService_Delete_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "value/v1/service.proto",
}

ValueService_ServiceDesc is the grpc.ServiceDesc for ValueService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterValueServiceServer 

func RegisterValueServiceServer(s grpc.ServiceRegistrar, srv ValueServiceServer)

Types

type CreateRequest 

type CreateRequest struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Batch string `protobuf:"bytes,3,opt,name=batch,proto3" json:"batch,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateRequest) Descriptor deprecated 

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

Deprecated: Use CreateRequest.ProtoReflect.Descriptor instead.

func (*CreateRequest) GetBatch 

func (x *CreateRequest) GetBatch() string

func (*CreateRequest) GetKey 

func (x *CreateRequest) GetKey() string

func (*CreateRequest) GetValue 

func (x *CreateRequest) GetValue() string

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) ProtoReflect 

func (x *CreateRequest) ProtoReflect() protoreflect.Message

func (*CreateRequest) Reset 

func (x *CreateRequest) Reset()

func (*CreateRequest) String 

func (x *CreateRequest) String() string

type CreateResponse 

type CreateResponse struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Record  *Value `protobuf:"bytes,2,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateResponse) Descriptor deprecated 

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

Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead.

func (*CreateResponse) GetMessage 

func (x *CreateResponse) GetMessage() string

func (*CreateResponse) GetRecord 

func (x *CreateResponse) GetRecord() *Value

func (*CreateResponse) ProtoMessage 

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) ProtoReflect 

func (x *CreateResponse) ProtoReflect() protoreflect.Message

func (*CreateResponse) Reset 

func (x *CreateResponse) Reset()

func (*CreateResponse) String 

func (x *CreateResponse) String() string

type DeleteRequest 

type DeleteRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetId 

func (x *DeleteRequest) GetId() string

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect 

func (x *DeleteRequest) ProtoReflect() protoreflect.Message

func (*DeleteRequest) Reset 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (x *DeleteRequest) String() string

type DeleteResponse 

type DeleteResponse struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Record  *Value `protobuf:"bytes,2,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteResponse) Descriptor deprecated 

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

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) GetMessage 

func (x *DeleteResponse) GetMessage() string

func (*DeleteResponse) GetRecord 

func (x *DeleteResponse) GetRecord() *Value

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect 

func (x *DeleteResponse) ProtoReflect() protoreflect.Message

func (*DeleteResponse) Reset 

func (x *DeleteResponse) Reset()

func (*DeleteResponse) String 

func (x *DeleteResponse) String() string

type ReadAllRequest 

type ReadAllRequest struct {
	Query *v1.Query `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadAllRequest) Descriptor deprecated 

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

Deprecated: Use ReadAllRequest.ProtoReflect.Descriptor instead.

func (*ReadAllRequest) GetQuery 

func (x *ReadAllRequest) GetQuery() *v1.Query

func (*ReadAllRequest) ProtoMessage 

func (*ReadAllRequest) ProtoMessage()

func (*ReadAllRequest) ProtoReflect 

func (x *ReadAllRequest) ProtoReflect() protoreflect.Message

func (*ReadAllRequest) Reset 

func (x *ReadAllRequest) Reset()

func (*ReadAllRequest) String 

func (x *ReadAllRequest) String() string

type ReadAllResponse 

type ReadAllResponse struct {
	Message string      `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Option  *v1.Options `protobuf:"bytes,2,opt,name=option,proto3" json:"option,omitempty"`
	Records []*Value    `protobuf:"bytes,3,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadAllResponse) Descriptor deprecated 

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

Deprecated: Use ReadAllResponse.ProtoReflect.Descriptor instead.

func (*ReadAllResponse) GetMessage 

func (x *ReadAllResponse) GetMessage() string

func (*ReadAllResponse) GetOption 

func (x *ReadAllResponse) GetOption() *v1.Options

func (*ReadAllResponse) GetRecords 

func (x *ReadAllResponse) GetRecords() []*Value

func (*ReadAllResponse) ProtoMessage 

func (*ReadAllResponse) ProtoMessage()

func (*ReadAllResponse) ProtoReflect 

func (x *ReadAllResponse) ProtoReflect() protoreflect.Message

func (*ReadAllResponse) Reset 

func (x *ReadAllResponse) Reset()

func (*ReadAllResponse) String 

func (x *ReadAllResponse) String() string

type ReadByGroupRequest 

type ReadByGroupRequest struct {
	Batch string `protobuf:"bytes,1,opt,name=batch,proto3" json:"batch,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadByGroupRequest) Descriptor deprecated 

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

Deprecated: Use ReadByGroupRequest.ProtoReflect.Descriptor instead.

func (*ReadByGroupRequest) GetBatch 

func (x *ReadByGroupRequest) GetBatch() string

func (*ReadByGroupRequest) ProtoMessage 

func (*ReadByGroupRequest) ProtoMessage()

func (*ReadByGroupRequest) ProtoReflect 

func (x *ReadByGroupRequest) ProtoReflect() protoreflect.Message

func (*ReadByGroupRequest) Reset 

func (x *ReadByGroupRequest) Reset()

func (*ReadByGroupRequest) String 

func (x *ReadByGroupRequest) String() string

type ReadByGroupResponse 

type ReadByGroupResponse struct {
	Message string       `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Records []*v1.Option `protobuf:"bytes,2,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadByGroupResponse) Descriptor deprecated 

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

Deprecated: Use ReadByGroupResponse.ProtoReflect.Descriptor instead.

func (*ReadByGroupResponse) GetMessage 

func (x *ReadByGroupResponse) GetMessage() string

func (*ReadByGroupResponse) GetRecords 

func (x *ReadByGroupResponse) GetRecords() []*v1.Option

func (*ReadByGroupResponse) ProtoMessage 

func (*ReadByGroupResponse) ProtoMessage()

func (*ReadByGroupResponse) ProtoReflect 

func (x *ReadByGroupResponse) ProtoReflect() protoreflect.Message

func (*ReadByGroupResponse) Reset 

func (x *ReadByGroupResponse) Reset()

func (*ReadByGroupResponse) String 

func (x *ReadByGroupResponse) String() string

type UnimplementedValueServiceServer 

type UnimplementedValueServiceServer struct{}

UnimplementedValueServiceServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedValueServiceServer) Create 

func (UnimplementedValueServiceServer) Create(context.Context, *CreateRequest) (*CreateResponse, error)

func (UnimplementedValueServiceServer) Delete 

func (UnimplementedValueServiceServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)

func (UnimplementedValueServiceServer) ReadAll 

func (UnimplementedValueServiceServer) ReadAll(context.Context, *ReadAllRequest) (*ReadAllResponse, error)

func (UnimplementedValueServiceServer) ReadByBatch 

func (UnimplementedValueServiceServer) ReadByBatch(context.Context, *ReadByGroupRequest) (*ReadByGroupResponse, error)

func (UnimplementedValueServiceServer) Update 

func (UnimplementedValueServiceServer) Update(context.Context, *UpdateRequest) (*UpdateResponse, error)

type UnsafeValueServiceServer 

type UnsafeValueServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeValueServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ValueServiceServer will result in compilation errors.

type UpdateRequest 

type UpdateRequest struct {
	Id    string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Key   string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Batch string `protobuf:"bytes,4,opt,name=batch,proto3" json:"batch,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateRequest) Descriptor deprecated 

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

Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.

func (*UpdateRequest) GetBatch 

func (x *UpdateRequest) GetBatch() string

func (*UpdateRequest) GetId 

func (x *UpdateRequest) GetId() string

func (*UpdateRequest) GetKey 

func (x *UpdateRequest) GetKey() string

func (*UpdateRequest) GetValue 

func (x *UpdateRequest) GetValue() string

func (*UpdateRequest) ProtoMessage 

func (*UpdateRequest) ProtoMessage()

func (*UpdateRequest) ProtoReflect 

func (x *UpdateRequest) ProtoReflect() protoreflect.Message

func (*UpdateRequest) Reset 

func (x *UpdateRequest) Reset()

func (*UpdateRequest) String 

func (x *UpdateRequest) String() string

type UpdateResponse 

type UpdateResponse struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Record  *Value `protobuf:"bytes,2,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateResponse) Descriptor deprecated 

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

Deprecated: Use UpdateResponse.ProtoReflect.Descriptor instead.

func (*UpdateResponse) GetMessage 

func (x *UpdateResponse) GetMessage() string

func (*UpdateResponse) GetRecord 

func (x *UpdateResponse) GetRecord() *Value

func (*UpdateResponse) ProtoMessage 

func (*UpdateResponse) ProtoMessage()

func (*UpdateResponse) ProtoReflect 

func (x *UpdateResponse) ProtoReflect() protoreflect.Message

func (*UpdateResponse) Reset 

func (x *UpdateResponse) Reset()

func (*UpdateResponse) String 

func (x *UpdateResponse) String() string

type Value 

type Value struct {
	Id        string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Key       string                 `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value     string                 `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Batch     string                 `protobuf:"bytes,4,opt,name=batch,proto3" json:"batch,omitempty"`
	State     string                 `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"`
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Value) Descriptor deprecated 

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

Deprecated: Use Value.ProtoReflect.Descriptor instead.

func (*Value) GetBatch 

func (x *Value) GetBatch() string

func (*Value) GetCreatedAt 

func (x *Value) GetCreatedAt() *timestamppb.Timestamp

func (*Value) GetId 

func (x *Value) GetId() string

func (*Value) GetKey 

func (x *Value) GetKey() string

func (*Value) GetState 

func (x *Value) GetState() string

func (*Value) GetUpdatedAt 

func (x *Value) GetUpdatedAt() *timestamppb.Timestamp

func (*Value) GetValue 

func (x *Value) GetValue() string

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) ProtoReflect 

func (x *Value) ProtoReflect() protoreflect.Message

func (*Value) Reset 

func (x *Value) Reset()

func (*Value) String 

func (x *Value) String() string

type ValueServiceClient 

type ValueServiceClient interface {
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	ReadByBatch(ctx context.Context, in *ReadByGroupRequest, opts ...grpc.CallOption) (*ReadByGroupResponse, error)
	ReadAll(ctx context.Context, in *ReadAllRequest, opts ...grpc.CallOption) (*ReadAllResponse, error)
	Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
}

ValueServiceClient is the client API for ValueService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewValueServiceClient 

func NewValueServiceClient(cc grpc.ClientConnInterface) ValueServiceClient

type ValueServiceServer 

type ValueServiceServer interface {
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	ReadByBatch(context.Context, *ReadByGroupRequest) (*ReadByGroupResponse, error)
	ReadAll(context.Context, *ReadAllRequest) (*ReadAllResponse, error)
	Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
}

ValueServiceServer is the server API for ValueService service. All implementations should embed UnimplementedValueServiceServer for forward compatibility.

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.