v1alpha1

package
v0.2.1 Latest Latest
Warning

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

 Go to latest Published: Dec 19, 2024 License: Apache-2.0 Imports: 15 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthApi        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowApi          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupApi = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var BucketState_name = map[int32]string{
	0: "BUCKET_PENDING",
	1: "BUCKET_AVAILABLE",
	2: "BUCKET_ERROR",
}
View Source 
var BucketState_value = map[string]int32{
	"BUCKET_PENDING":   0,
	"BUCKET_AVAILABLE": 1,
	"BUCKET_ERROR":     2,
}

Functions

func RegisterBucketRuntimeServer 

func RegisterBucketRuntimeServer(s *grpc.Server, srv BucketRuntimeServer)

Types

type Bucket 

type Bucket struct {
	Metadata             *v1alpha1.ObjectMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Spec                 *BucketSpec              `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	Status               *BucketStatus            `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*Bucket) Descriptor 

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

func (*Bucket) GetMetadata 

func (m *Bucket) GetMetadata() *v1alpha1.ObjectMetadata

func (*Bucket) GetSpec 

func (m *Bucket) GetSpec() *BucketSpec

func (*Bucket) GetStatus 

func (m *Bucket) GetStatus() *BucketStatus

func (*Bucket) Marshal 

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

func (*Bucket) MarshalTo 

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

func (*Bucket) MarshalToSizedBuffer 

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

func (*Bucket) ProtoMessage 

func (*Bucket) ProtoMessage()

func (*Bucket) Reset 

func (m *Bucket) Reset()

func (*Bucket) Size 

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

func (*Bucket) String 

func (this *Bucket) String() string

func (*Bucket) Unmarshal 

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

func (*Bucket) XXX_DiscardUnknown 

func (m *Bucket) XXX_DiscardUnknown()

func (*Bucket) XXX_Marshal 

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

func (*Bucket) XXX_Merge 

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

func (*Bucket) XXX_Size 

func (m *Bucket) XXX_Size() int

func (*Bucket) XXX_Unmarshal 

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

type BucketAccess 

