datastream

Nov 21, 2024

Changes in this version

type CallOptions

+ RunStream []gax.CallOption

type Client

+ func (c *Client) RunStream(ctx context.Context, req *datastreampb.RunStreamRequest, ...) (*RunStreamOperation, error)

+ func (c *Client) RunStreamOperation(name string) *RunStreamOperation

+ type RunStreamOperation struct

+ func (op *RunStreamOperation) Done() bool

+ func (op *RunStreamOperation) Metadata() (*datastreampb.OperationMetadata, error)

+ func (op *RunStreamOperation) Name() string

+ func (op *RunStreamOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*datastreampb.Stream, error)

+ func (op *RunStreamOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*datastreampb.Stream, error)

Sep 12, 2024

Changes in this version

type ConnectionProfileIterator

+ func (it *ConnectionProfileIterator) All() iter.Seq2[*datastreampb.ConnectionProfile, error]

type LocationIterator

+ func (it *LocationIterator) All() iter.Seq2[*locationpb.Location, error]

type OperationIterator

+ func (it *OperationIterator) All() iter.Seq2[*longrunningpb.Operation, error]

type PrivateConnectionIterator

+ func (it *PrivateConnectionIterator) All() iter.Seq2[*datastreampb.PrivateConnection, error]

type RouteIterator

+ func (it *RouteIterator) All() iter.Seq2[*datastreampb.Route, error]

type StreamIterator

+ func (it *StreamIterator) All() iter.Seq2[*datastreampb.Stream, error]

type StreamObjectIterator

+ func (it *StreamObjectIterator) All() iter.Seq2[*datastreampb.StreamObject, error]

type StringIterator

+ func (it *StringIterator) All() iter.Seq2[string, error]

Mar 15, 2023

Changes in this version

+ type IamPolicyCallOptions struct

+ CancelOperation []gax.CallOption

+ DeleteOperation []gax.CallOption

+ GetIamPolicy []gax.CallOption

+ GetLocation []gax.CallOption

+ GetOperation []gax.CallOption

+ ListLocations []gax.CallOption

+ ListOperations []gax.CallOption

+ SetIamPolicy []gax.CallOption

+ TestIamPermissions []gax.CallOption

+ type IamPolicyClient struct

+ CallOptions *IamPolicyCallOptions

+ func NewIamPolicyClient(ctx context.Context, opts ...option.ClientOption) (*IamPolicyClient, error)

+ func NewIamPolicyRESTClient(ctx context.Context, opts ...option.ClientOption) (*IamPolicyClient, error)

+ func (c *IamPolicyClient) CancelOperation(ctx context.Context, req *longrunningpb.CancelOperationRequest, ...) error

+ func (c *IamPolicyClient) Close() error

+ func (c *IamPolicyClient) Connection() *grpc.ClientConn

+ func (c *IamPolicyClient) DeleteOperation(ctx context.Context, req *longrunningpb.DeleteOperationRequest, ...) error

+ func (c *IamPolicyClient) GetIamPolicy(ctx context.Context, req *iampb.GetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)

+ func (c *IamPolicyClient) GetLocation(ctx context.Context, req *locationpb.GetLocationRequest, ...) (*locationpb.Location, error)

+ func (c *IamPolicyClient) GetOperation(ctx context.Context, req *longrunningpb.GetOperationRequest, ...) (*longrunningpb.Operation, error)

+ func (c *IamPolicyClient) ListLocations(ctx context.Context, req *locationpb.ListLocationsRequest, ...) *LocationIterator

+ func (c *IamPolicyClient) ListOperations(ctx context.Context, req *longrunningpb.ListOperationsRequest, ...) *OperationIterator

+ func (c *IamPolicyClient) SetIamPolicy(ctx context.Context, req *iampb.SetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)

+ func (c *IamPolicyClient) TestIamPermissions(ctx context.Context, req *iampb.TestIamPermissionsRequest, ...) (*iampb.TestIamPermissionsResponse, error)

Jan 5, 2023

Changes in this version

type Client

+ func NewRESTClient(ctx context.Context, opts ...option.ClientOption) (*Client, error)

Sep 6, 2022

Changes in this version

type CallOptions

+ CancelOperation []gax.CallOption

+ DeleteOperation []gax.CallOption

+ GetOperation []gax.CallOption

+ ListOperations []gax.CallOption

type Client

+ func (c *Client) CancelOperation(ctx context.Context, req *longrunningpb.CancelOperationRequest, ...) error

+ func (c *Client) DeleteOperation(ctx context.Context, req *longrunningpb.DeleteOperationRequest, ...) error

+ func (c *Client) GetOperation(ctx context.Context, req *longrunningpb.GetOperationRequest, ...) (*longrunningpb.Operation, error)

