statev1alpha1

package
v0.18.0 Latest Latest
Warning

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

Go to latest
Published: Jun 28, 2024 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source
var File_windshift_state_v1alpha1_service_proto protoreflect.FileDescriptor
View Source
var StateService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "windshift.state.v1alpha1.StateService",
	HandlerType: (*StateServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "EnsureStore",
			Handler:    _StateService_EnsureStore_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _StateService_Get_Handler,
		},
		{
			MethodName: "Set",
			Handler:    _StateService_Set_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _StateService_Delete_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "windshift/state/v1alpha1/service.proto",
}

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

Functions

func RegisterStateServiceServer

func RegisterStateServiceServer(s grpc.ServiceRegistrar, srv StateServiceServer)

Types

type DeleteRequest

type DeleteRequest struct {

	// Store to delete the key from.
	Store string `protobuf:"bytes,1,opt,name=store,proto3" json:"store,omitempty"`
	// Key to delete.
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// If set the operation will only succeed if the current revision of the
	// key matches the given revision.
	LastRevision *uint64 `protobuf:"varint,3,opt,name=last_revision,json=lastRevision,proto3,oneof" json:"last_revision,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRequest) Descriptor deprecated

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetKey

func (x *DeleteRequest) GetKey() string

func (*DeleteRequest) GetLastRevision

func (x *DeleteRequest) GetLastRevision() uint64

func (*DeleteRequest) GetStore

func (x *DeleteRequest) GetStore() string

func (*DeleteRequest) MarshalToSizedBufferVT

func (m *DeleteRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DeleteRequest) MarshalToVT

func (m *DeleteRequest) MarshalToVT(dAtA []byte) (int, error)

func (*DeleteRequest) MarshalVT

func (m *DeleteRequest) MarshalVT() (dAtA []byte, err error)

func (*DeleteRequest) ProtoMessage

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect

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

func (*DeleteRequest) Reset

func (x *DeleteRequest) Reset()

func (*DeleteRequest) SizeVT

func (m *DeleteRequest) SizeVT() (n int)

func (*DeleteRequest) String

func (x *DeleteRequest) String() string

func (*DeleteRequest) UnmarshalVT

func (m *DeleteRequest) UnmarshalVT(dAtA []byte) error

type DeleteResponse

type DeleteResponse struct {
	// contains filtered or unexported fields
}

func (*DeleteResponse) Descriptor deprecated

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

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) MarshalToSizedBufferVT

func (m *DeleteResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DeleteResponse) MarshalToVT

func (m *DeleteResponse) MarshalToVT(dAtA []byte) (int, error)

func (*DeleteResponse) MarshalVT

func (m *DeleteResponse) MarshalVT() (dAtA []byte, err error)

func (*DeleteResponse) ProtoMessage

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect

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

func (*DeleteResponse) Reset

func (x *DeleteResponse) Reset()

func (*DeleteResponse) SizeVT

func (m *DeleteResponse) SizeVT() (n int)

func (*DeleteResponse) String

func (x *DeleteResponse) String() string

func (*DeleteResponse) UnmarshalVT

func (m *DeleteResponse) UnmarshalVT(dAtA []byte) error

type EnsureStoreRequest

type EnsureStoreRequest struct {

	// The name of the store to create or update. Store names are case-sensitive
	// and should only contain the following characters:
	//
	// - `a` to `z`, `A` to `Z` and `0` to `9` are allowed.
	// - `_` and `-` are allowed for separating words.
	Store string `protobuf:"bytes,1,opt,name=store,proto3" json:"store,omitempty"`
	// contains filtered or unexported fields
}

EnsureStoreRequest creates or updates a state store.

func (*EnsureStoreRequest) Descriptor deprecated

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

Deprecated: Use EnsureStoreRequest.ProtoReflect.Descriptor instead.

func (*EnsureStoreRequest) GetStore

func (x *EnsureStoreRequest) GetStore() string

func (*EnsureStoreRequest) MarshalToSizedBufferVT

func (m *EnsureStoreRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EnsureStoreRequest) MarshalToVT

func (m *EnsureStoreRequest) MarshalToVT(dAtA []byte) (int, error)

func (*EnsureStoreRequest) MarshalVT

func (m *EnsureStoreRequest) MarshalVT() (dAtA []byte, err error)

func (*EnsureStoreRequest) ProtoMessage

func (*EnsureStoreRequest) ProtoMessage()

func (*EnsureStoreRequest) ProtoReflect

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

func (*EnsureStoreRequest) Reset

func (x *EnsureStoreRequest) Reset()

func (*EnsureStoreRequest) SizeVT

func (m *EnsureStoreRequest) SizeVT() (n int)

func (*EnsureStoreRequest) String

func (x *EnsureStoreRequest) String() string

func (*EnsureStoreRequest) UnmarshalVT

func (m *EnsureStoreRequest) UnmarshalVT(dAtA []byte) error

type EnsureStoreResponse

type EnsureStoreResponse struct {
	// contains filtered or unexported fields
}

func (*EnsureStoreResponse) Descriptor deprecated

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

Deprecated: Use EnsureStoreResponse.ProtoReflect.Descriptor instead.

func (*EnsureStoreResponse) MarshalToSizedBufferVT

func (m *EnsureStoreResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EnsureStoreResponse) MarshalToVT

func (m *EnsureStoreResponse) MarshalToVT(dAtA []byte) (int, error)

func (*EnsureStoreResponse) MarshalVT

func (m *EnsureStoreResponse) MarshalVT() (dAtA []byte, err error)

func (*EnsureStoreResponse) ProtoMessage

func (*EnsureStoreResponse) ProtoMessage()

func (*EnsureStoreResponse) ProtoReflect

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

func (*EnsureStoreResponse) Reset

func (x *EnsureStoreResponse) Reset()

func (*EnsureStoreResponse) SizeVT

func (m *EnsureStoreResponse) SizeVT() (n int)

func (*EnsureStoreResponse) String

func (x *EnsureStoreResponse) String() string

func (*EnsureStoreResponse) UnmarshalVT

func (m *EnsureStoreResponse) UnmarshalVT(dAtA []byte) error

type GetRequest

type GetRequest struct {

	// Store to retrieve the value from.
	Store string `protobuf:"bytes,1,opt,name=store,proto3" json:"store,omitempty"`
	// Key to retrieve the value for.
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

GetRequest is the message sent to retrieve a value from a store.

func (*GetRequest) Descriptor deprecated

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetKey

func (x *GetRequest) GetKey() string

func (*GetRequest) GetStore

func (x *GetRequest) GetStore() string

func (*GetRequest) MarshalToSizedBufferVT

func (m *GetRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetRequest) MarshalToVT

func (m *GetRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetRequest) MarshalVT

func (m *GetRequest) MarshalVT() (dAtA []byte, err error)

func (*GetRequest) ProtoMessage

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect

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

func (*GetRequest) Reset

func (x *GetRequest) Reset()

func (*GetRequest) SizeVT

func (m *GetRequest) SizeVT() (n int)

func (*GetRequest) String

func (x *GetRequest) String() string

func (*GetRequest) UnmarshalVT

func (m *GetRequest) UnmarshalVT(dAtA []byte) error

type GetResponse

type GetResponse struct {

	// *
	// Timestamp of the last update to the key.
	LastUpdated *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=last_updated,json=lastUpdated,proto3,oneof" json:"last_updated,omitempty"`
	// *
	// The revision of the key.
	Revision uint64 `protobuf:"varint,2,opt,name=revision,proto3" json:"revision,omitempty"`
	// *
	// The value of the key.
	Value *anypb.Any `protobuf:"bytes,3,opt,name=value,proto3,oneof" json:"value,omitempty"`
	// contains filtered or unexported fields
}