type BucketAccess struct {
	Endpoint             string            `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	SecretData           map[string][]byte `` /* 179-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*BucketAccess) Descriptor 

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

func (*BucketAccess) GetEndpoint 

func (m *BucketAccess) GetEndpoint() string

func (*BucketAccess) GetSecretData 

func (m *BucketAccess) GetSecretData() map[string][]byte

func (*BucketAccess) Marshal 

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

func (*BucketAccess) MarshalTo 

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

func (*BucketAccess) MarshalToSizedBuffer 

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

func (*BucketAccess) ProtoMessage 

func (*BucketAccess) ProtoMessage()

func (*BucketAccess) Reset 

func (m *BucketAccess) Reset()

func (*BucketAccess) Size 

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

func (*BucketAccess) String 

func (this *BucketAccess) String() string

func (*BucketAccess) Unmarshal 

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

func (*BucketAccess) XXX_DiscardUnknown 

func (m *BucketAccess) XXX_DiscardUnknown()

func (*BucketAccess) XXX_Marshal 

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

func (*BucketAccess) XXX_Merge 

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

func (*BucketAccess) XXX_Size 

func (m *BucketAccess) XXX_Size() int

func (*BucketAccess) XXX_Unmarshal 

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

type BucketClass 

type BucketClass struct {
	Name                 string                   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Capabilities         *BucketClassCapabilities `protobuf:"bytes,2,opt,name=capabilities,proto3" json:"capabilities,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*BucketClass) Descriptor 

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

func (*BucketClass) GetCapabilities 

func (m *BucketClass) GetCapabilities() *BucketClassCapabilities

func (*BucketClass) GetName 

func (m *BucketClass) GetName() string

func (*BucketClass) Marshal 

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

func (*BucketClass) MarshalTo 

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

func (*BucketClass) MarshalToSizedBuffer 

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

func (*BucketClass) ProtoMessage 

func (*BucketClass) ProtoMessage()

func (*BucketClass) Reset 

func (m *BucketClass) Reset()

func (*BucketClass) Size 

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

func (*BucketClass) String 

func (this *BucketClass) String() string

func (*BucketClass) Unmarshal 

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

func (*BucketClass) XXX_DiscardUnknown 

func (m *BucketClass) XXX_DiscardUnknown()

func (*BucketClass) XXX_Marshal 

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

func (*BucketClass) XXX_Merge 

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

func (*BucketClass) XXX_Size 

func (m *BucketClass) XXX_Size() int

func (*BucketClass) XXX_Unmarshal 

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

type BucketClassCapabilities 

type BucketClassCapabilities struct {
	Tps                  int64    `protobuf:"varint,1,opt,name=tps,proto3" json:"tps,omitempty"`
	Iops                 int64    `protobuf:"varint,2,opt,name=iops,proto3" json:"iops,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BucketClassCapabilities) Descriptor 

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

func (*BucketClassCapabilities) GetIops 

func (m *BucketClassCapabilities) GetIops() int64

func (*BucketClassCapabilities) GetTps 

func (m *BucketClassCapabilities) GetTps() int64

func (*BucketClassCapabilities) Marshal 

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

func (*BucketClassCapabilities) MarshalTo 

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

func (*BucketClassCapabilities) MarshalToSizedBuffer 

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

func (*BucketClassCapabilities) ProtoMessage 

func (*BucketClassCapabilities) ProtoMessage()

func (*BucketClassCapabilities) Reset 

func (m *BucketClassCapabilities) Reset()

func (*BucketClassCapabilities) Size 

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

func (*BucketClassCapabilities) String 

func (this *BucketClassCapabilities) String() string

func (*BucketClassCapabilities) Unmarshal 

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

func (*BucketClassCapabilities) XXX_DiscardUnknown 

func (m *BucketClassCapabilities) XXX_DiscardUnknown()

func (*BucketClassCapabilities) XXX_Marshal 

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

func (*BucketClassCapabilities) XXX_Merge 

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

func (*BucketClassCapabilities) XXX_Size 

func (m *BucketClassCapabilities) XXX_Size() int

func (*BucketClassCapabilities) XXX_Unmarshal 

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

type BucketFilter 

type BucketFilter struct {
	Id                   string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	LabelSelector        map[string]string `` /* 188-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*BucketFilter) Descriptor 

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

func (*BucketFilter) GetId 

func (m *BucketFilter) GetId() string

func (*BucketFilter) GetLabelSelector 

func (m *BucketFilter) GetLabelSelector() map[string]string

func (*BucketFilter) Marshal 

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

func (*BucketFilter) MarshalTo 

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

func (*BucketFilter) MarshalToSizedBuffer 

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

func (*BucketFilter) ProtoMessage 

func (*BucketFilter) ProtoMessage()

func (*BucketFilter) Reset 

func (m *BucketFilter) Reset()

func (*BucketFilter) Size 

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

func (*BucketFilter) String 

func (this *BucketFilter) String() string

func (*BucketFilter) Unmarshal 

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

func (*BucketFilter) XXX_DiscardUnknown 

func (m *BucketFilter) XXX_DiscardUnknown()

func (*BucketFilter) XXX_Marshal 

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

func (*BucketFilter) XXX_Merge 

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

func (*BucketFilter) XXX_Size 

func (m *BucketFilter) XXX_Size() int

func (*BucketFilter) XXX_Unmarshal 

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

type BucketRuntimeClient 

type BucketRuntimeClient interface {
	ListEvents(ctx context.Context, in *ListEventsRequest, opts ...grpc.CallOption) (*ListEventsResponse, error)
	ListBuckets(ctx context.Context, in *ListBucketsRequest, opts ...grpc.CallOption) (*ListBucketsResponse, error)
	CreateBucket(ctx context.Context, in *CreateBucketRequest, opts ...grpc.CallOption) (*CreateBucketResponse, error)
	DeleteBucket(ctx context.Context, in *DeleteBucketRequest, opts ...grpc.CallOption) (*DeleteBucketResponse, error)
	ListBucketClasses(ctx context.Context, in *ListBucketClassesRequest, opts ...grpc.CallOption) (*ListBucketClassesResponse, error)
}

BucketRuntimeClient is the client API for BucketRuntime service.

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

func NewBucketRuntimeClient 

func NewBucketRuntimeClient(cc *grpc.ClientConn) BucketRuntimeClient

type BucketRuntimeServer 

type BucketRuntimeServer interface {
	ListEvents(context.Context, *ListEventsRequest) (*ListEventsResponse, error)
	ListBuckets(context.Context, *ListBucketsRequest) (*ListBucketsResponse, error)
	CreateBucket(context.Context, *CreateBucketRequest) (*CreateBucketResponse, error)
	DeleteBucket(context.Context, *DeleteBucketRequest) (*DeleteBucketResponse, error)
	ListBucketClasses(context.Context, *ListBucketClassesRequest) (*ListBucketClassesResponse, error)
}

BucketRuntimeServer is the server API for BucketRuntime service.

type BucketSpec 

type BucketSpec struct {
	Class                string   `protobuf:"bytes,2,opt,name=class,proto3" json:"class,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BucketSpec) Descriptor 

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

func (*BucketSpec) GetClass 

func (m *BucketSpec) GetClass() string

func (*BucketSpec) Marshal 

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

func (*BucketSpec) MarshalTo 

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

func (*BucketSpec) MarshalToSizedBuffer 

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

func (*BucketSpec) ProtoMessage 

func (*BucketSpec) ProtoMessage()

func (*BucketSpec) Reset 

func (m *BucketSpec) Reset()

func (*BucketSpec) Size 

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

func (*BucketSpec) String 

func (this *BucketSpec) String() string

func (*BucketSpec) Unmarshal 

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

func (*BucketSpec) XXX_DiscardUnknown 

func (m *BucketSpec) XXX_DiscardUnknown()

func (*BucketSpec) XXX_Marshal 

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

func (*BucketSpec) XXX_Merge 

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

func (*BucketSpec) XXX_Size 

func (m *BucketSpec) XXX_Size() int

func (*BucketSpec) XXX_Unmarshal 

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

type BucketState 

type BucketState int32
const (
	BucketState_BUCKET_PENDING   BucketState = 0
	BucketState_BUCKET_AVAILABLE BucketState = 1
	BucketState_BUCKET_ERROR     BucketState = 2
)

func (BucketState) EnumDescriptor 

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

func (BucketState) String 

func (x BucketState) String() string

type BucketStatus 

type BucketStatus struct {
	State                BucketState   `protobuf:"varint,1,opt,name=state,proto3,enum=bucket.v1alpha1.BucketState" json:"state,omitempty"`
	Access               *BucketAccess `protobuf:"bytes,2,opt,name=access,proto3" json:"access,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*BucketStatus) Descriptor 

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

func (*BucketStatus) GetAccess 

func (m *BucketStatus) GetAccess() *BucketAccess

func (*BucketStatus) GetState 

func (m *BucketStatus) GetState() BucketState

func (*BucketStatus) Marshal 

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

func (*BucketStatus) MarshalTo 

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

func (*BucketStatus) MarshalToSizedBuffer 

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

func (*BucketStatus) ProtoMessage 

func (*BucketStatus) ProtoMessage()

func (*BucketStatus) Reset 

func (m *BucketStatus) Reset()

func (*BucketStatus) Size 

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

func (*BucketStatus) String 

func (this *BucketStatus) String() string

func (*BucketStatus) Unmarshal 

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

func (*BucketStatus) XXX_DiscardUnknown 

func (m *BucketStatus) XXX_DiscardUnknown()

func (*BucketStatus) XXX_Marshal 

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

func (*BucketStatus) XXX_Merge 

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

func (*BucketStatus) XXX_Size 

func (m *BucketStatus) XXX_Size() int

func (*BucketStatus) XXX_Unmarshal 

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

type CreateBucketRequest 

type CreateBucketRequest struct {
	Bucket               *Bucket  `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateBucketRequest) Descriptor 

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

func (*CreateBucketRequest) GetBucket 

func (m *CreateBucketRequest) GetBucket() *Bucket

func (*CreateBucketRequest) Marshal 

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

func (*CreateBucketRequest) MarshalTo 

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

func (*CreateBucketRequest) MarshalToSizedBuffer 

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

func (*CreateBucketRequest) ProtoMessage 

func (*CreateBucketRequest) ProtoMessage()

func (*CreateBucketRequest) Reset 

func (m *CreateBucketRequest) Reset()

func (*CreateBucketRequest) Size 

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

func (*CreateBucketRequest) String 

func (this *CreateBucketRequest) String() string

func (*CreateBucketRequest) Unmarshal 

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

func (*CreateBucketRequest) XXX_DiscardUnknown 

func (m *CreateBucketRequest) XXX_DiscardUnknown()

func (*CreateBucketRequest) XXX_Marshal 

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

func (*CreateBucketRequest) XXX_Merge 

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

func (*CreateBucketRequest) XXX_Size 

func (m *CreateBucketRequest) XXX_Size() int

func (*CreateBucketRequest) XXX_Unmarshal 

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

type CreateBucketResponse 

type CreateBucketResponse struct {
	Bucket               *Bucket  `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateBucketResponse) Descriptor 

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

func (*CreateBucketResponse) GetBucket 

func (m *CreateBucketResponse) GetBucket() *Bucket

func (*CreateBucketResponse) Marshal 

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

func (*CreateBucketResponse) MarshalTo 

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

func (*CreateBucketResponse) MarshalToSizedBuffer 

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

func (*CreateBucketResponse) ProtoMessage 

func (*CreateBucketResponse) ProtoMessage()

func (*CreateBucketResponse) Reset 

func (m *CreateBucketResponse) Reset()

func (*CreateBucketResponse) Size 

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

func (*CreateBucketResponse) String 

func (this *CreateBucketResponse) String() string

func (*CreateBucketResponse) Unmarshal 

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

func (*CreateBucketResponse) XXX_DiscardUnknown 

func (m *CreateBucketResponse) XXX_DiscardUnknown()

func (*CreateBucketResponse) XXX_Marshal 

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

func (*CreateBucketResponse) XXX_Merge 

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

func (*CreateBucketResponse) XXX_Size 

func (m *CreateBucketResponse) XXX_Size() int

func (*CreateBucketResponse) XXX_Unmarshal 

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

type DeleteBucketRequest 

type DeleteBucketRequest struct {
	BucketId             string   `protobuf:"bytes,1,opt,name=bucket_id,json=bucketId,proto3" json:"bucket_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteBucketRequest) Descriptor 

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

func (*DeleteBucketRequest) GetBucketId 

func (m *DeleteBucketRequest) GetBucketId() string

func (*DeleteBucketRequest) Marshal 

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

func (*DeleteBucketRequest) MarshalTo 

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

func (*DeleteBucketRequest) MarshalToSizedBuffer 

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

func (*DeleteBucketRequest) ProtoMessage 

func (*DeleteBucketRequest) ProtoMessage()

func (*DeleteBucketRequest) Reset 

func (m *DeleteBucketRequest) Reset()

func (*DeleteBucketRequest) Size 

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

func (*DeleteBucketRequest) String 

func (this *DeleteBucketRequest) String() string

func (*DeleteBucketRequest) Unmarshal 

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

func (*DeleteBucketRequest) XXX_DiscardUnknown 

func (m *DeleteBucketRequest) XXX_DiscardUnknown()

func (*DeleteBucketRequest) XXX_Marshal 

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

func (*DeleteBucketRequest) XXX_Merge 

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

func (*DeleteBucketRequest) XXX_Size 

func (m *DeleteBucketRequest) XXX_Size() int

func (*DeleteBucketRequest) XXX_Unmarshal 

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

type DeleteBucketResponse 

type DeleteBucketResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteBucketResponse) Descriptor 

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

func (*DeleteBucketResponse) Marshal 

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

func (*DeleteBucketResponse) MarshalTo 

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

func (*DeleteBucketResponse) MarshalToSizedBuffer 

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

func (*DeleteBucketResponse) ProtoMessage 

func (*DeleteBucketResponse) ProtoMessage()

func (*DeleteBucketResponse) Reset 

func (m *DeleteBucketResponse) Reset()

func (*DeleteBucketResponse) Size 

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

func (*DeleteBucketResponse) String 

func (this *DeleteBucketResponse) String() string

func (*DeleteBucketResponse) Unmarshal 

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

func (*DeleteBucketResponse) XXX_DiscardUnknown 

func (m *DeleteBucketResponse) XXX_DiscardUnknown()

func (*DeleteBucketResponse) XXX_Marshal 

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

func (*DeleteBucketResponse) XXX_Merge 

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

func (*DeleteBucketResponse) XXX_Size 

func (m *DeleteBucketResponse) XXX_Size() int

func (*DeleteBucketResponse) XXX_Unmarshal 

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

type EventFilter added in v0.2.0 

type EventFilter struct {
	Id                   string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	LabelSelector        map[string]string `` /* 188-byte string literal not displayed */
	EventsFromTime       int64             `protobuf:"varint,3,opt,name=events_from_time,json=eventsFromTime,proto3" json:"events_from_time,omitempty"`
	EventsToTime         int64             `protobuf:"varint,4,opt,name=events_to_time,json=eventsToTime,proto3" json:"events_to_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*EventFilter) Descriptor added in v0.2.0 

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

func (*EventFilter) GetEventsFromTime added in v0.2.0 

func (m *EventFilter) GetEventsFromTime() int64

func (*EventFilter) GetEventsToTime added in v0.2.0 

func (m *EventFilter) GetEventsToTime() int64

func (*EventFilter) GetId added in v0.2.0 

func (m *EventFilter) GetId() string

func (*EventFilter) GetLabelSelector added in v0.2.0 

func (m *EventFilter) GetLabelSelector() map[string]string

func (*EventFilter) Marshal added in v0.2.0 

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

func (*EventFilter) MarshalTo added in v0.2.0 

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

func (*EventFilter) MarshalToSizedBuffer added in v0.2.0 

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

func (*EventFilter) ProtoMessage added in v0.2.0 

func (*EventFilter) ProtoMessage()

func (*EventFilter) Reset added in v0.2.0 

func (m *EventFilter) Reset()

func (*EventFilter) Size added in v0.2.0 

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

func (*EventFilter) String added in v0.2.0 

func (this *EventFilter) String() string

func (*EventFilter) Unmarshal added in v0.2.0 

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

func (*EventFilter) XXX_DiscardUnknown added in v0.2.0 

func (m *EventFilter) XXX_DiscardUnknown()

func (*EventFilter) XXX_Marshal added in v0.2.0 

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

func (*EventFilter) XXX_Merge added in v0.2.0 

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

func (*EventFilter) XXX_Size added in v0.2.0 

func (m *EventFilter) XXX_Size() int

func (*EventFilter) XXX_Unmarshal added in v0.2.0 

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

type ListBucketClassesRequest 

type ListBucketClassesRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListBucketClassesRequest) Descriptor 

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

func (*ListBucketClassesRequest) Marshal 

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

func (*ListBucketClassesRequest) MarshalTo 

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

func (*ListBucketClassesRequest) MarshalToSizedBuffer 

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

func (*ListBucketClassesRequest) ProtoMessage 

func (*ListBucketClassesRequest) ProtoMessage()

func (*ListBucketClassesRequest) Reset 

func (m *ListBucketClassesRequest) Reset()

func (*ListBucketClassesRequest) Size 

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

func (*ListBucketClassesRequest) String 

func (this *ListBucketClassesRequest) String() string

func (*ListBucketClassesRequest) Unmarshal 

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

func (*ListBucketClassesRequest) XXX_DiscardUnknown 

func (m *ListBucketClassesRequest) XXX_DiscardUnknown()

func (*ListBucketClassesRequest) XXX_Marshal 

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

func (*ListBucketClassesRequest) XXX_Merge 

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

func (*ListBucketClassesRequest) XXX_Size 

func (m *ListBucketClassesRequest) XXX_Size() int

func (*ListBucketClassesRequest) XXX_Unmarshal 

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

type ListBucketClassesResponse 

type ListBucketClassesResponse struct {
	BucketClasses        []*BucketClass `protobuf:"bytes,1,rep,name=bucket_classes,json=bucketClasses,proto3" json:"bucket_classes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ListBucketClassesResponse) Descriptor 

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

func (*ListBucketClassesResponse) GetBucketClasses 

func (m *ListBucketClassesResponse) GetBucketClasses() []*BucketClass

func (*ListBucketClassesResponse) Marshal 

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

func (*ListBucketClassesResponse) MarshalTo 

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

func (*ListBucketClassesResponse) MarshalToSizedBuffer 

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

func (*ListBucketClassesResponse) ProtoMessage 

func (*ListBucketClassesResponse) ProtoMessage()

func (*ListBucketClassesResponse) Reset 

func (m *ListBucketClassesResponse) Reset()

func (*ListBucketClassesResponse) Size 

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

func (*ListBucketClassesResponse) String 

func (this *ListBucketClassesResponse) String() string

func (*ListBucketClassesResponse) Unmarshal 

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

func (*ListBucketClassesResponse) XXX_DiscardUnknown 

func (m *ListBucketClassesResponse) XXX_DiscardUnknown()

func (*ListBucketClassesResponse) XXX_Marshal 

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

func (*ListBucketClassesResponse) XXX_Merge 

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

func (*ListBucketClassesResponse) XXX_Size 

func (m *ListBucketClassesResponse) XXX_Size() int

func (*ListBucketClassesResponse) XXX_Unmarshal 

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

type ListBucketsRequest 

type ListBucketsRequest struct {
	Filter               *BucketFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ListBucketsRequest) Descriptor 

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

func (*ListBucketsRequest) GetFilter 

func (m *ListBucketsRequest) GetFilter() *BucketFilter

func (*ListBucketsRequest) Marshal 

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

func (*ListBucketsRequest) MarshalTo 

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

func (*ListBucketsRequest) MarshalToSizedBuffer 

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

func (*ListBucketsRequest) ProtoMessage 

func (*ListBucketsRequest) ProtoMessage()

func (*ListBucketsRequest) Reset 

func (m *ListBucketsRequest) Reset()

func (*ListBucketsRequest) Size 

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

func (*ListBucketsRequest) String 

func (this *ListBucketsRequest) String() string

func (*ListBucketsRequest) Unmarshal 

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

func (*ListBucketsRequest) XXX_DiscardUnknown 

func (m *ListBucketsRequest) XXX_DiscardUnknown()

func (*ListBucketsRequest) XXX_Marshal 

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

func (*ListBucketsRequest) XXX_Merge 

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

func (*ListBucketsRequest) XXX_Size 

func (m *ListBucketsRequest) XXX_Size() int

func (*ListBucketsRequest) XXX_Unmarshal 

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

type ListBucketsResponse 

type ListBucketsResponse struct {
	Buckets              []*Bucket `protobuf:"bytes,1,rep,name=buckets,proto3" json:"buckets,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ListBucketsResponse) Descriptor 

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

func (*ListBucketsResponse) GetBuckets 

func (m *ListBucketsResponse) GetBuckets() []*Bucket

func (*ListBucketsResponse) Marshal 

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

func (*ListBucketsResponse) MarshalTo 

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

func (*ListBucketsResponse) MarshalToSizedBuffer 

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

func (*ListBucketsResponse) ProtoMessage 

func (*ListBucketsResponse) ProtoMessage()

func (*ListBucketsResponse) Reset 

func (m *ListBucketsResponse) Reset()

func (*ListBucketsResponse) Size 

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

func (*ListBucketsResponse) String 

func (this *ListBucketsResponse) String() string

func (*ListBucketsResponse) Unmarshal 

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

func (*ListBucketsResponse) XXX_DiscardUnknown 

func (m *ListBucketsResponse) XXX_DiscardUnknown()

func (*ListBucketsResponse) XXX_Marshal 

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

func (*ListBucketsResponse) XXX_Merge 

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

func (*ListBucketsResponse) XXX_Size 

func (m *ListBucketsResponse) XXX_Size() int

func (*ListBucketsResponse) XXX_Unmarshal 

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

type ListEventsRequest added in v0.2.0 

type ListEventsRequest struct {
	Filter               *EventFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ListEventsRequest) Descriptor added in v0.2.0 

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

func (*ListEventsRequest) GetFilter added in v0.2.0 

func (m *ListEventsRequest) GetFilter() *EventFilter

func (*ListEventsRequest) Marshal added in v0.2.0 

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

func (*ListEventsRequest) MarshalTo added in v0.2.0 

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

func (*ListEventsRequest) MarshalToSizedBuffer added in v0.2.0 

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

func (*ListEventsRequest) ProtoMessage added in v0.2.0 

func (*ListEventsRequest) ProtoMessage()

func (*ListEventsRequest) Reset added in v0.2.0 

func (m *ListEventsRequest) Reset()

func (*ListEventsRequest) Size added in v0.2.0 

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

func (*ListEventsRequest) String added in v0.2.0 

func (this *ListEventsRequest) String() string

func (*ListEventsRequest) Unmarshal added in v0.2.0 

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

func (*ListEventsRequest) XXX_DiscardUnknown added in v0.2.0 

func (m *ListEventsRequest) XXX_DiscardUnknown()

func (*ListEventsRequest) XXX_Marshal added in v0.2.0 

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

func (*ListEventsRequest) XXX_Merge added in v0.2.0 

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

func (*ListEventsRequest) XXX_Size added in v0.2.0 

func (m *ListEventsRequest) XXX_Size() int

func (*ListEventsRequest) XXX_Unmarshal added in v0.2.0 

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

type ListEventsResponse added in v0.2.0 

type ListEventsResponse struct {
	Events               []*v1alpha11.Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ListEventsResponse) Descriptor added in v0.2.0 

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

func (*ListEventsResponse) GetEvents added in v0.2.0 

func (m *ListEventsResponse) GetEvents() []*v1alpha11.Event

func (*ListEventsResponse) Marshal added in v0.2.0 

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

func (*ListEventsResponse) MarshalTo added in v0.2.0 

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

func (*ListEventsResponse) MarshalToSizedBuffer added in v0.2.0 

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

func (*ListEventsResponse) ProtoMessage added in v0.2.0 

func (*ListEventsResponse) ProtoMessage()

func (*ListEventsResponse) Reset added in v0.2.0 

func (m *ListEventsResponse) Reset()

func (*ListEventsResponse) Size added in v0.2.0 

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

func (*ListEventsResponse) String added in v0.2.0 

func (this *ListEventsResponse) String() string

func (*ListEventsResponse) Unmarshal added in v0.2.0 

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

func (*ListEventsResponse) XXX_DiscardUnknown added in v0.2.0 

func (m *ListEventsResponse) XXX_DiscardUnknown()

func (*ListEventsResponse) XXX_Marshal added in v0.2.0 

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

func (*ListEventsResponse) XXX_Merge added in v0.2.0 

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

func (*ListEventsResponse) XXX_Size added in v0.2.0 

func (m *ListEventsResponse) XXX_Size() int

func (*ListEventsResponse) XXX_Unmarshal added in v0.2.0 

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

type UnimplementedBucketRuntimeServer 

type UnimplementedBucketRuntimeServer struct {
}

UnimplementedBucketRuntimeServer can be embedded to have forward compatible implementations.

func (*UnimplementedBucketRuntimeServer) CreateBucket 

func (*UnimplementedBucketRuntimeServer) CreateBucket(ctx context.Context, req *CreateBucketRequest) (*CreateBucketResponse, error)

func (*UnimplementedBucketRuntimeServer) DeleteBucket 

func (*UnimplementedBucketRuntimeServer) DeleteBucket(ctx context.Context, req *DeleteBucketRequest) (*DeleteBucketResponse, error)

func (*UnimplementedBucketRuntimeServer) ListBucketClasses 

func (*UnimplementedBucketRuntimeServer) ListBucketClasses(ctx context.Context, req *ListBucketClassesRequest) (*ListBucketClassesResponse, error)

func (*UnimplementedBucketRuntimeServer) ListBuckets 

func (*UnimplementedBucketRuntimeServer) ListBuckets(ctx context.Context, req *ListBucketsRequest) (*ListBucketsResponse, error)

func (*UnimplementedBucketRuntimeServer) ListEvents added in v0.2.0 

func (*UnimplementedBucketRuntimeServer) ListEvents(ctx context.Context, req *ListEventsRequest) (*ListEventsResponse, 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.