snapshot

Documentation

Index

• Variables
• type Phase
  • func (Phase) EnumDescriptor() ([]byte, []int)
  • func (x Phase) String() string
• type RetentionOptions
  • func (*RetentionOptions) Descriptor() ([]byte, []int)
  • func (m *RetentionOptions) GetRetainWindow() *time.Duration
  • func (m *RetentionOptions) Marshal() (dAtA []byte, err error)
  • func (m *RetentionOptions) MarshalTo(dAtA []byte) (int, error)
  • func (m *RetentionOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RetentionOptions) ProtoMessage()
  • func (m *RetentionOptions) Reset()
  • func (m *RetentionOptions) Size() (n int)
  • func (m *RetentionOptions) String() string
  • func (m *RetentionOptions) Unmarshal(dAtA []byte) error
  • func (m *RetentionOptions) XXX_DiscardUnknown()
  • func (m *RetentionOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RetentionOptions) XXX_Merge(src proto.Message)
  • func (m *RetentionOptions) XXX_Size() int
  • func (m *RetentionOptions) XXX_Unmarshal(b []byte) error
• type State
  • func (State) EnumDescriptor() ([]byte, []int)
  • func (x State) String() string
• type Status
  • func (*Status) Descriptor() ([]byte, []int)
  • func (m *Status) GetPhase() Phase
  • func (m *Status) GetState() State
  • func (m *Status) Marshal() (dAtA []byte, err error)
  • func (m *Status) MarshalTo(dAtA []byte) (int, error)
  • func (m *Status) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*Status) ProtoMessage()
  • func (m *Status) Reset()
  • func (m *Status) Size() (n int)
  • func (m *Status) String() string
  • func (m *Status) Unmarshal(dAtA []byte) error
  • func (m *Status) XXX_DiscardUnknown()
  • func (m *Status) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Status) XXX_Merge(src proto.Message)
  • func (m *Status) XXX_Size() int
  • func (m *Status) XXX_Unmarshal(b []byte) error

Variables

var (
	ErrInvalidLengthTypes        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group")
)

var Phase_name = map[int32]string{
	0: "MARK",
	1: "DELETE",
}

var Phase_value = map[string]int32{
	"MARK":   0,
	"DELETE": 1,
}

var State_name = map[int32]string{
	0: "PENDING",
	1: "RUNNING",
	2: "COMPLETE",
}

var State_value = map[string]int32{
	"PENDING":  0,
	"RUNNING":  1,
	"COMPLETE": 2,
}

Types

type Phase

type Phase int32

Phase is a snapshot phase

const (
	// MARK is the first phase in which changes are marked for deletion
	Phase_MARK Phase = 0
	// DELETE is the second phase in which changes are deleted from stores
	Phase_DELETE Phase = 1
)

func (Phase) EnumDescriptor

func (Phase) EnumDescriptor() ([]byte, []int)

func (Phase) String

func (x Phase) String() string

type RetentionOptions

type RetentionOptions struct {
	// 'retain_window' is the duration for which to retain network changes
	RetainWindow *time.Duration `protobuf:"bytes,1,opt,name=retain_window,json=retainWindow,proto3,stdduration" json:"retain_window,omitempty"`
}

RetentionOptions specifies the retention policy for a change log

func (*RetentionOptions) Descriptor

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

func (*RetentionOptions) GetRetainWindow

func (m *RetentionOptions) GetRetainWindow() *time.Duration

func (*RetentionOptions) Marshal

func (m *RetentionOptions) Marshal() (dAtA []byte, err error)

func (*RetentionOptions) MarshalTo

func (m *RetentionOptions) MarshalTo(dAtA []byte) (int, error)

func (*RetentionOptions) MarshalToSizedBuffer

func (m *RetentionOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RetentionOptions) ProtoMessage

func (*RetentionOptions) ProtoMessage()

func (*RetentionOptions) Reset

func (m *RetentionOptions) Reset()

func (*RetentionOptions) Size

func (m *RetentionOptions) Size() (n int)

func (*RetentionOptions) String

func (m *RetentionOptions) String() string

func (*RetentionOptions) Unmarshal

func (m *RetentionOptions) Unmarshal(dAtA []byte) error

func (*RetentionOptions) XXX_DiscardUnknown

func (m *RetentionOptions) XXX_DiscardUnknown()

func (*RetentionOptions) XXX_Marshal

func (m *RetentionOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RetentionOptions) XXX_Merge

func (m *RetentionOptions) XXX_Merge(src proto.Message)

func (*RetentionOptions) XXX_Size

func (m *RetentionOptions) XXX_Size() int

func (*RetentionOptions) XXX_Unmarshal

func (m *RetentionOptions) XXX_Unmarshal(b []byte) error

type State

type State int32

State is the state of a snapshot within a phase

const (
	// PENDING indicates the snapshot is pending
	State_PENDING State = 0
	// RUNNING indicates the snapshot is in progress
	State_RUNNING State = 1
	// COMPLETE indicates the snapshot is complete
	State_COMPLETE State = 2
)

func (State) EnumDescriptor

func (State) EnumDescriptor() ([]byte, []int)

func (State) String

func (x State) String() string

type Status

type Status struct {
	// 'phase' is the snapshot phase
	Phase Phase `protobuf:"varint,1,opt,name=phase,proto3,enum=onos.config.snapshot.Phase" json:"phase,omitempty"`
	// 'state' is the state of a snapshot
	State State `protobuf:"varint,2,opt,name=state,proto3,enum=onos.config.snapshot.State" json:"state,omitempty"`
}

Status is the status of a snapshot

func (*Status) Descriptor

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

func (*Status) GetPhase

func (m *Status) GetPhase() Phase

func (*Status) GetState

func (m *Status) GetState() State

func (*Status) Marshal

func (m *Status) Marshal() (dAtA []byte, err error)

func (*Status) MarshalTo

func (m *Status) MarshalTo(dAtA []byte) (int, error)

func (*Status) MarshalToSizedBuffer

func (m *Status) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Status) ProtoMessage

func (*Status) ProtoMessage()

func (*Status) Reset

func (m *Status) Reset()

func (*Status) Size

func (m *Status) Size() (n int)

func (*Status) String

func (m *Status) String() string

func (*Status) Unmarshal

func (m *Status) Unmarshal(dAtA []byte) error

func (*Status) XXX_DiscardUnknown

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal

func (m *Status) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Status) XXX_Merge

func (m *Status) XXX_Merge(src proto.Message)

func (*Status) XXX_Size

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal

func (m *Status) XXX_Unmarshal(b []byte) error