GetResponse is the message returned when retrieving a value from a store.

func (*GetResponse) Descriptor deprecated

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetLastUpdated

func (x *GetResponse) GetLastUpdated() *timestamppb.Timestamp

func (*GetResponse) GetRevision

func (x *GetResponse) GetRevision() uint64

func (*GetResponse) GetValue

func (x *GetResponse) GetValue() *anypb.Any

func (*GetResponse) MarshalToSizedBufferVT

func (m *GetResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetResponse) MarshalToVT

func (m *GetResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetResponse) MarshalVT

func (m *GetResponse) MarshalVT() (dAtA []byte, err error)

func (*GetResponse) ProtoMessage

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect

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

func (*GetResponse) Reset

func (x *GetResponse) Reset()

func (*GetResponse) SizeVT

func (m *GetResponse) SizeVT() (n int)

func (*GetResponse) String

func (x *GetResponse) String() string

func (*GetResponse) UnmarshalVT

func (m *GetResponse) UnmarshalVT(dAtA []byte) error

type SetRequest

type SetRequest struct {

	// Store to set the value in.
	Store string `protobuf:"bytes,1,opt,name=store,proto3" json:"store,omitempty"`
	// Key to set the value for. Keys are case-sensitive and should only contain
	// the following characters:
	//
	//   - `a` to `z`, `A` to `Z` and `0` to `9` are allowed.
	//   - `_` and `-` are allowed for separating words, but the use of camelCase
	//     is recommended.
	//   - `.` is allowed and used a hierarchy separator.
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// Value to set.
	Value *anypb.Any `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// If set the operation will only succeed if the key does not already
	// exist in the store.
	CreateOnly *bool `protobuf:"varint,4,opt,name=create_only,json=createOnly,proto3,oneof" json:"create_only,omitempty"`
	// If set the operation will only succeed if the current revision of the
	// key matches the given revision.
	LastRevision *uint64 `protobuf:"varint,5,opt,name=last_revision,json=lastRevision,proto3,oneof" json:"last_revision,omitempty"`
	// contains filtered or unexported fields
}

func (*SetRequest) Descriptor deprecated

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

Deprecated: Use SetRequest.ProtoReflect.Descriptor instead.

func (*SetRequest) GetCreateOnly

func (x *SetRequest) GetCreateOnly() bool

func (*SetRequest) GetKey

func (x *SetRequest) GetKey() string

func (*SetRequest) GetLastRevision

func (x *SetRequest) GetLastRevision() uint64

func (*SetRequest) GetStore

func (x *SetRequest) GetStore() string

func (*SetRequest) GetValue

func (x *SetRequest) GetValue() *anypb.Any

func (*SetRequest) MarshalToSizedBufferVT

func (m *SetRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SetRequest) MarshalToVT

func (m *SetRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SetRequest) MarshalVT

func (m *SetRequest) MarshalVT() (dAtA []byte, err error)

func (*SetRequest) ProtoMessage

func (*SetRequest) ProtoMessage()

func (*SetRequest) ProtoReflect

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

func (*SetRequest) Reset

func (x *SetRequest) Reset()

func (*SetRequest) SizeVT

func (m *SetRequest) SizeVT() (n int)

func (*SetRequest) String

func (x *SetRequest) String() string

func (*SetRequest) UnmarshalVT

func (m *SetRequest) UnmarshalVT(dAtA []byte) error

type SetResponse

type SetResponse struct {

	// The revision of the key.
	Revision uint64 `protobuf:"varint,1,opt,name=revision,proto3" json:"revision,omitempty"`
	// contains filtered or unexported fields
}

func (*SetResponse) Descriptor deprecated

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

Deprecated: Use SetResponse.ProtoReflect.Descriptor instead.

func (*SetResponse) GetRevision

func (x *SetResponse) GetRevision() uint64

func (*SetResponse) MarshalToSizedBufferVT

func (m *SetResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SetResponse) MarshalToVT

func (m *SetResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SetResponse) MarshalVT

func (m *SetResponse) MarshalVT() (dAtA []byte, err error)

func (*SetResponse) ProtoMessage

func (*SetResponse) ProtoMessage()

func (*SetResponse) ProtoReflect

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

func (*SetResponse) Reset

func (x *SetResponse) Reset()

func (*SetResponse) SizeVT

func (m *SetResponse) SizeVT() (n int)

func (*SetResponse) String

func (x *SetResponse) String() string

func (*SetResponse) UnmarshalVT

func (m *SetResponse) UnmarshalVT(dAtA []byte) error

type StateServiceClient

type StateServiceClient interface {
	// EnsureStore ensures that a store exists. If the store does not exist, it
	// will be created.
	//
	// Stores are used to collect related data. For example, a store could be
	// used to store the state of a single application.
	EnsureStore(ctx context.Context, in *EnsureStoreRequest, opts ...grpc.CallOption) (*EnsureStoreResponse, error)
	// Get retrieves the value of a key in a store.
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	// Set sets the value of a key in a store.
	Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*SetResponse, error)
	// Delete deletes a key from a store.
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
}

StateServiceClient is the client API for StateService 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.

type StateServiceServer

type StateServiceServer interface {
	// EnsureStore ensures that a store exists. If the store does not exist, it
	// will be created.
	//
	// Stores are used to collect related data. For example, a store could be
	// used to store the state of a single application.
	EnsureStore(context.Context, *EnsureStoreRequest) (*EnsureStoreResponse, error)
	// Get retrieves the value of a key in a store.
	Get(context.Context, *GetRequest) (*GetResponse, error)
	// Set sets the value of a key in a store.
	Set(context.Context, *SetRequest) (*SetResponse, error)
	// Delete deletes a key from a store.
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	// contains filtered or unexported methods
}

StateServiceServer is the server API for StateService service. All implementations must embed UnimplementedStateServiceServer for forward compatibility

type UnimplementedStateServiceServer

type UnimplementedStateServiceServer struct {
}

UnimplementedStateServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedStateServiceServer) Delete

func (UnimplementedStateServiceServer) EnsureStore

func (UnimplementedStateServiceServer) Get

func (UnimplementedStateServiceServer) Set

type UnsafeStateServiceServer

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

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

Jump to

Keyboard shortcuts

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