+ func (c *Client) ListOperations(ctx context.Context, req *longrunningpb.ListOperationsRequest, ...) *OperationIterator

+ type OperationIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*longrunningpb.Operation, nextPageToken string, err error)

+ Response interface{}

+ func (it *OperationIterator) Next() (*longrunningpb.Operation, error)

+ func (it *OperationIterator) PageInfo() *iterator.PageInfo

May 10, 2022

Changes in this version

+ func DefaultAuthScopes() []string

+ type CallOptions struct

+ CreateConnectionProfile []gax.CallOption

+ CreatePrivateConnection []gax.CallOption

+ CreateRoute []gax.CallOption

+ CreateStream []gax.CallOption

+ DeleteConnectionProfile []gax.CallOption

+ DeletePrivateConnection []gax.CallOption

+ DeleteRoute []gax.CallOption

+ DeleteStream []gax.CallOption

+ DiscoverConnectionProfile []gax.CallOption

+ FetchStaticIps []gax.CallOption

+ GetConnectionProfile []gax.CallOption

+ GetLocation []gax.CallOption

+ GetPrivateConnection []gax.CallOption

+ GetRoute []gax.CallOption

+ GetStream []gax.CallOption

+ GetStreamObject []gax.CallOption

+ ListConnectionProfiles []gax.CallOption

+ ListLocations []gax.CallOption

+ ListPrivateConnections []gax.CallOption

+ ListRoutes []gax.CallOption

+ ListStreamObjects []gax.CallOption

+ ListStreams []gax.CallOption

+ LookupStreamObject []gax.CallOption

+ StartBackfillJob []gax.CallOption

+ StopBackfillJob []gax.CallOption

+ UpdateConnectionProfile []gax.CallOption

+ UpdateStream []gax.CallOption

+ type Client struct

+ CallOptions *CallOptions

+ LROClient *lroauto.OperationsClient

+ func NewClient(ctx context.Context, opts ...option.ClientOption) (*Client, error)

+ func (c *Client) Close() error

+ func (c *Client) Connection() *grpc.ClientConn

+ func (c *Client) CreateConnectionProfile(ctx context.Context, req *datastreampb.CreateConnectionProfileRequest, ...) (*CreateConnectionProfileOperation, error)

+ func (c *Client) CreateConnectionProfileOperation(name string) *CreateConnectionProfileOperation

+ func (c *Client) CreatePrivateConnection(ctx context.Context, req *datastreampb.CreatePrivateConnectionRequest, ...) (*CreatePrivateConnectionOperation, error)

+ func (c *Client) CreatePrivateConnectionOperation(name string) *CreatePrivateConnectionOperation

+ func (c *Client) CreateRoute(ctx context.Context, req *datastreampb.CreateRouteRequest, ...) (*CreateRouteOperation, error)

+ func (c *Client) CreateRouteOperation(name string) *CreateRouteOperation

+ func (c *Client) CreateStream(ctx context.Context, req *datastreampb.CreateStreamRequest, ...) (*CreateStreamOperation, error)

+ func (c *Client) CreateStreamOperation(name string) *CreateStreamOperation

+ func (c *Client) DeleteConnectionProfile(ctx context.Context, req *datastreampb.DeleteConnectionProfileRequest, ...) (*DeleteConnectionProfileOperation, error)

+ func (c *Client) DeleteConnectionProfileOperation(name string) *DeleteConnectionProfileOperation

+ func (c *Client) DeletePrivateConnection(ctx context.Context, req *datastreampb.DeletePrivateConnectionRequest, ...) (*DeletePrivateConnectionOperation, error)

+ func (c *Client) DeletePrivateConnectionOperation(name string) *DeletePrivateConnectionOperation

+ func (c *Client) DeleteRoute(ctx context.Context, req *datastreampb.DeleteRouteRequest, ...) (*DeleteRouteOperation, error)

+ func (c *Client) DeleteRouteOperation(name string) *DeleteRouteOperation

+ func (c *Client) DeleteStream(ctx context.Context, req *datastreampb.DeleteStreamRequest, ...) (*DeleteStreamOperation, error)

+ func (c *Client) DeleteStreamOperation(name string) *DeleteStreamOperation

+ func (c *Client) DiscoverConnectionProfile(ctx context.Context, req *datastreampb.DiscoverConnectionProfileRequest, ...) (*datastreampb.DiscoverConnectionProfileResponse, error)

+ func (c *Client) FetchStaticIps(ctx context.Context, req *datastreampb.FetchStaticIpsRequest, ...) *StringIterator

