utils

Documentation

Index

• Constants
• func Push2Stream(stream string, b []byte) (*kinesis.PutRecordOutput, error)
• func Save2Table(it interface{}, tab string) (*dynamodb.PutItemOutput, error)

Constants

const (
	TackerchangeitemsColTaskId          = "task_id"
	TackerchangeitemsColOwner           = "owner"
	TackerchangeitemsColTtitle          = "title"
	TackerchangeitemsColTaskDescription = "task_description"
	TackerchangeitemsColTaskPrevstatus  = "task_prev_status"
	TackerchangeitemsColTaskAfterstatus = "task_after_status"
	TackerchangeitemsColTaskUpdate      = "task_update"
)

Column name of table - tackerChangeItems

const TackerChangeItems = "tackerChangeItems"

TackerChangeItems is table name in DynamoDB

Functions

func Push2Stream

func Push2Stream(stream string, b []byte) (*kinesis.PutRecordOutput, error)

Push2Stream is pushing change records into Kinesis stream

func Save2Table

func Save2Table(it interface{}, tab string) (*dynamodb.PutItemOutput, error)

Save2Table is saving records into DynamoDB table - tackerChangeItems