gravity_sdk_types_projection

Documentation

Index

• func ConvertToRecord(pj *Projection, record *gravity_sdk_types_record.Record) error
• func Marshal(pj *Projection) ([]byte, error)
• func StrToBytes(s string) []byte
• func Unmarshal(data []byte, pj *Projection) error
• type Field
• type JSONResult
• type Projection
  • func (pj *Projection) GetPayload() map[string]interface{}
  • func (pj *Projection) ToJSON() ([]byte, error)
  • func (pj *Projection) ToRecord() (*gravity_sdk_types_record.Record, error)

Functions

func ConvertToRecord

func ConvertToRecord(pj *Projection, record *gravity_sdk_types_record.Record) error

func Marshal

func Marshal(pj *Projection) ([]byte, error)

func StrToBytes

func StrToBytes(s string) []byte

func Unmarshal

func Unmarshal(data []byte, pj *Projection) error

Types

type Field

type Field struct {
	Name    string      `json:"name"`
	Value   interface{} `json:"value"`
	Primary bool        `json:"primary"`
}

type JSONResult

type JSONResult struct {
	EventName  string                 `json:"event"`
	Collection string                 `json:"collection"`
	Payload    map[string]interface{} `json:"payload"`
	Meta       map[string][]byte      `json:"meta"`
}

type Projection

type Projection struct {
	EventName  string            `json:"event"`
	Collection string            `json:"collection"`
	Method     string            `json:"method"`
	PrimaryKey string            `json:"primaryKey"`
	Fields     []Field           `json:"fields"`
	Meta       map[string][]byte `json:"meta"`
}

func (*Projection) GetPayload

func (pj *Projection) GetPayload() map[string]interface{}

func (*Projection) ToJSON

func (pj *Projection) ToJSON() ([]byte, error)

func (*Projection) ToRecord

func (pj *Projection) ToRecord() (*gravity_sdk_types_record.Record, error)