proto

package
v0.0.0-...-102eb4e Latest Latest
Warning

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

 Go to latest Published: Oct 18, 2023 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterDirectoryServerServer 

func RegisterDirectoryServerServer(s *grpc.Server, srv DirectoryServerServer)

func RegisterPolicyStoreServer 

func RegisterPolicyStoreServer(s *grpc.Server, srv PolicyStoreServer)

Types

type Client 

type Client struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ID                   string   `protobuf:"bytes,2,opt,name=ID,proto3" json:"ID,omitempty"`
	EmailAddress         string   `protobuf:"bytes,3,opt,name=emailAddress,proto3" json:"emailAddress,omitempty"`
	MacAddress           string   `protobuf:"bytes,4,opt,name=macAddress,proto3" json:"macAddress,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Client) Descriptor 

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

func (*Client) GetEmailAddress 

func (m *Client) GetEmailAddress() string

func (*Client) GetID 

func (m *Client) GetID() string

func (*Client) GetMacAddress 

func (m *Client) GetMacAddress() string

func (*Client) GetName 

func (m *Client) GetName() string

func (*Client) ProtoMessage 

func (*Client) ProtoMessage()

func (*Client) Reset 

func (m *Client) Reset()

func (*Client) String 

func (m *Client) String() string

func (*Client) XXX_DiscardUnknown 

func (m *Client) XXX_DiscardUnknown()

func (*Client) XXX_Marshal 

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

func (*Client) XXX_Merge 

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

func (*Client) XXX_Size 

func (m *Client) XXX_Size() int

func (*Client) XXX_Unmarshal 

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

type ClientState 

type ClientState struct {
	LastPolicyUpdate     *timestamp.Timestamp `protobuf:"bytes,1,opt,name=LastPolicyUpdate,proto3" json:"LastPolicyUpdate,omitempty"`
	LastComplyCheck      *timestamp.Timestamp `protobuf:"bytes,2,opt,name=LastComplyCheck,proto3" json:"LastComplyCheck,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ClientState) Descriptor 

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

func (*ClientState) GetLastComplyCheck 

func (m *ClientState) GetLastComplyCheck() *timestamp.Timestamp

func (*ClientState) GetLastPolicyUpdate 

func (m *ClientState) GetLastPolicyUpdate() *timestamp.Timestamp

func (*ClientState) ProtoMessage 

func (*ClientState) ProtoMessage()

func (*ClientState) Reset 

func (m *ClientState) Reset()

func (*ClientState) String 

func (m *ClientState) String() string

func (*ClientState) XXX_DiscardUnknown 

func (m *ClientState) XXX_DiscardUnknown()

func (*ClientState) XXX_Marshal 

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

func (*ClientState) XXX_Merge 

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

func (*ClientState) XXX_Size 

func (m *ClientState) XXX_Size() int

func (*ClientState) XXX_Unmarshal 

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

type Dataset 

