cache

type CacheHandler interface {
	Put(context.Context, *CacheMessage, *CacheMessage) error
	Set(context.Context, *CacheMessage, *CacheMessage) error
	Get(context.Context, *CacheKeyRequest, *CacheMessage) error
	Delete(context.Context, *CacheKeyRequest, *CacheMessage) error
	List(context.Context, *CacheListRequest, *CacheListResponse) error
}

type CacheKeyRequest struct {
	Key                  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type CacheListRequest struct {
	Limit                *wrappers.UInt32Value `protobuf:"bytes,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset               *wrappers.UInt32Value `protobuf:"bytes,2,opt,name=offset,proto3" json:"offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

type CacheListResponse struct {
	Items                []*CacheMessage `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

type CacheMessage struct {
	Key                  []byte               `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                []byte               `protobuf:"bytes,2,opt,name=value,proto3" json:"value,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:"-"`
}

type CacheService interface {
	Put(ctx context.Context, in *CacheMessage, opts ...client.CallOption) (*CacheMessage, error)
	Set(ctx context.Context, in *CacheMessage, opts ...client.CallOption) (*CacheMessage, error)
	Get(ctx context.Context, in *CacheKeyRequest, opts ...client.CallOption) (*CacheMessage, error)
	Delete(ctx context.Context, in *CacheKeyRequest, opts ...client.CallOption) (*CacheMessage, error)
	List(ctx context.Context, in *CacheListRequest, opts ...client.CallOption) (*CacheListResponse, error)
}