+ func (c *Client) GetConnectionProfile(ctx context.Context, req *datastreampb.GetConnectionProfileRequest, ...) (*datastreampb.ConnectionProfile, error)

+ func (c *Client) GetLocation(ctx context.Context, req *locationpb.GetLocationRequest, ...) (*locationpb.Location, error)

+ func (c *Client) GetPrivateConnection(ctx context.Context, req *datastreampb.GetPrivateConnectionRequest, ...) (*datastreampb.PrivateConnection, error)

+ func (c *Client) GetRoute(ctx context.Context, req *datastreampb.GetRouteRequest, opts ...gax.CallOption) (*datastreampb.Route, error)

+ func (c *Client) GetStream(ctx context.Context, req *datastreampb.GetStreamRequest, ...) (*datastreampb.Stream, error)

+ func (c *Client) GetStreamObject(ctx context.Context, req *datastreampb.GetStreamObjectRequest, ...) (*datastreampb.StreamObject, error)

+ func (c *Client) ListConnectionProfiles(ctx context.Context, req *datastreampb.ListConnectionProfilesRequest, ...) *ConnectionProfileIterator

+ func (c *Client) ListLocations(ctx context.Context, req *locationpb.ListLocationsRequest, ...) *LocationIterator

+ func (c *Client) ListPrivateConnections(ctx context.Context, req *datastreampb.ListPrivateConnectionsRequest, ...) *PrivateConnectionIterator

+ func (c *Client) ListRoutes(ctx context.Context, req *datastreampb.ListRoutesRequest, ...) *RouteIterator

+ func (c *Client) ListStreamObjects(ctx context.Context, req *datastreampb.ListStreamObjectsRequest, ...) *StreamObjectIterator

+ func (c *Client) ListStreams(ctx context.Context, req *datastreampb.ListStreamsRequest, ...) *StreamIterator

+ func (c *Client) LookupStreamObject(ctx context.Context, req *datastreampb.LookupStreamObjectRequest, ...) (*datastreampb.StreamObject, error)

+ func (c *Client) StartBackfillJob(ctx context.Context, req *datastreampb.StartBackfillJobRequest, ...) (*datastreampb.StartBackfillJobResponse, error)

+ func (c *Client) StopBackfillJob(ctx context.Context, req *datastreampb.StopBackfillJobRequest, ...) (*datastreampb.StopBackfillJobResponse, error)

+ func (c *Client) UpdateConnectionProfile(ctx context.Context, req *datastreampb.UpdateConnectionProfileRequest, ...) (*UpdateConnectionProfileOperation, error)

+ func (c *Client) UpdateConnectionProfileOperation(name string) *UpdateConnectionProfileOperation

+ func (c *Client) UpdateStream(ctx context.Context, req *datastreampb.UpdateStreamRequest, ...) (*UpdateStreamOperation, error)

+ func (c *Client) UpdateStreamOperation(name string) *UpdateStreamOperation

+ type ConnectionProfileIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*datastreampb.ConnectionProfile, nextPageToken string, err error)

+ Response interface{}

+ func (it *ConnectionProfileIterator) Next() (*datastreampb.ConnectionProfile, error)

+ func (it *ConnectionProfileIterator) PageInfo() *iterator.PageInfo

+ type CreateConnectionProfileOperation struct

+ func (op *CreateConnectionProfileOperation) Done() bool

+ func (op *CreateConnectionProfileOperation) Metadata() (*datastreampb.OperationMetadata, error)

+ func (op *CreateConnectionProfileOperation) Name() string

+ func (op *CreateConnectionProfileOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*datastreampb.ConnectionProfile, error)

+ func (op *CreateConnectionProfileOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*datastreampb.ConnectionProfile, error)

+ type CreatePrivateConnectionOperation struct

+ func (op *CreatePrivateConnectionOperation) Done() bool

+ func (op *CreatePrivateConnectionOperation) Metadata() (*datastreampb.OperationMetadata, error)

+ func (op *CreatePrivateConnectionOperation) Name() string

+ func (op *CreatePrivateConnectionOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*datastreampb.PrivateConnection, error)

+ func (op *CreatePrivateConnectionOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*datastreampb.PrivateConnection, error)

+ type CreateRouteOperation struct

+ func (op *CreateRouteOperation) Done() bool

+ func (op *CreateRouteOperation) Metadata() (*datastreampb.OperationMetadata, error)

+ func (op *CreateRouteOperation) Name() string

+ func (op *CreateRouteOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*datastreampb.Route, error)

+ func (op *CreateRouteOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*datastreampb.Route, error)

+ type CreateStreamOperation struct

+ func (op *CreateStreamOperation) Done() bool

+ func (op *CreateStreamOperation) Metadata() (*datastreampb.OperationMetadata, error)

