Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Event ¶
type Event struct { // The data blob. The data in the blob is both opaque and immutable to Kinesis // Data Streams, which does not inspect, interpret, or change the data in the // blob in any way. When the data blob (the payload before base64-encoding) // is added to the partition key size, the total size must not exceed the maximum // record size (1 MiB). // Data is automatically base64 encoded/decoded by the SDK. // // Data is a required field Data string `json:"data"` }
type Repository ¶
var Repo *Repository
func (Repository) DeleteSqsMsg ¶
func (r Repository) DeleteSqsMsg( ctx context.Context, receipt string, ) error
func (Repository) ReceiveSqsMsg ¶
type Revision ¶
type Revision struct { BlockAddress RevisionBlockAddress `ion:"blockAddress"` Hash []byte `ion:"hash"` Data interface{} `ion:"data"` RevisionMetadata RevisionMetadata `ion:"metadata"` }
type RevisionBlockAddress ¶
type RevisionMetadata ¶
type RevisionRecordPayload ¶
type StreamRecord ¶
Click to show internal directories.
Click to hide internal directories.