type Dataset struct {
	Identifier             string   `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
	Policy                 *Policy  `protobuf:"bytes,2,opt,name=policy,proto3" json:"policy,omitempty"`
	AllowMultipleCheckouts bool     `protobuf:"varint,3,opt,name=allowMultipleCheckouts,proto3" json:"allowMultipleCheckouts,omitempty"`
	XXX_NoUnkeyedLiteral   struct{} `json:"-"`
	XXX_unrecognized       []byte   `json:"-"`
	XXX_sizecache          int32    `json:"-"`
}

func (*Dataset) Descriptor 

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

func (*Dataset) GetAllowMultipleCheckouts 

func (m *Dataset) GetAllowMultipleCheckouts() bool

func (*Dataset) GetIdentifier 

func (m *Dataset) GetIdentifier() string

func (*Dataset) GetPolicy 

func (m *Dataset) GetPolicy() *Policy

func (*Dataset) ProtoMessage 

func (*Dataset) ProtoMessage()

func (*Dataset) Reset 

func (m *Dataset) Reset()

func (*Dataset) String 

func (m *Dataset) String() string

func (*Dataset) XXX_DiscardUnknown 

func (m *Dataset) XXX_DiscardUnknown()

func (*Dataset) XXX_Marshal 

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

func (*Dataset) XXX_Merge 

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

func (*Dataset) XXX_Size 

func (m *Dataset) XXX_Size() int

func (*Dataset) XXX_Unmarshal 

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

type DatasetCheckout 

type DatasetCheckout struct {
	DatasetIdentifier    string               `protobuf:"bytes,1,opt,name=datasetIdentifier,proto3" json:"datasetIdentifier,omitempty"`
	DateCheckout         *timestamp.Timestamp `protobuf:"bytes,3,opt,name=DateCheckout,proto3" json:"DateCheckout,omitempty"`
	Client               *Client              `protobuf:"bytes,4,opt,name=client,proto3" json:"client,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*DatasetCheckout) Descriptor 

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

func (*DatasetCheckout) GetClient 

func (m *DatasetCheckout) GetClient() *Client

func (*DatasetCheckout) GetDatasetIdentifier 

func (m *DatasetCheckout) GetDatasetIdentifier() string

func (*DatasetCheckout) GetDateCheckout 

func (m *DatasetCheckout) GetDateCheckout() *timestamp.Timestamp

func (*DatasetCheckout) ProtoMessage 

func (*DatasetCheckout) ProtoMessage()

func (*DatasetCheckout) Reset 

func (m *DatasetCheckout) Reset()

func (*DatasetCheckout) String 

func (m *DatasetCheckout) String() string

func (*DatasetCheckout) XXX_DiscardUnknown 

func (m *DatasetCheckout) XXX_DiscardUnknown()

func (*DatasetCheckout) XXX_Marshal 

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

func (*DatasetCheckout) XXX_Merge 

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

func (*DatasetCheckout) XXX_Size 

func (m *DatasetCheckout) XXX_Size() int

func (*DatasetCheckout) XXX_Unmarshal 

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

type DatasetCollectionSummary 

type DatasetCollectionSummary struct {
	DatasetMap           map[string]*Dataset `` /* 161-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

Send from the node to LDS/PS

func (*DatasetCollectionSummary) Descriptor 

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

func (*DatasetCollectionSummary) GetDatasetMap 

func (m *DatasetCollectionSummary) GetDatasetMap() map[string]*Dataset

func (*DatasetCollectionSummary) ProtoMessage 

func (*DatasetCollectionSummary) ProtoMessage()

func (*DatasetCollectionSummary) Reset 

func (m *DatasetCollectionSummary) Reset()

func (*DatasetCollectionSummary) String 

func (m *DatasetCollectionSummary) String() string

func (*DatasetCollectionSummary) XXX_DiscardUnknown 

func (m *DatasetCollectionSummary) XXX_DiscardUnknown()

func (*DatasetCollectionSummary) XXX_Marshal 

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

func (*DatasetCollectionSummary) XXX_Merge 

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

func (*DatasetCollectionSummary) XXX_Size 

func (m *DatasetCollectionSummary) XXX_Size() int

func (*DatasetCollectionSummary) XXX_Unmarshal 

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

type DatasetRequest 

type DatasetRequest struct {
	Identifier           string        `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
	ClientToken          []byte        `protobuf:"bytes,2,opt,name=clientToken,proto3" json:"clientToken,omitempty"`
	Signature            *MsgSignature `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*DatasetRequest) Descriptor 

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

func (*DatasetRequest) GetClientToken 

func (m *DatasetRequest) GetClientToken() []byte

func (*DatasetRequest) GetIdentifier 

func (m *DatasetRequest) GetIdentifier() string

func (*DatasetRequest) GetSignature 

func (m *DatasetRequest) GetSignature() *MsgSignature

func (*DatasetRequest) ProtoMessage 

func (*DatasetRequest) ProtoMessage()

func (*DatasetRequest) Reset 

func (m *DatasetRequest) Reset()

func (*DatasetRequest) String 

func (m *DatasetRequest) String() string

func (*DatasetRequest) XXX_DiscardUnknown 

func (m *DatasetRequest) XXX_DiscardUnknown()

func (*DatasetRequest) XXX_Marshal 

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

func (*DatasetRequest) XXX_Merge 

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

func (*DatasetRequest) XXX_Size 

func (m *DatasetRequest) XXX_Size() int

func (*DatasetRequest) XXX_Unmarshal 

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

type DatasetResponse 

type DatasetResponse struct {
	Type                 string        `protobuf:"bytes,1,opt,name=Type,proto3" json:"Type,omitempty"`
	URL                  string        `protobuf:"bytes,2,opt,name=URL,proto3" json:"URL,omitempty"`
	IsAllowed            bool          `protobuf:"varint,3,opt,name=isAllowed,proto3" json:"isAllowed,omitempty"`
	ErrorMessage         string        `protobuf:"bytes,4,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"`
	Signature            *MsgSignature `protobuf:"bytes,5,opt,name=signature,proto3" json:"signature,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*DatasetResponse) Descriptor 

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

func (*DatasetResponse) GetErrorMessage 

func (m *DatasetResponse) GetErrorMessage() string

func (*DatasetResponse) GetIsAllowed 

func (m *DatasetResponse) GetIsAllowed() bool

func (*DatasetResponse) GetSignature 

func (m *DatasetResponse) GetSignature() *MsgSignature

func (*DatasetResponse) GetType 

func (m *DatasetResponse) GetType() string

func (*DatasetResponse) GetURL 

func (m *DatasetResponse) GetURL() string

func (*DatasetResponse) ProtoMessage 

func (*DatasetResponse) ProtoMessage()

func (*DatasetResponse) Reset 

func (m *DatasetResponse) Reset()

func (*DatasetResponse) String 

func (m *DatasetResponse) String() string

func (*DatasetResponse) XXX_DiscardUnknown 

func (m *DatasetResponse) XXX_DiscardUnknown()

func (*DatasetResponse) XXX_Marshal 

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

func (*DatasetResponse) XXX_Merge 

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

func (*DatasetResponse) XXX_Size 

func (m *DatasetResponse) XXX_Size() int

func (*DatasetResponse) XXX_Unmarshal 

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

type DirectoryServerClient 

type DirectoryServerClient interface {
	Handshake(ctx context.Context, in *Node, opts ...grpc.CallOption) (*HandshakeResponse, error)
}

DirectoryServerClient is the client API for DirectoryServer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDirectoryServerClient 

func NewDirectoryServerClient(cc *grpc.ClientConn) DirectoryServerClient

type DirectoryServerServer 

type DirectoryServerServer interface {
	Handshake(context.Context, *Node) (*HandshakeResponse, error)
}

DirectoryServerServer is the server API for DirectoryServer service.

type GossipMessage 

type GossipMessage struct {
	Sender               string               `protobuf:"bytes,1,opt,name=Sender,proto3" json:"Sender,omitempty"`
	MessageType          string               `protobuf:"bytes,2,opt,name=MessageType,proto3" json:"MessageType,omitempty"`
	DateSent             *timestamp.Timestamp `protobuf:"bytes,3,opt,name=DateSent,proto3" json:"DateSent,omitempty"`
	Signature            *MsgSignature        `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
	GossipMessageBody    []*GossipMessageBody `protobuf:"bytes,5,rep,name=gossipMessageBody,proto3" json:"gossipMessageBody,omitempty"`
	GossipMessageID      *GossipMessageID     `protobuf:"bytes,6,opt,name=gossipMessageID,proto3" json:"gossipMessageID,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Fix later

func (*GossipMessage) Descriptor 

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

func (*GossipMessage) GetDateSent 

func (m *GossipMessage) GetDateSent() *timestamp.Timestamp

func (*GossipMessage) GetGossipMessageBody 

func (m *GossipMessage) GetGossipMessageBody() []*GossipMessageBody

func (*GossipMessage) GetGossipMessageID 

func (m *GossipMessage) GetGossipMessageID() *GossipMessageID

func (*GossipMessage) GetMessageType 

func (m *GossipMessage) GetMessageType() string

func (*GossipMessage) GetSender 

func (m *GossipMessage) GetSender() string

func (*GossipMessage) GetSignature 

func (m *GossipMessage) GetSignature() *MsgSignature

func (*GossipMessage) ProtoMessage 

func (*GossipMessage) ProtoMessage()

func (*GossipMessage) Reset 

func (m *GossipMessage) Reset()

func (*GossipMessage) String 

func (m *GossipMessage) String() string

func (*GossipMessage) XXX_DiscardUnknown 

func (m *GossipMessage) XXX_DiscardUnknown()

func (*GossipMessage) XXX_Marshal 

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

func (*GossipMessage) XXX_Merge 

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

func (*GossipMessage) XXX_Size 

func (m *GossipMessage) XXX_Size() int

func (*GossipMessage) XXX_Unmarshal 

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

type GossipMessageBody 

type GossipMessageBody struct {
	Policy               *Policy  `protobuf:"bytes,1,opt,name=policy,proto3" json:"policy,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GossipMessageBody) Descriptor 

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

func (*GossipMessageBody) GetPolicy 

func (m *GossipMessageBody) GetPolicy() *Policy

func (*GossipMessageBody) ProtoMessage 

func (*GossipMessageBody) ProtoMessage()

func (*GossipMessageBody) Reset 

func (m *GossipMessageBody) Reset()

func (*GossipMessageBody) String 

func (m *GossipMessageBody) String() string

func (*GossipMessageBody) XXX_DiscardUnknown 

func (m *GossipMessageBody) XXX_DiscardUnknown()

func (*GossipMessageBody) XXX_Marshal 

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

func (*GossipMessageBody) XXX_Merge 

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

func (*GossipMessageBody) XXX_Size 

func (m *GossipMessageBody) XXX_Size() int

func (*GossipMessageBody) XXX_Unmarshal 

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

type GossipMessageID 

type GossipMessageID struct {
	PolicyStoreID        string   `protobuf:"bytes,1,opt,name=PolicyStoreID,proto3" json:"PolicyStoreID,omitempty"`
	SequenceNumber       int32    `protobuf:"varint,2,opt,name=SequenceNumber,proto3" json:"SequenceNumber,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GossipMessageID) Descriptor 

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

func (*GossipMessageID) GetPolicyStoreID 

func (m *GossipMessageID) GetPolicyStoreID() string

func (*GossipMessageID) GetSequenceNumber 

func (m *GossipMessageID) GetSequenceNumber() int32

func (*GossipMessageID) ProtoMessage 

func (*GossipMessageID) ProtoMessage()

func (*GossipMessageID) Reset 

func (m *GossipMessageID) Reset()

func (*GossipMessageID) String 

func (m *GossipMessageID) String() string

func (*GossipMessageID) XXX_DiscardUnknown 

func (m *GossipMessageID) XXX_DiscardUnknown()

func (*GossipMessageID) XXX_Marshal 

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

func (*GossipMessageID) XXX_Merge 

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

func (*GossipMessageID) XXX_Size 

func (m *GossipMessageID) XXX_Size() int

func (*GossipMessageID) XXX_Unmarshal 

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

type HandshakeResponse 

type HandshakeResponse struct {
	Ip                   string   `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	Id                   []byte   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HandshakeResponse) Descriptor 

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

func (*HandshakeResponse) GetId 

func (m *HandshakeResponse) GetId() []byte

func (*HandshakeResponse) GetIp 

func (m *HandshakeResponse) GetIp() string

func (*HandshakeResponse) ProtoMessage 

func (*HandshakeResponse) ProtoMessage()

func (*HandshakeResponse) Reset 

func (m *HandshakeResponse) Reset()

func (*HandshakeResponse) String 

func (m *HandshakeResponse) String() string

func (*HandshakeResponse) XXX_DiscardUnknown 

func (m *HandshakeResponse) XXX_DiscardUnknown()

func (*HandshakeResponse) XXX_Marshal 

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

func (*HandshakeResponse) XXX_Merge 

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

func (*HandshakeResponse) XXX_Size 

func (m *HandshakeResponse) XXX_Size() int

func (*HandshakeResponse) XXX_Unmarshal 

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

type MembershipState 

type MembershipState struct {
	JoinTime             *timestamp.Timestamp `protobuf:"bytes,1,opt,name=joinTime,proto3" json:"joinTime,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

TODO all messages below here should be put in its separate package that concerns consistency in the network. It should be treated as a lower-level abstraction.

func (*MembershipState) Descriptor 

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

func (*MembershipState) GetJoinTime 

func (m *MembershipState) GetJoinTime() *timestamp.Timestamp

func (*MembershipState) ProtoMessage 

func (*MembershipState) ProtoMessage()

func (*MembershipState) Reset 

func (m *MembershipState) Reset()

func (*MembershipState) String 

func (m *MembershipState) String() string

func (*MembershipState) XXX_DiscardUnknown 

func (m *MembershipState) XXX_DiscardUnknown()

func (*MembershipState) XXX_Marshal 

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

func (*MembershipState) XXX_Merge 

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

func (*MembershipState) XXX_Size 

func (m *MembershipState) XXX_Size() int

func (*MembershipState) XXX_Unmarshal 

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

type Message 

type Message struct {
	Type            string           `protobuf:"bytes,1,opt,name=Type,proto3" json:"Type,omitempty"`
	Sender          *Node            `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"`
	Policy          *Policy          `protobuf:"bytes,3,opt,name=policy,proto3" json:"policy,omitempty"`
	Signature       *MsgSignature    `protobuf:"bytes,5,opt,name=signature,proto3" json:"signature,omitempty"`
	GossipMessage   *GossipMessage   `protobuf:"bytes,6,opt,name=gossipMessage,proto3" json:"gossipMessage,omitempty"`
	Probe           *Probe           `protobuf:"bytes,7,opt,name=probe,proto3" json:"probe,omitempty"`
	DatasetRequest  *DatasetRequest  `protobuf:"bytes,8,opt,name=datasetRequest,proto3" json:"datasetRequest,omitempty"`
	DatasetResponse *DatasetResponse `protobuf:"bytes,9,opt,name=datasetResponse,proto3" json:"datasetResponse,omitempty"`
	PolicyRequest   *PolicyRequest   `protobuf:"bytes,10,opt,name=policyRequest,proto3" json:"policyRequest,omitempty"`
	//DatasetIdentifierStateRequest datasetIdentifierStateRequest = 11;
	//    DatasetDeltaRequest datasetDeltaRequest = 11;
	//    DatasetDeltaResponse DatasetDeltaResponse = 12;
	DatasetCollectionSummary *DatasetCollectionSummary `protobuf:"bytes,13,opt,name=datasetCollectionSummary,proto3" json:"datasetCollectionSummary,omitempty"`
	// Other fields
	StringValue          string   `protobuf:"bytes,14,opt,name=stringValue,proto3" json:"stringValue,omitempty"`
	StringSlice          []string `protobuf:"bytes,15,rep,name=stringSlice,proto3" json:"stringSlice,omitempty"`
	Bytes                []byte   `protobuf:"bytes,16,opt,name=Bytes,proto3" json:"Bytes,omitempty"`
	BytesSlice           [][]byte `protobuf:"bytes,17,rep,name=BytesSlice,proto3" json:"BytesSlice,omitempty"`
	BoolValue            bool     `protobuf:"varint,18,opt,name=boolValue,proto3" json:"boolValue,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Used in direct messaging

func (*Message) Descriptor 

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

func (*Message) GetBoolValue 

func (m *Message) GetBoolValue() bool

func (*Message) GetBytes 

func (m *Message) GetBytes() []byte

func (*Message) GetBytesSlice 

func (m *Message) GetBytesSlice() [][]byte

func (*Message) GetDatasetCollectionSummary 

func (m *Message) GetDatasetCollectionSummary() *DatasetCollectionSummary

func (*Message) GetDatasetRequest 

func (m *Message) GetDatasetRequest() *DatasetRequest

func (*Message) GetDatasetResponse 

func (m *Message) GetDatasetResponse() *DatasetResponse

func (*Message) GetGossipMessage 

func (m *Message) GetGossipMessage() *GossipMessage

func (*Message) GetPolicy 

func (m *Message) GetPolicy() *Policy

func (*Message) GetPolicyRequest 

func (m *Message) GetPolicyRequest() *PolicyRequest

func (*Message) GetProbe 

func (m *Message) GetProbe() *Probe

func (*Message) GetSender 

func (m *Message) GetSender() *Node

func (*Message) GetSignature 

func (m *Message) GetSignature() *MsgSignature

func (*Message) GetStringSlice 

func (m *Message) GetStringSlice() []string

func (*Message) GetStringValue 

func (m *Message) GetStringValue() string

func (*Message) GetType 

func (m *Message) GetType() string

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) String 

func (m *Message) String() string

func (*Message) XXX_DiscardUnknown 

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal 

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

func (*Message) XXX_Merge 

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

func (*Message) XXX_Size 

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal 

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

type MetadataRequest 

type MetadataRequest struct {
	Identifier           string        `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
	ClientToken          []byte        `protobuf:"bytes,2,opt,name=clientToken,proto3" json:"clientToken,omitempty"`
	Signature            *MsgSignature `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*MetadataRequest) Descriptor 

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

func (*MetadataRequest) GetClientToken 

func (m *MetadataRequest) GetClientToken() []byte

func (*MetadataRequest) GetIdentifier 

func (m *MetadataRequest) GetIdentifier() string

func (*MetadataRequest) GetSignature 

func (m *MetadataRequest) GetSignature() *MsgSignature

func (*MetadataRequest) ProtoMessage 

func (*MetadataRequest) ProtoMessage()

func (*MetadataRequest) Reset 

func (m *MetadataRequest) Reset()

func (*MetadataRequest) String 

func (m *MetadataRequest) String() string

func (*MetadataRequest) XXX_DiscardUnknown 

func (m *MetadataRequest) XXX_DiscardUnknown()

func (*MetadataRequest) XXX_Marshal 

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

func (*MetadataRequest) XXX_Merge 

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

func (*MetadataRequest) XXX_Size 

func (m *MetadataRequest) XXX_Size() int

func (*MetadataRequest) XXX_Unmarshal 

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

type MetadataResponse 

type MetadataResponse struct {
	URL                  string        `protobuf:"bytes,1,opt,name=URL,proto3" json:"URL,omitempty"`
	Signature            *MsgSignature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*MetadataResponse) Descriptor 

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

func (*MetadataResponse) GetSignature 

func (m *MetadataResponse) GetSignature() *MsgSignature

func (*MetadataResponse) GetURL 

func (m *MetadataResponse) GetURL() string

func (*MetadataResponse) ProtoMessage 

func (*MetadataResponse) ProtoMessage()

func (*MetadataResponse) Reset 

func (m *MetadataResponse) Reset()

func (*MetadataResponse) String 

func (m *MetadataResponse) String() string

func (*MetadataResponse) XXX_DiscardUnknown 

func (m *MetadataResponse) XXX_DiscardUnknown()

func (*MetadataResponse) XXX_Marshal 

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

func (*MetadataResponse) XXX_Merge 

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

func (*MetadataResponse) XXX_Size 

func (m *MetadataResponse) XXX_Size() int

func (*MetadataResponse) XXX_Unmarshal 

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

type MsgSignature 

type MsgSignature struct {
	R                    []byte   `protobuf:"bytes,1,opt,name=r,proto3" json:"r,omitempty"`
	S                    []byte   `protobuf:"bytes,2,opt,name=s,proto3" json:"s,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MsgSignature) Descriptor 

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

func (*MsgSignature) GetR 

func (m *MsgSignature) GetR() []byte

func (*MsgSignature) GetS 

func (m *MsgSignature) GetS() []byte

func (*MsgSignature) ProtoMessage 

func (*MsgSignature) ProtoMessage()

func (*MsgSignature) Reset 

func (m *MsgSignature) Reset()

func (*MsgSignature) String 

func (m *MsgSignature) String() string

func (*MsgSignature) XXX_DiscardUnknown 

func (m *MsgSignature) XXX_DiscardUnknown()

func (*MsgSignature) XXX_Marshal 

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

func (*MsgSignature) XXX_Merge 

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

func (*MsgSignature) XXX_Size 

func (m *MsgSignature) XXX_Size() int

func (*MsgSignature) XXX_Unmarshal 

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

type Node 

type Node struct {
	Name                 string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	IfritAddress         string               `protobuf:"bytes,2,opt,name=ifritAddress,proto3" json:"ifritAddress,omitempty"`
	Id                   []byte               `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	HttpsAddress         string               `protobuf:"bytes,4,opt,name=httpsAddress,proto3" json:"httpsAddress,omitempty"`
	Port                 int32                `protobuf:"varint,5,opt,name=port,proto3" json:"port,omitempty"`
	BootTime             *timestamp.Timestamp `protobuf:"bytes,6,opt,name=bootTime,proto3" json:"bootTime,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Here, node is Lohpi storage nodes, policy store and mux (and compliance engine?)

func (*Node) Descriptor 

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

func (*Node) GetBootTime 

func (m *Node) GetBootTime() *timestamp.Timestamp

func (*Node) GetHttpsAddress 

func (m *Node) GetHttpsAddress() string

func (*Node) GetId 

func (m *Node) GetId() []byte

func (*Node) GetIfritAddress 

func (m *Node) GetIfritAddress() string

func (*Node) GetName 

func (m *Node) GetName() string

func (*Node) GetPort 

func (m *Node) GetPort() int32

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) String 

func (m *Node) String() string

func (*Node) XXX_DiscardUnknown 

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal 

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

func (*Node) XXX_Merge 

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

func (*Node) XXX_Size 

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal 

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

type Policy 

type Policy struct {
	DatasetIdentifier    string               `protobuf:"bytes,2,opt,name=datasetIdentifier,proto3" json:"datasetIdentifier,omitempty"`
	Content              bool                 `protobuf:"varint,3,opt,name=content,proto3" json:"content,omitempty"`
	Version              uint64               `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"`
	DateCreated          *timestamp.Timestamp `protobuf:"bytes,5,opt,name=DateCreated,proto3" json:"DateCreated,omitempty"`
	DateApplied          *timestamp.Timestamp `protobuf:"bytes,6,opt,name=DateApplied,proto3" json:"DateApplied,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Policy) Descriptor 

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

func (*Policy) GetContent 

func (m *Policy) GetContent() bool

func (*Policy) GetDatasetIdentifier 

func (m *Policy) GetDatasetIdentifier() string

func (*Policy) GetDateApplied 

func (m *Policy) GetDateApplied() *timestamp.Timestamp

func (*Policy) GetDateCreated 

func (m *Policy) GetDateCreated() *timestamp.Timestamp

func (*Policy) GetVersion 

func (m *Policy) GetVersion() uint64

func (*Policy) ProtoMessage 

func (*Policy) ProtoMessage()

func (*Policy) Reset 

func (m *Policy) Reset()

func (*Policy) String 

func (m *Policy) String() string

func (*Policy) XXX_DiscardUnknown 

func (m *Policy) XXX_DiscardUnknown()

func (*Policy) XXX_Marshal 

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

func (*Policy) XXX_Merge 

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

func (*Policy) XXX_Size 

func (m *Policy) XXX_Size() int

func (*Policy) XXX_Unmarshal 

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

type PolicyRequest 

type PolicyRequest struct {
	Identifier           string   `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PolicyRequest) Descriptor 

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

func (*PolicyRequest) GetIdentifier 

func (m *PolicyRequest) GetIdentifier() string

func (*PolicyRequest) ProtoMessage 

func (*PolicyRequest) ProtoMessage()

func (*PolicyRequest) Reset 

func (m *PolicyRequest) Reset()

func (*PolicyRequest) String 

func (m *PolicyRequest) String() string

func (*PolicyRequest) XXX_DiscardUnknown 

func (m *PolicyRequest) XXX_DiscardUnknown()

func (*PolicyRequest) XXX_Marshal 

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

func (*PolicyRequest) XXX_Merge 

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

func (*PolicyRequest) XXX_Size 

func (m *PolicyRequest) XXX_Size() int

func (*PolicyRequest) XXX_Unmarshal 

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

type PolicyStoreClient 

type PolicyStoreClient interface {
	Handshake(ctx context.Context, in *Node, opts ...grpc.CallOption) (*HandshakeResponse, error)
}

PolicyStoreClient is the client API for PolicyStore service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPolicyStoreClient 

func NewPolicyStoreClient(cc *grpc.ClientConn) PolicyStoreClient

type PolicyStoreServer 

type PolicyStoreServer interface {
	Handshake(context.Context, *Node) (*HandshakeResponse, error)
}

PolicyStoreServer is the server API for PolicyStore service.

type Probe 

type Probe struct {
	Order                uint32   `protobuf:"varint,1,opt,name=order,proto3" json:"order,omitempty"`
	SessionId            []byte   `protobuf:"bytes,2,opt,name=sessionId,proto3" json:"sessionId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Probe) Descriptor 

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

func (*Probe) GetOrder 

func (m *Probe) GetOrder() uint32

func (*Probe) GetSessionId 

func (m *Probe) GetSessionId() []byte

func (*Probe) ProtoMessage 

func (*Probe) ProtoMessage()

func (*Probe) Reset 

func (m *Probe) Reset()

func (*Probe) String 

func (m *Probe) String() string

func (*Probe) XXX_DiscardUnknown 

func (m *Probe) XXX_DiscardUnknown()

func (*Probe) XXX_Marshal 

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

func (*Probe) XXX_Merge 

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

func (*Probe) XXX_Size 

func (m *Probe) XXX_Size() int

func (*Probe) XXX_Unmarshal 

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

type Response 

type Response struct {
	Signature            *MsgSignature `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty"`
	StringValue          string        `protobuf:"bytes,2,opt,name=stringValue,proto3" json:"stringValue,omitempty"`
	StringSlice          []string      `protobuf:"bytes,3,rep,name=stringSlice,proto3" json:"stringSlice,omitempty"`
	BytesValue           []byte        `protobuf:"bytes,4,opt,name=bytesValue,proto3" json:"bytesValue,omitempty"`
	BytesSlice           [][]byte      `protobuf:"bytes,5,rep,name=bytesSlice,proto3" json:"bytesSlice,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*Response) Descriptor 

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

func (*Response) GetBytesSlice 

func (m *Response) GetBytesSlice() [][]byte

func (*Response) GetBytesValue 

func (m *Response) GetBytesValue() []byte

func (*Response) GetSignature 

func (m *Response) GetSignature() *MsgSignature

func (*Response) GetStringSlice 

func (m *Response) GetStringSlice() []string

func (*Response) GetStringValue 

func (m *Response) GetStringValue() string

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) String 

func (m *Response) String() string

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

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

func (*Response) XXX_Merge 

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

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

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

type UnimplementedDirectoryServerServer 

type UnimplementedDirectoryServerServer struct {
}

UnimplementedDirectoryServerServer can be embedded to have forward compatible implementations.

func (*UnimplementedDirectoryServerServer) Handshake 

func (*UnimplementedDirectoryServerServer) Handshake(ctx context.Context, req *Node) (*HandshakeResponse, error)

type UnimplementedPolicyStoreServer 

type UnimplementedPolicyStoreServer struct {
}

UnimplementedPolicyStoreServer can be embedded to have forward compatible implementations.

func (*UnimplementedPolicyStoreServer) Handshake 

func (*UnimplementedPolicyStoreServer) Handshake(ctx context.Context, req *Node) (*HandshakeResponse, error)

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.