+ func (op *CreateStreamOperation) Name() string

+ func (op *CreateStreamOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*datastreampb.Stream, error)

+ func (op *CreateStreamOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*datastreampb.Stream, error)

+ type DeleteConnectionProfileOperation struct

+ func (op *DeleteConnectionProfileOperation) Done() bool

+ func (op *DeleteConnectionProfileOperation) Metadata() (*datastreampb.OperationMetadata, error)

+ func (op *DeleteConnectionProfileOperation) Name() string

+ func (op *DeleteConnectionProfileOperation) Poll(ctx context.Context, opts ...gax.CallOption) error

+ func (op *DeleteConnectionProfileOperation) Wait(ctx context.Context, opts ...gax.CallOption) error

+ type DeletePrivateConnectionOperation struct

+ func (op *DeletePrivateConnectionOperation) Done() bool

+ func (op *DeletePrivateConnectionOperation) Metadata() (*datastreampb.OperationMetadata, error)

+ func (op *DeletePrivateConnectionOperation) Name() string

+ func (op *DeletePrivateConnectionOperation) Poll(ctx context.Context, opts ...gax.CallOption) error

+ func (op *DeletePrivateConnectionOperation) Wait(ctx context.Context, opts ...gax.CallOption) error

+ type DeleteRouteOperation struct

+ func (op *DeleteRouteOperation) Done() bool

+ func (op *DeleteRouteOperation) Metadata() (*datastreampb.OperationMetadata, error)

+ func (op *DeleteRouteOperation) Name() string

+ func (op *DeleteRouteOperation) Poll(ctx context.Context, opts ...gax.CallOption) error

+ func (op *DeleteRouteOperation) Wait(ctx context.Context, opts ...gax.CallOption) error

+ type DeleteStreamOperation struct

+ func (op *DeleteStreamOperation) Done() bool

+ func (op *DeleteStreamOperation) Metadata() (*datastreampb.OperationMetadata, error)

+ func (op *DeleteStreamOperation) Name() string

+ func (op *DeleteStreamOperation) Poll(ctx context.Context, opts ...gax.CallOption) error

+ func (op *DeleteStreamOperation) Wait(ctx context.Context, opts ...gax.CallOption) error

+ type LocationIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*locationpb.Location, nextPageToken string, err error)

+ Response interface{}

+ func (it *LocationIterator) Next() (*locationpb.Location, error)

+ func (it *LocationIterator) PageInfo() *iterator.PageInfo

+ type PrivateConnectionIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*datastreampb.PrivateConnection, nextPageToken string, err error)

+ Response interface{}

+ func (it *PrivateConnectionIterator) Next() (*datastreampb.PrivateConnection, error)

+ func (it *PrivateConnectionIterator) PageInfo() *iterator.PageInfo

+ type RouteIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*datastreampb.Route, nextPageToken string, err error)

+ Response interface{}

+ func (it *RouteIterator) Next() (*datastreampb.Route, error)

+ func (it *RouteIterator) PageInfo() *iterator.PageInfo

+ type StreamIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*datastreampb.Stream, nextPageToken string, err error)

+ Response interface{}

+ func (it *StreamIterator) Next() (*datastreampb.Stream, error)

+ func (it *StreamIterator) PageInfo() *iterator.PageInfo

+ type StreamObjectIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*datastreampb.StreamObject, nextPageToken string, err error)

+ Response interface{}

+ func (it *StreamObjectIterator) Next() (*datastreampb.StreamObject, error)

+ func (it *StreamObjectIterator) PageInfo() *iterator.PageInfo

+ type StringIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []string, nextPageToken string, err error)

+ Response interface{}

+ func (it *StringIterator) Next() (string, error)

+ func (it *StringIterator) PageInfo() *iterator.PageInfo

+ type UpdateConnectionProfileOperation struct

+ func (op *UpdateConnectionProfileOperation) Done() bool

+ func (op *UpdateConnectionProfileOperation) Metadata() (*datastreampb.OperationMetadata, error)

+ func (op *UpdateConnectionProfileOperation) Name() string

+ func (op *UpdateConnectionProfileOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*datastreampb.ConnectionProfile, error)

+ func (op *UpdateConnectionProfileOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*datastreampb.ConnectionProfile, error)

+ type UpdateStreamOperation struct

+ func (op *UpdateStreamOperation) Done() bool

+ func (op *UpdateStreamOperation) Metadata() (*datastreampb.OperationMetadata, error)

+ func (op *UpdateStreamOperation) Name() string

+ func (op *UpdateStreamOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*datastreampb.Stream, error)

+ func (op *UpdateStreamOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*datastreampb.Stream, error)