| /dports/www/mattermost-server/mattermost-server-6.0.2/app/ |
| H A D | cluster_discovery.go | 18 model.ClusterDiscovery anonMember
25 ClusterDiscovery: model.ClusterDiscovery{},
38 err := cds.srv.Store.ClusterDiscovery().Cleanup()
43 exists, err := cds.srv.Store.ClusterDiscovery().Exists(&cds.ClusterDiscovery)
47 if _, err := cds.srv.Store.ClusterDiscovery().Delete(&cds.ClusterDiscovery); err != nil {
52 if err := cds.srv.Store.ClusterDiscovery().Save(&cds.ClusterDiscovery); err != nil {
53 …overyService failed to save", mlog.String("ClusterDiscoveryID", cds.ClusterDiscovery.Id), mlog.Err…
58 …rDiscoveryService ping writer started", mlog.String("ClusterDiscoveryID", cds.ClusterDiscovery.Id))
62 if _, err := cds.srv.Store.ClusterDiscovery().Delete(&cds.ClusterDiscovery); err != nil {
65 …rDiscoveryService ping writer stopped", mlog.String("ClusterDiscoveryID", cds.ClusterDiscovery.Id))
[all …]
|
| /dports/www/mattermost-server/mattermost-server-6.0.2/store/storetest/ |
| H A D | cluster_discovery_store.go | 26 discovery := &model.ClusterDiscovery{
32 err := ss.ClusterDiscovery().Save(discovery)
35 err = ss.ClusterDiscovery().Cleanup()
40 discovery := &model.ClusterDiscovery{
54 discovery := &model.ClusterDiscovery{
79 discovery2 := &model.ClusterDiscovery{
90 discovery := &model.ClusterDiscovery{
113 discovery1 := &model.ClusterDiscovery{
120 discovery2 := &model.ClusterDiscovery{
127 discovery3 := &model.ClusterDiscovery{
[all …]
|
| H A D | store.go | 69 func (s *Store) ClusterDiscovery() store.ClusterDiscoveryStore { return &s.ClusterDiscoveryStor… func
|
| /dports/www/mattermost-server/mattermost-server-6.0.2/store/sqlstore/ |
| H A D | cluster_discovery_store.go | 32 func (s sqlClusterDiscoveryStore) Save(ClusterDiscovery *model.ClusterDiscovery) error {
33 ClusterDiscovery.PreSave()
34 if err := ClusterDiscovery.IsValid(); err != nil {
44 func (s sqlClusterDiscoveryStore) Delete(ClusterDiscovery *model.ClusterDiscovery) (bool, error) {
47 Where(sq.Eq{"Type": ClusterDiscovery.Type}).
49 Where(sq.Eq{"Hostname": ClusterDiscovery.Hostname})
66 func (s sqlClusterDiscoveryStore) Exists(ClusterDiscovery *model.ClusterDiscovery) (bool, error) {
70 Where(sq.Eq{"Type": ClusterDiscovery.Type}).
102 var list []*model.ClusterDiscovery
109 func (s sqlClusterDiscoveryStore) SetLastPingAt(ClusterDiscovery *model.ClusterDiscovery) error {
[all …]
|
| H A D | store.go | 1233 func (ss *SqlStore) ClusterDiscovery() store.ClusterDiscoveryStore { func
|
| /dports/net-im/matterircd/matterircd-0.25.0/vendor/github.com/mattermost/mattermost-server/v5/model/ |
| H A D | cluster_discovery.go | 18 type ClusterDiscovery struct { struct
29 func (o *ClusterDiscovery) PreSave() { argument
40 func (o *ClusterDiscovery) AutoFillHostname() { argument
49 func (o *ClusterDiscovery) AutoFillIpAddress(iface string, ipAddress string) { argument
60 func (o *ClusterDiscovery) IsEqual(in *ClusterDiscovery) bool { argument
80 func FilterClusterDiscovery(vs []*ClusterDiscovery, f func(*ClusterDiscovery) bool) []*ClusterDisco… argument
81 copy := make([]*ClusterDiscovery, 0)
91 func (o *ClusterDiscovery) IsValid() *AppError { argument
119 func (o *ClusterDiscovery) ToJson() string { argument
128 func ClusterDiscoveryFromJson(data io.Reader) *ClusterDiscovery {
[all …]
|
| /dports/net-im/matterbridge/matterbridge-1.22.3/vendor/github.com/mattermost/mattermost-server/v5/model/ |
| H A D | cluster_discovery.go | 18 type ClusterDiscovery struct { struct
29 func (o *ClusterDiscovery) PreSave() { argument
40 func (o *ClusterDiscovery) AutoFillHostname() { argument
49 func (o *ClusterDiscovery) AutoFillIpAddress(iface string, ipAddress string) { argument
60 func (o *ClusterDiscovery) IsEqual(in *ClusterDiscovery) bool { argument
80 func FilterClusterDiscovery(vs []*ClusterDiscovery, f func(*ClusterDiscovery) bool) []*ClusterDisco… argument
81 copy := make([]*ClusterDiscovery, 0)
91 func (o *ClusterDiscovery) IsValid() *AppError { argument
119 func (o *ClusterDiscovery) ToJson() string { argument
128 func ClusterDiscoveryFromJson(data io.Reader) *ClusterDiscovery {
[all …]
|
| /dports/www/mattermost-server/mattermost-server-6.0.2/store/storetest/mocks/ |
| H A D | ClusterDiscoveryStore.go | 32 func (_m *ClusterDiscoveryStore) Delete(discovery *model.ClusterDiscovery) (bool, error) {
36 if rf, ok := ret.Get(0).(func(*model.ClusterDiscovery) bool); ok {
43 if rf, ok := ret.Get(1).(func(*model.ClusterDiscovery) error); ok {
57 if rf, ok := ret.Get(0).(func(*model.ClusterDiscovery) bool); ok {
64 if rf, ok := ret.Get(1).(func(*model.ClusterDiscovery) error); ok {
77 var r0 []*model.ClusterDiscovery
78 if rf, ok := ret.Get(0).(func(string, string) []*model.ClusterDiscovery); ok {
82 r0 = ret.Get(0).([]*model.ClusterDiscovery)
97 func (_m *ClusterDiscoveryStore) Save(discovery *model.ClusterDiscovery) error {
101 if rf, ok := ret.Get(0).(func(*model.ClusterDiscovery) error); ok {
[all …]
|
| H A D | Store.go | 109 func (_m *Store) ClusterDiscovery() store.ClusterDiscoveryStore { func
|
| /dports/net-im/matterircd/matterircd-0.25.0/vendor/github.com/mattermost/mattermost-server/v6/model/ |
| H A D | cluster_discovery.go | 16 type ClusterDiscovery struct { struct
27 func (o *ClusterDiscovery) PreSave() { argument
38 func (o *ClusterDiscovery) AutoFillHostname() { argument
47 func (o *ClusterDiscovery) AutoFillIPAddress(iface string, ipAddress string) { argument
58 func (o *ClusterDiscovery) IsEqual(in *ClusterDiscovery) bool { argument
78 func FilterClusterDiscovery(vs []*ClusterDiscovery, f func(*ClusterDiscovery) bool) []*ClusterDisco… argument
79 copy := make([]*ClusterDiscovery, 0)
89 func (o *ClusterDiscovery) IsValid() *AppError { argument
|
| /dports/www/mattermost-server/mattermost-server-6.0.2/model/ |
| H A D | cluster_discovery.go | 16 type ClusterDiscovery struct { struct
27 func (o *ClusterDiscovery) PreSave() { argument
38 func (o *ClusterDiscovery) AutoFillHostname() { argument
47 func (o *ClusterDiscovery) AutoFillIPAddress(iface string, ipAddress string) { argument
58 func (o *ClusterDiscovery) IsEqual(in *ClusterDiscovery) bool { argument
78 func FilterClusterDiscovery(vs []*ClusterDiscovery, f func(*ClusterDiscovery) bool) []*ClusterDisco… argument
79 copy := make([]*ClusterDiscovery, 0)
89 func (o *ClusterDiscovery) IsValid() *AppError { argument
|
| H A D | cluster_discovery_test.go | 13 o := ClusterDiscovery{
31 list := make([]*ClusterDiscovery, 0)
37 rlist := FilterClusterDiscovery(list, func(in *ClusterDiscovery) bool {
|
| /dports/www/mattermost-server/mattermost-server-6.0.2/scripts/ |
| H A D | mattermost-mysql-5.0.sql | 152 DROP TABLE IF EXISTS `ClusterDiscovery`;
155 CREATE TABLE `ClusterDiscovery` (
172 LOCK TABLES `ClusterDiscovery` WRITE;
|
| H A D | mattermost-mysql-6.0.sql | 134 CREATE TABLE `ClusterDiscovery` (
|
| /dports/www/mattermost-server/mattermost-server-6.0.2/store/ |
| H A D | store.go | 31 ClusterDiscovery() ClusterDiscoveryStore methodSpec
465 Save(discovery *model.ClusterDiscovery) error argument
466 Delete(discovery *model.ClusterDiscovery) (bool, error) argument
467 Exists(discovery *model.ClusterDiscovery) (bool, error) argument
468 GetAll(discoveryType, clusterName string) ([]*model.ClusterDiscovery, error)
469 SetLastPingAt(discovery *model.ClusterDiscovery) error argument
|
| /dports/www/mattermost-server/mattermost-server-6.0.2/store/retrylayer/ |
| H A D | retrylayer.go | 78 func (s *RetryLayer) ClusterDiscovery() store.ClusterDiscoveryStore { func
2631 func (s *RetryLayerClusterDiscoveryStore) Delete(discovery *model.ClusterDiscovery) (bool, error) {
2651 func (s *RetryLayerClusterDiscoveryStore) Exists(discovery *model.ClusterDiscovery) (bool, error) {
2671 …scoveryStore) GetAll(discoveryType string, clusterName string) ([]*model.ClusterDiscovery, error) {
2691 func (s *RetryLayerClusterDiscoveryStore) Save(discovery *model.ClusterDiscovery) error {
2711 func (s *RetryLayerClusterDiscoveryStore) SetLastPingAt(discovery *model.ClusterDiscovery) error {
12514 … &RetryLayerClusterDiscoveryStore{ClusterDiscoveryStore: childStore.ClusterDiscovery(), Root: &new…
|
| /dports/www/mattermost-server/mattermost-server-6.0.2/store/timerlayer/ |
| H A D | timerlayer.go | 76 func (s *TimerLayer) ClusterDiscovery() store.ClusterDiscoveryStore { func
2273 func (s *TimerLayerClusterDiscoveryStore) Delete(discovery *model.ClusterDiscovery) (bool, error) {
2289 func (s *TimerLayerClusterDiscoveryStore) Exists(discovery *model.ClusterDiscovery) (bool, error) {
2305 …scoveryStore) GetAll(discoveryType string, clusterName string) ([]*model.ClusterDiscovery, error) {
2321 func (s *TimerLayerClusterDiscoveryStore) Save(discovery *model.ClusterDiscovery) error {
2337 func (s *TimerLayerClusterDiscoveryStore) SetLastPingAt(discovery *model.ClusterDiscovery) error {
10389 … &TimerLayerClusterDiscoveryStore{ClusterDiscoveryStore: childStore.ClusterDiscovery(), Root: &new…
|
| /dports/www/mattermost-server/mattermost-server-6.0.2/store/opentracinglayer/ |
| H A D | opentracinglayer.go | 76 func (s *OpenTracingLayer) ClusterDiscovery() store.ClusterDiscoveryStore { func
2467 func (s *OpenTracingLayerClusterDiscoveryStore) Delete(discovery *model.ClusterDiscovery) (bool, er…
2485 func (s *OpenTracingLayerClusterDiscoveryStore) Exists(discovery *model.ClusterDiscovery) (bool, er…
2503 …scoveryStore) GetAll(discoveryType string, clusterName string) ([]*model.ClusterDiscovery, error) {
2521 func (s *OpenTracingLayerClusterDiscoveryStore) Save(discovery *model.ClusterDiscovery) error {
2539 func (s *OpenTracingLayerClusterDiscoveryStore) SetLastPingAt(discovery *model.ClusterDiscovery) er…
11519 …TracingLayerClusterDiscoveryStore{ClusterDiscoveryStore: childStore.ClusterDiscovery(), Root: &new…
|