store

package
v0.7.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 17, 2021 License: MPL-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package store provides storage types/behavior for the oplog

Index

Constants

This section is empty.

Variables

View Source 
var File_controller_storage_oplog_store_v1_oplog_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Entry 

type Entry struct {

	// @inject_tag: gorm:"primary_key"
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty" gorm:"primary_key"`
	// @inject_tag: `gorm:"default:current_timestamp"`
	CreateTime *timestamp.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty" gorm:"default:current_timestamp"`
	// @inject_tag: `gorm:"default:current_timestamp"`
	UpdateTime *timestamp.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty" gorm:"default:current_timestamp"`
	// @inject_tag: gorm:"not_null"
	Version string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty" gorm:"not_null"`
	// @inject_tat: gorm:"not_null"
	AggregateName string `protobuf:"bytes,5,opt,name=aggregate_name,json=aggregateName,proto3" json:"aggregate_name,omitempty"`
	// one to many relationship
	// @inject_tag: gorm:"foreignkey:entry_id"
	Metadata []*Metadata `protobuf:"bytes,6,rep,name=metadata,proto3" json:"metadata,omitempty" gorm:"foreignkey:entry_id"`
	// ciphertext entry data stored in the database
	// @inject_tag: gorm:"column:data;not_null" wrapping:"ct,entry_data"
	CtData []byte `` /* 132-byte string literal not displayed */
	// plain text version of the decrypted entry data
	// we are NOT storing this plain-text entry data in the db
	// @inject_tag: gorm:"-" wrapping:"pt,entry_data"
	Data []byte `protobuf:"bytes,8,opt,name=data,proto3" json:"data,omitempty" gorm:"-" wrapping:"pt,entry_data"`
	// contains filtered or unexported fields
}

Entry provides a message for oplog entries that's compatible with gorm

func (*Entry) Descriptor deprecated 

func (*Entry) Descriptor() ([]byte, []int)

Deprecated: Use Entry.ProtoReflect.Descriptor instead.

func (*Entry) GetAggregateName 

func (x *Entry) GetAggregateName() string

func (*Entry) GetCreateTime 

func (x *Entry) GetCreateTime() *timestamp.Timestamp

func (*Entry) GetCtData 

func (x *Entry) GetCtData() []byte

func (*Entry) GetData 

func (x *Entry) GetData() []byte

func (*Entry) GetId 

func (x *Entry) GetId() uint32

func (*Entry) GetMetadata 

func (x *Entry) GetMetadata() []*Metadata

func (*Entry) GetUpdateTime 

func (x *Entry) GetUpdateTime() *timestamp.Timestamp

func (*Entry) GetVersion 

func (x *Entry) GetVersion() string

func (*Entry) ProtoMessage 

func (*Entry) ProtoMessage()

func (*Entry) ProtoReflect 

func (x *Entry) ProtoReflect() protoreflect.Message

func (*Entry) Reset 

func (x *Entry) Reset()

func (*Entry) String 

func (x *Entry) String() string

func (*Entry) TableName 

func (*Entry) TableName() string

TableName overrides the gorm database table for the store.Oplog messages

type Metadata 

type Metadata struct {

	// @inject_tag: gorm:"primary_key"
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty" gorm:"primary_key"`
	// @inject_tag: `gorm:"default:current_timestamp"`
	CreateTime *timestamp.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty" gorm:"default:current_timestamp"` // @inject_tag: gorm:"not_nul
	EntryId    uint32               `protobuf:"varint,3,opt,name=entry_id,json=entryId,proto3" json:"entry_id,omitempty"`
	// @inject_tag: gorm:"foreignkey:EntryId"
	Entry *Entry `protobuf:"bytes,4,opt,name=entry,proto3" json:"entry,omitempty" gorm:"foreignkey:EntryId"`
	// @inject_tag: gorm:"not_null"
	Key string `protobuf:"bytes,5,opt,name=key,proto3" json:"key,omitempty" gorm:"not_null"`
	// @inject_tag: gorm:"not_null"
	Value string `protobuf:"bytes,6,opt,name=value,proto3" json:"value,omitempty" gorm:"not_null"`
	// contains filtered or unexported fields
}

Metadata provides a message for oplog metadata that's compatible with gorm

func (*Metadata) Descriptor deprecated 

func (*Metadata) Descriptor() ([]byte, []int)

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetCreateTime 

func (x *Metadata) GetCreateTime() *timestamp.Timestamp

func (*Metadata) GetEntry 

func (x *Metadata) GetEntry() *Entry

func (*Metadata) GetEntryId 

func (x *Metadata) GetEntryId() uint32

func (*Metadata) GetId 

func (x *Metadata) GetId() uint32

func (*Metadata) GetKey 

func (x *Metadata) GetKey() string

func (*Metadata) GetValue 

func (x *Metadata) GetValue() string

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect 

func (x *Metadata) ProtoReflect() protoreflect.Message

func (*Metadata) Reset 

func (x *Metadata) Reset()

func (*Metadata) String 

func (x *Metadata) String() string

func (*Metadata) TableName 

func (*Metadata) TableName() string

TableName overrides the gorm database table for the store.Metadata messages

type Ticket 

type Ticket struct {

	// @inject_tag: gorm:"primary_key"
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty" gorm:"primary_key"`
	// @inject_tag: `gorm:"default:current_timestamp"`
	CreateTime *timestamp.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty" gorm:"default:current_timestamp"`
	// @inject_tag: `gorm:"default:current_timestamp"`
	UpdateTime *timestamp.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty" gorm:"default:current_timestamp"`
	// @inject_tat: gorm:"not_null"
	Name string `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`
	// @inject_tat: gorm:"not_null;default:'1'"
	Version uint32 `protobuf:"varint,7,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

Ticket provides a message for oplog tickets that's compatible with gorm

func (*Ticket) Descriptor deprecated 

func (*Ticket) Descriptor() ([]byte, []int)

Deprecated: Use Ticket.ProtoReflect.Descriptor instead.

func (*Ticket) GetCreateTime 

func (x *Ticket) GetCreateTime() *timestamp.Timestamp

func (*Ticket) GetId 

func (x *Ticket) GetId() uint32

func (*Ticket) GetName 

func (x *Ticket) GetName() string

func (*Ticket) GetUpdateTime 

func (x *Ticket) GetUpdateTime() *timestamp.Timestamp

func (*Ticket) GetVersion 

func (x *Ticket) GetVersion() uint32

func (*Ticket) ProtoMessage 

func (*Ticket) ProtoMessage()

func (*Ticket) ProtoReflect 

func (x *Ticket) ProtoReflect() protoreflect.Message

func (*Ticket) Reset 

func (x *Ticket) Reset()

func (*Ticket) String 

func (x *Ticket) String() string

func (*Ticket) TableName 

func (*Ticket) TableName() string

TableName overrides the gorm database table for the store.Ticket messages

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.