datasetv1

type Dataset struct {
	Files     []*File  `protobuf:"bytes,1,rep,name=files,proto3" json:"files,omitempty"`                           // manifest of files within the dataset
	BlockSize int32    `protobuf:"varint,2,opt,name=block_size,json=blockSize,proto3" json:"block_size,omitempty"` // maximum size of the blocks in bytes
	Blocks    []string `protobuf:"bytes,3,rep,name=blocks,proto3" json:"blocks,omitempty"`                         // a list of block signatures
	// contains filtered or unexported fields
}

type DatasetAPIClient interface {
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	ListTags(ctx context.Context, in *ListTagsRequest, opts ...grpc.CallOption) (*ListTagsResponse, error)
	Lookup(ctx context.Context, in *LookupRequest, opts ...grpc.CallOption) (*LookupResponse, error)
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)
	Subscribe(ctx context.Context, opts ...grpc.CallOption) (DatasetAPI_SubscribeClient, error)
}

type DatasetAPIServer interface {
	List(context.Context, *ListRequest) (*ListResponse, error)
	ListTags(context.Context, *ListTagsRequest) (*ListTagsResponse, error)
	Lookup(context.Context, *LookupRequest) (*LookupResponse, error)
	Publish(context.Context, *PublishRequest) (*PublishResponse, error)
	Subscribe(DatasetAPI_SubscribeServer) error
	// contains filtered or unexported methods
}

type DatasetAPI_SubscribeClient interface {
	Send(*SubscribeRequest) error
	Recv() (*SubscribeResponse, error)
	grpc.ClientStream
}

type DatasetAPI_SubscribeServer interface {
	Send(*SubscribeResponse) error
	Recv() (*SubscribeRequest, error)
	grpc.ServerStream
}

type File struct {
	Name         string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                                     // name of the file (including directories)
	Size         int64                  `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`                                    // size in bytes
	LastModified *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=last_modified,json=lastModified,proto3" json:"last_modified,omitempty"` // time of last modification
	// contains filtered or unexported fields
}

type ListRequest struct {
	PageToken string `protobuf:"bytes,1,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // the token used to manage pagination.
	PageSize  int32  `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`   // the number of results to include in the page.
	// contains filtered or unexported fields
}

type ListResponse struct {
	NextPageToken string `protobuf:"bytes,1,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // the token associated with the start of the next page.
	Datasets      []*Tag `protobuf:"bytes,2,rep,name=datasets,proto3" json:"datasets,omitempty"`                                  // the list of datasets for the current page.
	// contains filtered or unexported fields
}

type ListTagsRequest struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                            // the name of the dataset.
	PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // the token used to manage pagination.
	PageSize  int32  `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`   // the number of results to include in the page.
	// contains filtered or unexported fields
}

type ListTagsResponse struct {
	NextPageToken string `protobuf:"bytes,1,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // the token associated with the start of the next page.
	Tags          []*Tag `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"`                                          // the list of tags for the current page.
	// contains filtered or unexported fields
}

type LookupRequest struct {
	Tag *Tag `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	// contains filtered or unexported fields
}

type LookupResponse struct {
	Dataset *Dataset `protobuf:"bytes,1,opt,name=dataset,proto3" json:"dataset,omitempty"`
	// contains filtered or unexported fields
}

type PublishRequest struct {
	Dataset *Dataset `protobuf:"bytes,1,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Tags    []*Tag   `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

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

type SubscribeRequest struct {
	Tag    *Tag `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	Cancel bool `protobuf:"varint,2,opt,name=cancel,proto3" json:"cancel,omitempty"`
	// contains filtered or unexported fields
}

type SubscribeResponse struct {
	Tag     *Tag     `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	Dataset *Dataset `protobuf:"bytes,2,opt,name=dataset,proto3" json:"dataset,omitempty"`
	// contains filtered or unexported fields
}

type Tag struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`       // name and optional scope of the dataset (example: @scope/name)
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` // the version of the dataset (example: qa, prod, latest, v21.09, etc)
	// contains filtered or unexported fields
}

type UnimplementedDatasetAPIServer struct {
}

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